public class org.apache.nifi.processors.standard.TestCompressContent extends java.lang.Object
{
public void <init>()
{
org.apache.nifi.processors.standard.TestCompressContent v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void testSnappyCompress() throws java.lang.Exception
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.lang.String v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "compress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "snappy");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
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()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "application/x-snappy");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt.snappy");
return;
}
public void testSnappyDecompress() throws java.lang.Exception
{
java.lang.String[] v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.nio.file.Path v, v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "decompress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "snappy");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.snappy", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
return;
}
public void testSnappyHadoopCompress() throws java.lang.Exception
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.lang.String v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "compress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "snappy-hadoop");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
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()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "application/x-snappy-hadoop");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt.snappy");
return;
}
public void testSnappyHadoopDecompress()
{
org.apache.nifi.util.TestRunner v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "decompress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "snappy-hadoop");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertNotValid()>();
return;
}
public void testSnappyFramedCompress() throws java.lang.Exception
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.lang.String v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "compress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "snappy framed");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
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()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "application/x-snappy-framed");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt.sz");
return;
}
public void testSnappyFramedDecompress() throws java.lang.Exception
{
java.lang.String[] v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.nio.file.Path v, v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "decompress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "snappy framed");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.sz", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
return;
}
public void testBzip2DecompressConcatenated() throws java.lang.Exception
{
java.lang.String[] v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.nio.file.Path v, v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "decompress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "bzip2");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFileConcat.txt.bz2", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFileConcat.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFileConcat.txt.bz2");
return;
}
public void testBzip2Decompress() throws java.lang.Exception
{
java.lang.String[] v, v, v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.nio.file.Path v, v, v, v;
java.util.List v, v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "decompress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "bzip2");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.bz2", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.bz2", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
return;
}
public void testProperMimeTypeFromBzip2() throws java.lang.Exception
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "compress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "bzip2");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("mime.type", "application/x-bzip2");
return;
}
public void testBzip2DecompressWithBothMimeTypes() throws java.lang.Exception
{
java.lang.String[] v, v, v, v;
java.util.HashMap v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.nio.file.Path v, v, v, v;
java.util.List v, v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "decompress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "use mime.type attribute");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("mime.type", "application/x-bzip2");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.bz2", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path,java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("mime.type", "application/bzip2");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.bz2", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path,java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
return;
}
public void testGzipDecompress() throws java.lang.Exception
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
org.apache.nifi.util.TestRunner v;
java.nio.file.Path v, v, v, v, v, v;
boolean v;
java.util.List v, v, v;
java.lang.String[] v, v, v, v, v, v;
java.util.HashMap v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v;
java.lang.String v;
org.apache.nifi.components.ValidationResult v;
java.lang.Object v, v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "decompress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "gzip");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult: boolean isValid()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.gz", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.gz", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "use mime.type attribute");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
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()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "application/x-gzip");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.gz", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path,java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
return;
}
public void testDeflateDecompress() throws java.lang.Exception
{
byte[] v;
java.lang.String[] v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v;
java.nio.file.Path v, v;
org.apache.nifi.components.ValidationResult v;
boolean v;
java.io.PrintStream v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "decompress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "deflate");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult: boolean isValid()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.zlib", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <java.lang.System: java.io.PrintStream err>;
v = new java.lang.String;
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
return;
}
public void testDeflateCompress() throws java.lang.Exception
{
java.lang.String[] v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.nio.file.Path v, v;
org.apache.nifi.components.ValidationResult v;
boolean v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "compress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_LEVEL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "6");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "deflate");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult: boolean isValid()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.zlib", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt.zlib");
return;
}
public void testFilenameUpdatedOnCompress() throws java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.nio.file.Path v;
org.apache.nifi.components.ValidationResult v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "compress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "gzip");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult: boolean isValid()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt.gz");
return;
}
public void testDecompressFailure() throws java.io.IOException
{
byte[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
org.apache.nifi.components.ValidationResult v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "decompress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "gzip");
v = newarray (byte)[10];
v[0] = 1;
v[1] = 2;
v[2] = 3;
v[3] = 4;
v[4] = 5;
v[5] = 6;
v[6] = 7;
v[7] = 8;
v[8] = 9;
v[9] = 10;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult: boolean isValid()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertQueueEmpty()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_FAILURE>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(byte[])>(v);
return;
}
public void testLz4FramedCompress() throws java.lang.Exception
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.lang.String v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "compress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "lz4-framed");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
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()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "application/x-lz4-framed");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt.lz4");
return;
}
public void testLz4FramedDecompress() throws java.lang.Exception
{
java.lang.String[] v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.nio.file.Path v, v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "decompress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "lz4-framed");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.lz4", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
return;
}
public void testZstdCompress() throws java.lang.Exception
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.lang.String v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "compress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "zstd");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
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()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "application/zstd");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt.zst");
return;
}
public void testZstdDecompress() throws java.lang.Exception
{
java.lang.String[] v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.nio.file.Path v, v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "decompress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "zstd");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.zst", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
return;
}
public void testBrotliCompress() throws java.lang.Exception
{
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.lang.String v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "compress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "brotli");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
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()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "application/x-brotli");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt.br");
return;
}
public void testBrotliDecompress() throws java.lang.Exception
{
java.lang.String[] v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.TestCompressContent v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.nio.file.Path v, v;
v := @this: org.apache.nifi.processors.standard.TestCompressContent;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/CompressContent;");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor MODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "decompress");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "brotli");
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.components.PropertyDescriptor UPDATE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt.br", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.CompressContent: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/CompressedData/SampleFile.txt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("filename", "SampleFile.txt");
return;
}
}