public class org.apache.nifi.processors.compress.ModifyCompression extends org.apache.nifi.processor.AbstractProcessor
{
public static final org.apache.nifi.components.PropertyDescriptor INPUT_COMPRESSION_STRATEGY;
public static final org.apache.nifi.components.PropertyDescriptor OUTPUT_COMPRESSION_STRATEGY;
public static final org.apache.nifi.components.PropertyDescriptor OUTPUT_COMPRESSION_LEVEL;
public static final org.apache.nifi.components.PropertyDescriptor OUTPUT_FILENAME_STRATEGY;
public static final org.apache.nifi.processor.Relationship REL_SUCCESS;
public static final org.apache.nifi.processor.Relationship REL_FAILURE;
private static final java.util.List PROPERTIES;
private static final java.util.Set RELATIONSHIPS;
private static final java.util.Map compressionFormatMimeTypeMap;
private static final int STREAM_BUFFER_SIZE;
public void <init>()
{
org.apache.nifi.processors.compress.ModifyCompression v;
v := @this: org.apache.nifi.processors.compress.ModifyCompression;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
return;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.compress.ModifyCompression v;
v := @this: org.apache.nifi.processors.compress.ModifyCompression;
v = <org.apache.nifi.processors.compress.ModifyCompression: java.util.Set RELATIONSHIPS>;
return v;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.compress.ModifyCompression v;
v := @this: org.apache.nifi.processors.compress.ModifyCompression;
v = <org.apache.nifi.processors.compress.ModifyCompression: java.util.List PROPERTIES>;
return v;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession)
{
org.apache.nifi.processors.compress.property.CompressionStrategy v, v, v;
java.lang.Integer v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v;
java.lang.Long v, v, v;
java.util.Map v;
boolean v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.util.StopWatch v;
org.apache.nifi.processor.io.StreamCallback v;
java.lang.Object[] v, v, v, v;
long v, v, v;
org.apache.nifi.logging.ComponentLog v, v, v, v;
java.util.concurrent.atomic.AtomicReference v;
org.apache.nifi.processors.compress.property.FilenameStrategy v, v;
org.apache.nifi.provenance.ProvenanceReporter v;
org.apache.nifi.processor.Relationship v, v, v, v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.ProcessSession v;
java.lang.RuntimeException v;
org.apache.nifi.processors.compress.ModifyCompression v;
java.util.concurrent.TimeUnit v;
java.lang.Object v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v, v, v, v, v;
v := @this: org.apache.nifi.processors.compress.ModifyCompression;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if v != null goto label;
return;
label:
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor INPUT_COMPRESSION_STRATEGY>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = specialinvoke v.<org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.processors.compress.property.CompressionStrategy getCompressionStrategy(java.lang.String)>(v);
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy MIME_TYPE_ATTRIBUTE>;
if v != v goto label;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes MIME_TYPE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
if v != null goto label;
v = virtualinvoke v.<org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes MIME_TYPE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Required FlowFile Attribute [{}] not found {}", v);
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
return;
label:
v = <org.apache.nifi.processors.compress.ModifyCompression: java.util.Map compressionFormatMimeTypeMap>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = virtualinvoke v.<org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Compression Strategy not found for MIME Type [{}] {}", v);
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
return;
label:
v = v;
label:
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor OUTPUT_COMPRESSION_STRATEGY>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = specialinvoke v.<org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.processors.compress.property.CompressionStrategy getCompressionStrategy(java.lang.String)>(v);
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(null);
v = new org.apache.nifi.util.StopWatch;
specialinvoke v.<org.apache.nifi.util.StopWatch: void <init>(boolean)>(1);
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor OUTPUT_COMPRESSION_LEVEL>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
label:
v = staticinvoke <org.apache.nifi.processors.compress.ModifyCompression$lambda_onTrigger_0__1: org.apache.nifi.processor.io.StreamCallback bootstrap$(org.apache.nifi.processors.compress.ModifyCompression,org.apache.nifi.processors.compress.property.CompressionStrategy,org.apache.nifi.processors.compress.property.CompressionStrategy,int,java.util.concurrent.atomic.AtomicReference)>(v, v, v, v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile write(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.StreamCallback)>(v, v);
virtualinvoke v.<org.apache.nifi.util.StopWatch: void stop()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = staticinvoke <org.apache.nifi.util.StringUtils: boolean isEmpty(java.lang.String)>(v);
if v == 0 goto label;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes MIME_TYPE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile removeAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String)>(v, v);
goto label;
label:
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes MIME_TYPE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, v, v);
label:
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor OUTPUT_FILENAME_STRATEGY>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <org.apache.nifi.processors.compress.property.FilenameStrategy: org.apache.nifi.processors.compress.property.FilenameStrategy valueOf(java.lang.String)>(v);
v = <org.apache.nifi.processors.compress.property.FilenameStrategy: org.apache.nifi.processors.compress.property.FilenameStrategy UPDATED>;
if v != v goto label;
v = specialinvoke v.<org.apache.nifi.processors.compress.ModifyCompression: java.lang.String getUpdatedFilename(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processors.compress.property.CompressionStrategy,org.apache.nifi.processors.compress.property.CompressionStrategy)>(v, v, v);
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, v, v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[5];
v[0] = v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[1] = v;
v[2] = v;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[3] = v;
v[4] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Input Compression [{}] Size [{}] Output Compression [{}] Size [{}] Completed {}", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<org.apache.nifi.util.StopWatch: long getDuration(java.util.concurrent.TimeUnit)>(v);
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void modifyContent(org.apache.nifi.flowfile.FlowFile,long)>(v, v);
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[5];
v[0] = v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[1] = v;
v[2] = v;
v[3] = v;
v[4] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Input Compression [{}] Size [{}] Output Compression [{}] Failed {}", v);
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
return;
catch java.lang.RuntimeException from label to label with label;
}
private java.io.InputStream getCompressionInputStream(org.apache.nifi.processors.compress.property.CompressionStrategy, java.io.InputStream) throws java.io.IOException
{
org.apache.commons.compress.compressors.CompressorInputStream v;
org.apache.nifi.processors.compress.property.CompressionStrategy v, v, v, v, v, v, v, v, v, v, v, v, v;
lzma.streams.LzmaInputStream v;
org.apache.commons.compress.compressors.lz.FramedLZ4CompressorInputStream v;
org.tukaani.xz.XZInputStream v;
org.apache.commons.compress.compressors.CompressorStreamFactory v;
com.aayushatharva.brotli4j.decoder.BrotliInputStream v;
java.lang.Throwable v;
java.lang.Object[] v;
java.util.zip.InflaterInputStream v;
org.xerial.snappy.SnappyInputStream v;
org.xerial.snappy.SnappyFramedInputStream v;
java.lang.String v, v, v;
org.apache.commons.compress.compressors.bzip.BZip2CompressorInputStream v;
org.apache.commons.compress.compressors.gzip.GzipCompressorInputStream v;
lzma.sdk.lzma.Decoder v;
org.apache.commons.compress.compressors.zstandard.ZstdCompressorInputStream v;
java.io.IOException v, v;
org.apache.nifi.processors.compress.ModifyCompression v;
java.io.InputStream v;
v := @this: org.apache.nifi.processors.compress.ModifyCompression;
v := @parameter: org.apache.nifi.processors.compress.property.CompressionStrategy;
v := @parameter: java.io.InputStream;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy LZMA>;
if v != v goto label;
v = new lzma.streams.LzmaInputStream;
v = new lzma.sdk.lzma.Decoder;
specialinvoke v.<lzma.sdk.lzma.Decoder: void <init>()>();
specialinvoke v.<lzma.streams.LzmaInputStream: void <init>(java.io.InputStream,lzma.sdk.lzma.Decoder)>(v, v);
return v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy XZ_LZMA2>;
if v != v goto label;
v = new org.tukaani.xz.XZInputStream;
specialinvoke v.<org.tukaani.xz.XZInputStream: void <init>(java.io.InputStream)>(v);
return v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy BZIP2>;
if v != v goto label;
v = new org.apache.commons.compress.compressors.bzip.BZip2CompressorInputStream;
specialinvoke v.<org.apache.commons.compress.compressors.bzip.BZip2CompressorInputStream: void <init>(java.io.InputStream,boolean)>(v, 1);
return v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy GZIP>;
if v != v goto label;
v = new org.apache.commons.compress.compressors.gzip.GzipCompressorInputStream;
specialinvoke v.<org.apache.commons.compress.compressors.gzip.GzipCompressorInputStream: void <init>(java.io.InputStream,boolean)>(v, 1);
return v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy DEFLATE>;
if v != v goto label;
v = new java.util.zip.InflaterInputStream;
specialinvoke v.<java.util.zip.InflaterInputStream: void <init>(java.io.InputStream)>(v);
return v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY>;
if v != v goto label;
v = new org.xerial.snappy.SnappyInputStream;
specialinvoke v.<org.xerial.snappy.SnappyInputStream: void <init>(java.io.InputStream)>(v);
return v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY_HADOOP>;
if v != v goto label;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("Cannot decompress snappy-hadoop");
throw v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY_FRAMED>;
if v != v goto label;
v = new org.xerial.snappy.SnappyFramedInputStream;
specialinvoke v.<org.xerial.snappy.SnappyFramedInputStream: void <init>(java.io.InputStream)>(v);
return v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy LZ4_FRAMED>;
if v != v goto label;
v = new org.apache.commons.compress.compressors.lz.FramedLZ4CompressorInputStream;
specialinvoke v.<org.apache.commons.compress.compressors.lz.FramedLZ4CompressorInputStream: void <init>(java.io.InputStream,boolean)>(v, 1);
return v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy ZSTD>;
if v != v goto label;
v = new org.apache.commons.compress.compressors.zstandard.ZstdCompressorInputStream;
specialinvoke v.<org.apache.commons.compress.compressors.zstandard.ZstdCompressorInputStream: void <init>(java.io.InputStream)>(v);
return v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy BROTLI>;
if v != v goto label;
staticinvoke <com.aayushatharva.brotli4j.Brotli4jLoader: void ensureAvailability()>();
v = new com.aayushatharva.brotli4j.decoder.BrotliInputStream;
specialinvoke v.<com.aayushatharva.brotli4j.decoder.BrotliInputStream: void <init>(java.io.InputStream)>(v);
return v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy NONE>;
if v != v goto label;
return v;
label:
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
label:
v = new org.apache.commons.compress.compressors.CompressorStreamFactory;
specialinvoke v.<org.apache.commons.compress.compressors.CompressorStreamFactory: void <init>()>();
v = virtualinvoke v.<org.apache.commons.compress.compressors.CompressorStreamFactory: org.apache.commons.compress.compressors.CompressorInputStream createCompressorInputStream(java.lang.String,java.io.InputStream)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = new java.io.IOException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Compressor Stream Format [%s] creation failed", v);
specialinvoke v.<java.io.IOException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch org.apache.commons.compress.compressors.CompressorException from label to label with label;
}
private java.io.OutputStream getCompressionOutputStream(org.apache.nifi.processors.compress.property.CompressionStrategy, int, java.util.concurrent.atomic.AtomicReference, java.io.OutputStream) throws java.io.IOException
{
org.apache.nifi.processors.compress.property.CompressionStrategy v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.tukaani.xz.LZMA2Options v;
lzma.streams.LzmaOutputStream$Builder v;
org.apache.nifi.stream.io.GZIPOutputStream v;
java.lang.Throwable v, v;
java.lang.Object[] v, v;
java.util.zip.DeflaterOutputStream v;
org.xerial.snappy.SnappyOutputStream v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
com.aayushatharva.brotli4j.encoder.Encoder$Parameters v, v;
java.io.IOException v, v;
org.apache.nifi.processors.compress.ModifyCompression v;
org.apache.commons.compress.compressors.zstandard.ZstdCompressorOutputStream v;
org.apache.commons.compress.compressors.CompressorStreamFactory v, v;
java.util.zip.Deflater v;
org.xerial.snappy.SnappyFramedOutputStream v;
java.lang.String[] v, v, v, v, v, v, v, v, v, v, v;
java.util.concurrent.atomic.AtomicReference v;
int v, v;
java.io.OutputStream v;
java.lang.Object v;
org.xerial.snappy.SnappyHadoopCompatibleOutputStream v;
org.tukaani.xz.XZOutputStream v;
com.aayushatharva.brotli4j.encoder.BrotliOutputStream v;
v := @this: org.apache.nifi.processors.compress.ModifyCompression;
v := @parameter: org.apache.nifi.processors.compress.property.CompressionStrategy;
v := @parameter: int;
v := @parameter: java.util.concurrent.atomic.AtomicReference;
v := @parameter: java.io.OutputStream;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy GZIP>;
if v != v goto label;
v = new org.apache.nifi.stream.io.GZIPOutputStream;
specialinvoke v.<org.apache.nifi.stream.io.GZIPOutputStream: void <init>(java.io.OutputStream,int)>(v, v);
v = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy GZIP>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String[] getMimeTypes()>();
v = v[0];
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy DEFLATE>;
if v != v goto label;
v = new java.util.zip.DeflaterOutputStream;
v = new java.util.zip.Deflater;
specialinvoke v.<java.util.zip.Deflater: void <init>(int)>(v);
specialinvoke v.<java.util.zip.DeflaterOutputStream: void <init>(java.io.OutputStream,java.util.zip.Deflater)>(v, v);
v = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy GZIP>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String[] getMimeTypes()>();
v = v[0];
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy LZMA>;
if v != v goto label;
v = new lzma.streams.LzmaOutputStream$Builder;
specialinvoke v.<lzma.streams.LzmaOutputStream$Builder: void <init>(java.io.OutputStream)>(v);
v = virtualinvoke v.<lzma.streams.LzmaOutputStream$Builder: lzma.streams.LzmaOutputStream build()>();
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy LZMA>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String[] getMimeTypes()>();
v = v[0];
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy XZ_LZMA2>;
if v != v goto label;
v = new org.tukaani.xz.XZOutputStream;
v = new org.tukaani.xz.LZMA2Options;
specialinvoke v.<org.tukaani.xz.LZMA2Options: void <init>(int)>(v);
specialinvoke v.<org.tukaani.xz.XZOutputStream: void <init>(java.io.OutputStream,org.tukaani.xz.FilterOptions)>(v, v);
v = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy XZ_LZMA2>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String[] getMimeTypes()>();
v = v[0];
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY>;
if v != v goto label;
v = new org.xerial.snappy.SnappyOutputStream;
specialinvoke v.<org.xerial.snappy.SnappyOutputStream: void <init>(java.io.OutputStream)>(v);
v = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String[] getMimeTypes()>();
v = v[0];
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY_HADOOP>;
if v != v goto label;
v = new org.xerial.snappy.SnappyHadoopCompatibleOutputStream;
specialinvoke v.<org.xerial.snappy.SnappyHadoopCompatibleOutputStream: void <init>(java.io.OutputStream)>(v);
v = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY_HADOOP>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String[] getMimeTypes()>();
v = v[0];
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY_FRAMED>;
if v != v goto label;
v = new org.xerial.snappy.SnappyFramedOutputStream;
specialinvoke v.<org.xerial.snappy.SnappyFramedOutputStream: void <init>(java.io.OutputStream)>(v);
v = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY_FRAMED>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String[] getMimeTypes()>();
v = v[0];
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy LZ4_FRAMED>;
if v != v goto label;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
label:
v = new org.apache.commons.compress.compressors.CompressorStreamFactory;
specialinvoke v.<org.apache.commons.compress.compressors.CompressorStreamFactory: void <init>()>();
v = virtualinvoke v.<org.apache.commons.compress.compressors.CompressorStreamFactory: org.apache.commons.compress.compressors.CompressorOutputStream createCompressorOutputStream(java.lang.String,java.io.OutputStream)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Compressor Stream Format [%s] creation failed", v);
specialinvoke v.<java.io.IOException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy LZ4_FRAMED>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String[] getMimeTypes()>();
v = v[0];
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy ZSTD>;
if v != v goto label;
v = v * 2;
v = new org.apache.commons.compress.compressors.zstandard.ZstdCompressorOutputStream;
specialinvoke v.<org.apache.commons.compress.compressors.zstandard.ZstdCompressorOutputStream: void <init>(java.io.OutputStream,int)>(v, v);
v = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy ZSTD>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String[] getMimeTypes()>();
v = v[0];
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy BROTLI>;
if v != v goto label;
staticinvoke <com.aayushatharva.brotli4j.Brotli4jLoader: void ensureAvailability()>();
v = new com.aayushatharva.brotli4j.encoder.Encoder$Parameters;
specialinvoke v.<com.aayushatharva.brotli4j.encoder.Encoder$Parameters: void <init>()>();
v = virtualinvoke v.<com.aayushatharva.brotli4j.encoder.Encoder$Parameters: com.aayushatharva.brotli4j.encoder.Encoder$Parameters setQuality(int)>(v);
v = new com.aayushatharva.brotli4j.encoder.BrotliOutputStream;
specialinvoke v.<com.aayushatharva.brotli4j.encoder.BrotliOutputStream: void <init>(java.io.OutputStream,com.aayushatharva.brotli4j.encoder.Encoder$Parameters)>(v, v);
v = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy BROTLI>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String[] getMimeTypes()>();
v = v[0];
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy BZIP2>;
if v != v goto label;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
label:
v = new org.apache.commons.compress.compressors.CompressorStreamFactory;
specialinvoke v.<org.apache.commons.compress.compressors.CompressorStreamFactory: void <init>()>();
v = virtualinvoke v.<org.apache.commons.compress.compressors.CompressorStreamFactory: org.apache.commons.compress.compressors.CompressorOutputStream createCompressorOutputStream(java.lang.String,java.io.OutputStream)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Compressor Stream Format [%s] creation failed", v);
specialinvoke v.<java.io.IOException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy BZIP2>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String[] getMimeTypes()>();
v = v[0];
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
goto label;
label:
v = v;
label:
return v;
catch org.apache.commons.compress.compressors.CompressorException from label to label with label;
catch org.apache.commons.compress.compressors.CompressorException from label to label with label;
}
private java.lang.String getUpdatedFilename(org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processors.compress.property.CompressionStrategy, org.apache.nifi.processors.compress.property.CompressionStrategy)
{
org.apache.nifi.processors.compress.property.CompressionStrategy v, v;
int v, v, v;
java.lang.String v, v, v, v, v, v, v;
boolean v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.compress.ModifyCompression v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.compress.ModifyCompression;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: org.apache.nifi.processors.compress.property.CompressionStrategy;
v := @parameter: org.apache.nifi.processors.compress.property.CompressionStrategy;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String getFileExtension()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
v = virtualinvoke v.<java.lang.String: int length()>();
v = v - v;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
goto label;
label:
v = v;
label:
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String getFileExtension()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001\u0001");
return v;
}
private org.apache.nifi.processors.compress.property.CompressionStrategy getCompressionStrategy(java.lang.String)
{
java.util.Optional v;
java.lang.Object v;
java.lang.String v;
org.apache.nifi.processors.compress.ModifyCompression v;
java.util.function.Supplier v;
v := @this: org.apache.nifi.processors.compress.ModifyCompression;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.nifi.processors.compress.property.CompressionStrategy: java.util.Optional findValue(java.lang.String)>(v);
v = staticinvoke <org.apache.nifi.processors.compress.ModifyCompression$lambda_getCompressionStrategy_1__2: java.util.function.Supplier bootstrap$(java.lang.String)>(v);
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElseThrow(java.util.function.Supplier)>(v);
return v;
}
static void <clinit>()
{
java.util.Map v;
org.apache.nifi.components.AllowableValue v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object[] v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.processor.Relationship[] v;
int v, v, v, v;
org.apache.nifi.processors.compress.property.CompressionStrategy v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v;
org.apache.nifi.processors.compress.property.CompressionStrategy[] v;
java.util.Set v;
org.apache.nifi.processors.compress.property.FilenameStrategy v;
java.lang.String v, v, v, v;
java.util.LinkedHashSet v;
org.apache.nifi.components.PropertyDescriptor[] v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.List v, v, v;
org.apache.nifi.components.AllowableValue[] v, v;
java.lang.String[] v, v;
java.util.HashMap v;
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Input Compression Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Input Compression Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The strategy to use for decompressing input FlowFiles");
v = newarray (org.apache.nifi.components.AllowableValue)[12];
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy NONE>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[0] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy MIME_TYPE_ATTRIBUTE>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[1] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy GZIP>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[2] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy DEFLATE>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[3] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy BZIP2>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[4] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy XZ_LZMA2>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[5] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy LZMA>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[6] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[7] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY_FRAMED>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[8] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy LZ4_FRAMED>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[9] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy ZSTD>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[10] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy BROTLI>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[11] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(org.apache.nifi.components.AllowableValue[])>(v);
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy NONE>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String getValue()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor INPUT_COMPRESSION_STRATEGY> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Output Compression Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Output Compression Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The strategy to use for compressing output FlowFiles");
v = newarray (org.apache.nifi.components.AllowableValue)[12];
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy NONE>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[0] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy GZIP>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[1] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy DEFLATE>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[2] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy BZIP2>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[3] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy XZ_LZMA2>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[4] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy LZMA>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[5] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[6] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY_HADOOP>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[7] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy SNAPPY_FRAMED>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[8] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy LZ4_FRAMED>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[9] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy ZSTD>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[10] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy BROTLI>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.components.AllowableValue asAllowableValue()>();
v[11] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(org.apache.nifi.components.AllowableValue[])>(v);
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy NONE>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String getValue()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor OUTPUT_COMPRESSION_STRATEGY> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Output Compression Level");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Output Compression Level");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The compression level for output FlowFiles for supported formats. A lower value results in faster processing but less compression; a value of 0 indicates no (that is, simple archiving) for gzip or minimal for xz-lzma compression. Higher levels can mean much larger memory usage such as the case with levels 7-9 for xz-lzma/2 so be careful relative to heap size.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("1");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[10];
v[0] = "0";
v[1] = "1";
v[2] = "2";
v[3] = "3";
v[4] = "4";
v[5] = "5";
v[6] = "6";
v[7] = "7";
v[8] = "8";
v[9] = "9";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor OUTPUT_COMPRESSION_STRATEGY>;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy MIME_TYPE_ATTRIBUTE>;
v = newarray (org.apache.nifi.components.DescribedValue)[5];
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy GZIP>;
v[0] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy DEFLATE>;
v[1] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy XZ_LZMA2>;
v[2] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy ZSTD>;
v[3] = v;
v = <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy BROTLI>;
v[4] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.DescribedValue,org.apache.nifi.components.DescribedValue[])>(v, v, v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor OUTPUT_COMPRESSION_LEVEL> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Output Filename Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Output Filename Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Processing strategy for filename attribute on output FlowFiles");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.Class)>(class "Lorg/apache/nifi/processors/compress/property/FilenameStrategy;");
v = <org.apache.nifi.processors.compress.property.FilenameStrategy: org.apache.nifi.processors.compress.property.FilenameStrategy UPDATED>;
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.FilenameStrategy: java.lang.String getValue()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor OUTPUT_FILENAME_STRATEGY> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("success");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles will be transferred to the success relationship on compression modification success");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.processor.Relationship REL_SUCCESS> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("failure");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles will be transferred to the failure relationship on compression modification errors");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
v = newarray (org.apache.nifi.components.PropertyDescriptor)[4];
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor INPUT_COMPRESSION_STRATEGY>;
v[0] = v;
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor OUTPUT_COMPRESSION_STRATEGY>;
v[1] = v;
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor OUTPUT_COMPRESSION_LEVEL>;
v[2] = v;
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.components.PropertyDescriptor OUTPUT_FILENAME_STRATEGY>;
v[3] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
<org.apache.nifi.processors.compress.ModifyCompression: java.util.List PROPERTIES> = v;
v = new java.util.LinkedHashSet;
v = newarray (org.apache.nifi.processor.Relationship)[2];
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v[0] = v;
v = <org.apache.nifi.processors.compress.ModifyCompression: org.apache.nifi.processor.Relationship REL_FAILURE>;
v[1] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.LinkedHashSet: void <init>(java.util.Collection)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
<org.apache.nifi.processors.compress.ModifyCompression: java.util.Set RELATIONSHIPS> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = staticinvoke <org.apache.nifi.processors.compress.property.CompressionStrategy: org.apache.nifi.processors.compress.property.CompressionStrategy[] values()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.nifi.processors.compress.property.CompressionStrategy: java.lang.String[] getMimeTypes()>();
if v == null goto label;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
<org.apache.nifi.processors.compress.ModifyCompression: java.util.Map compressionFormatMimeTypeMap> = v;
return;
}
}