public abstract class org.apache.nifi.processors.standard.AbstractConversionIT extends java.lang.Object
{
protected org.apache.nifi.serialization.RecordReaderFactory reader;
protected java.util.function.Consumer inputHandler;
protected java.util.function.Consumer readerConfigurer;
protected org.apache.nifi.serialization.RecordSetWriterFactory writer;
protected java.util.function.Consumer resultHandler;
protected java.util.function.Consumer writerConfigurer;
public void <init>()
{
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void setUp() throws java.lang.Exception
{
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader> = null;
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler> = null;
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer> = null;
v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer> = null;
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler> = null;
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer> = null;
return;
}
public void testCsvToJson() throws java.lang.Exception
{
org.apache.nifi.serialization.RecordSetWriterFactory v;
java.util.function.Consumer v, v, v, v;
org.apache.nifi.serialization.RecordReaderFactory v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String csvPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromCsv(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String jsonPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toJson(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testConversion(org.apache.nifi.serialization.RecordReaderFactory,java.util.function.Consumer,org.apache.nifi.serialization.RecordSetWriterFactory,java.util.function.Consumer,java.util.function.Consumer,java.util.function.Consumer)>(v, v, v, v, v, v);
return;
}
public void testCsvToAvro() throws java.lang.Exception
{
org.apache.nifi.serialization.RecordSetWriterFactory v;
java.util.function.Consumer v, v, v, v;
org.apache.nifi.serialization.RecordReaderFactory v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String csvPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromCsv(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String avroPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toAvro(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testConversion(org.apache.nifi.serialization.RecordReaderFactory,java.util.function.Consumer,org.apache.nifi.serialization.RecordSetWriterFactory,java.util.function.Consumer,java.util.function.Consumer,java.util.function.Consumer)>(v, v, v, v, v, v);
return;
}
public void testCsvToAvroToCsv() throws java.lang.Exception
{
org.apache.nifi.avro.AvroRecordSetWriter v;
java.lang.String v, v;
org.apache.nifi.avro.AvroReader v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String csvPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromCsv(java.lang.String)>(v);
v = new org.apache.nifi.avro.AvroRecordSetWriter;
specialinvoke v.<org.apache.nifi.avro.AvroRecordSetWriter: void <init>()>();
v = new org.apache.nifi.avro.AvroReader;
specialinvoke v.<org.apache.nifi.avro.AvroReader: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String csvPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toCsv(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testChain(org.apache.nifi.serialization.RecordSetWriterFactory,org.apache.nifi.serialization.RecordReaderFactory)>(v, v);
return;
}
public void testCsvToXml() throws java.lang.Exception
{
org.apache.nifi.serialization.RecordSetWriterFactory v;
java.util.function.Consumer v, v, v, v;
org.apache.nifi.serialization.RecordReaderFactory v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String csvPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromCsv(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String xmlPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toXml(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testConversion(org.apache.nifi.serialization.RecordReaderFactory,java.util.function.Consumer,org.apache.nifi.serialization.RecordSetWriterFactory,java.util.function.Consumer,java.util.function.Consumer,java.util.function.Consumer)>(v, v, v, v, v, v);
return;
}
public void testJsonToCsv() throws java.lang.Exception
{
org.apache.nifi.serialization.RecordSetWriterFactory v;
java.util.function.Consumer v, v, v, v;
org.apache.nifi.serialization.RecordReaderFactory v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String jsonPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromJson(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String csvPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toCsv(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testConversion(org.apache.nifi.serialization.RecordReaderFactory,java.util.function.Consumer,org.apache.nifi.serialization.RecordSetWriterFactory,java.util.function.Consumer,java.util.function.Consumer,java.util.function.Consumer)>(v, v, v, v, v, v);
return;
}
public void testJsonToAvro() throws java.lang.Exception
{
org.apache.nifi.serialization.RecordSetWriterFactory v;
java.util.function.Consumer v, v, v, v;
org.apache.nifi.serialization.RecordReaderFactory v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String jsonPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromJson(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String avroPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toAvro(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testConversion(org.apache.nifi.serialization.RecordReaderFactory,java.util.function.Consumer,org.apache.nifi.serialization.RecordSetWriterFactory,java.util.function.Consumer,java.util.function.Consumer,java.util.function.Consumer)>(v, v, v, v, v, v);
return;
}
public void testJsonToAvroToJson() throws java.lang.Exception
{
org.apache.nifi.avro.AvroRecordSetWriter v;
java.lang.String v, v;
org.apache.nifi.avro.AvroReader v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String jsonPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromJson(java.lang.String)>(v);
v = new org.apache.nifi.avro.AvroRecordSetWriter;
specialinvoke v.<org.apache.nifi.avro.AvroRecordSetWriter: void <init>()>();
v = new org.apache.nifi.avro.AvroReader;
specialinvoke v.<org.apache.nifi.avro.AvroReader: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String jsonPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toJson(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testChain(org.apache.nifi.serialization.RecordSetWriterFactory,org.apache.nifi.serialization.RecordReaderFactory)>(v, v);
return;
}
public void testAvroToCsv() throws java.lang.Exception
{
org.apache.nifi.serialization.RecordSetWriterFactory v;
java.util.function.Consumer v, v, v, v;
org.apache.nifi.serialization.RecordReaderFactory v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String avroPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromAvro(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String csvPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toCsv(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testConversion(org.apache.nifi.serialization.RecordReaderFactory,java.util.function.Consumer,org.apache.nifi.serialization.RecordSetWriterFactory,java.util.function.Consumer,java.util.function.Consumer,java.util.function.Consumer)>(v, v, v, v, v, v);
return;
}
public void testAvroToJson() throws java.lang.Exception
{
org.apache.nifi.serialization.RecordSetWriterFactory v;
java.util.function.Consumer v, v, v, v;
org.apache.nifi.serialization.RecordReaderFactory v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String avroPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromAvro(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String jsonPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toJson(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testConversion(org.apache.nifi.serialization.RecordReaderFactory,java.util.function.Consumer,org.apache.nifi.serialization.RecordSetWriterFactory,java.util.function.Consumer,java.util.function.Consumer,java.util.function.Consumer)>(v, v, v, v, v, v);
return;
}
public void testAvroToXml() throws java.lang.Exception
{
org.apache.nifi.serialization.RecordSetWriterFactory v;
java.util.function.Consumer v, v, v, v;
org.apache.nifi.serialization.RecordReaderFactory v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String avroPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromAvro(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String xmlPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toXml(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testConversion(org.apache.nifi.serialization.RecordReaderFactory,java.util.function.Consumer,org.apache.nifi.serialization.RecordSetWriterFactory,java.util.function.Consumer,java.util.function.Consumer,java.util.function.Consumer)>(v, v, v, v, v, v);
return;
}
public void testXmlToCsv() throws java.lang.Exception
{
org.apache.nifi.serialization.RecordSetWriterFactory v;
java.util.function.Consumer v, v, v, v;
org.apache.nifi.serialization.RecordReaderFactory v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String xmlPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromXml(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String csvPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toCsv(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testConversion(org.apache.nifi.serialization.RecordReaderFactory,java.util.function.Consumer,org.apache.nifi.serialization.RecordSetWriterFactory,java.util.function.Consumer,java.util.function.Consumer,java.util.function.Consumer)>(v, v, v, v, v, v);
return;
}
public void testXmlToJson() throws java.lang.Exception
{
org.apache.nifi.serialization.RecordSetWriterFactory v;
java.util.function.Consumer v, v, v, v;
org.apache.nifi.serialization.RecordReaderFactory v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String xmlPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromXml(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String jsonPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toJson(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testConversion(org.apache.nifi.serialization.RecordReaderFactory,java.util.function.Consumer,org.apache.nifi.serialization.RecordSetWriterFactory,java.util.function.Consumer,java.util.function.Consumer,java.util.function.Consumer)>(v, v, v, v, v, v);
return;
}
public void testXmlToAvro() throws java.lang.Exception
{
org.apache.nifi.serialization.RecordSetWriterFactory v;
java.util.function.Consumer v, v, v, v;
org.apache.nifi.serialization.RecordReaderFactory v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String xmlPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromXml(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String avroPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toAvro(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testConversion(org.apache.nifi.serialization.RecordReaderFactory,java.util.function.Consumer,org.apache.nifi.serialization.RecordSetWriterFactory,java.util.function.Consumer,java.util.function.Consumer,java.util.function.Consumer)>(v, v, v, v, v, v);
return;
}
public void testXmlToAvroToXml() throws java.lang.Exception
{
org.apache.nifi.avro.AvroRecordSetWriter v;
java.lang.String v, v;
org.apache.nifi.avro.AvroReader v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String xmlPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void fromXml(java.lang.String)>(v);
v = new org.apache.nifi.avro.AvroRecordSetWriter;
specialinvoke v.<org.apache.nifi.avro.AvroRecordSetWriter: void <init>()>();
v = new org.apache.nifi.avro.AvroReader;
specialinvoke v.<org.apache.nifi.avro.AvroReader: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String xmlPostfix()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void toXml(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testChain(org.apache.nifi.serialization.RecordSetWriterFactory,org.apache.nifi.serialization.RecordReaderFactory)>(v, v);
return;
}
protected abstract java.lang.String csvPostfix();
protected abstract java.lang.String jsonPostfix();
protected abstract java.lang.String avroPostfix();
protected abstract java.lang.String xmlPostfix();
protected void commonReaderConfiguration(org.apache.nifi.util.TestRunner)
{
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: org.apache.nifi.util.TestRunner;
return;
}
protected void commonWriterConfiguration(org.apache.nifi.util.TestRunner)
{
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: org.apache.nifi.util.TestRunner;
return;
}
protected void fromCsv(java.lang.String)
{
java.util.function.Consumer v, v;
org.apache.nifi.csv.CSVReader v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: java.lang.String;
v = new org.apache.nifi.csv.CSVReader;
specialinvoke v.<org.apache.nifi.csv.CSVReader: void <init>()>();
v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader> = v;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String getContent(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer stringInputHandler(java.lang.String)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler> = v;
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_fromCsv_0__1: java.util.function.Consumer bootstrap$(org.apache.nifi.processors.standard.AbstractConversionIT)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer> = v;
return;
}
protected void fromJson(java.lang.String)
{
java.util.function.Consumer v, v;
org.apache.nifi.json.JsonTreeReader v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: java.lang.String;
v = new org.apache.nifi.json.JsonTreeReader;
specialinvoke v.<org.apache.nifi.json.JsonTreeReader: void <init>()>();
v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader> = v;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String getContent(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer stringInputHandler(java.lang.String)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler> = v;
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_fromJson_1__2: java.util.function.Consumer bootstrap$(org.apache.nifi.processors.standard.AbstractConversionIT)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer> = v;
return;
}
protected void fromXml(java.lang.String)
{
java.util.function.Consumer v, v;
org.apache.nifi.xml.XMLReader v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: java.lang.String;
v = new org.apache.nifi.xml.XMLReader;
specialinvoke v.<org.apache.nifi.xml.XMLReader: void <init>()>();
v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader> = v;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String getContent(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer stringInputHandler(java.lang.String)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler> = v;
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_fromXml_2__3: java.util.function.Consumer bootstrap$(org.apache.nifi.processors.standard.AbstractConversionIT)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer> = v;
return;
}
protected void fromAvro(java.lang.String)
{
java.util.function.Consumer v, v;
byte[] v;
java.lang.String v;
org.apache.nifi.avro.AvroReader v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: java.lang.String;
v = new org.apache.nifi.avro.AvroReader;
specialinvoke v.<org.apache.nifi.avro.AvroReader: void <init>()>();
v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader> = v;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: byte[] getByteContent(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer byteInputHandler(byte[])>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler> = v;
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_fromAvro_3__4: java.util.function.Consumer bootstrap$(org.apache.nifi.processors.standard.AbstractConversionIT)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer> = v;
return;
}
protected void toCsv(java.lang.String)
{
java.util.function.Consumer v, v;
org.apache.nifi.csv.CSVRecordSetWriter v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: java.lang.String;
v = new org.apache.nifi.csv.CSVRecordSetWriter;
specialinvoke v.<org.apache.nifi.csv.CSVRecordSetWriter: void <init>()>();
v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer> = v;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String getContent(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer stringOutputHandler(java.lang.String)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler> = v;
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_toCsv_4__5: java.util.function.Consumer bootstrap$(org.apache.nifi.processors.standard.AbstractConversionIT)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer> = v;
return;
}
protected void toJson(java.lang.String)
{
java.util.function.Consumer v, v;
org.apache.nifi.json.JsonRecordSetWriter v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: java.lang.String;
v = new org.apache.nifi.json.JsonRecordSetWriter;
specialinvoke v.<org.apache.nifi.json.JsonRecordSetWriter: void <init>()>();
v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer> = v;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String getContent(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer stringOutputHandler(java.lang.String)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler> = v;
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_toJson_5__6: java.util.function.Consumer bootstrap$(org.apache.nifi.processors.standard.AbstractConversionIT)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer> = v;
return;
}
protected void toXml(java.lang.String)
{
java.util.function.Consumer v, v;
java.lang.String v, v;
org.apache.nifi.xml.XMLRecordSetWriter v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: java.lang.String;
v = new org.apache.nifi.xml.XMLRecordSetWriter;
specialinvoke v.<org.apache.nifi.xml.XMLRecordSetWriter: void <init>()>();
v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer> = v;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.lang.String getContent(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer stringOutputHandler(java.lang.String)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler> = v;
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_toXml_6__7: java.util.function.Consumer bootstrap$(org.apache.nifi.processors.standard.AbstractConversionIT)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer> = v;
return;
}
protected void toAvro(java.lang.String)
{
java.util.function.Consumer v, v;
org.apache.nifi.avro.AvroRecordSetWriter v;
java.lang.String v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: java.lang.String;
v = new org.apache.nifi.avro.AvroRecordSetWriter;
specialinvoke v.<org.apache.nifi.avro.AvroRecordSetWriter: void <init>()>();
v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordSetWriterFactory writer> = v;
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_toAvro_7__8: java.util.function.Consumer bootstrap$(org.apache.nifi.processors.standard.AbstractConversionIT,java.lang.String)>(v, v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer resultHandler> = v;
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_toAvro_8__9: java.util.function.Consumer bootstrap$(org.apache.nifi.processors.standard.AbstractConversionIT)>(v);
v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer writerConfigurer> = v;
return;
}
protected java.util.function.Consumer stringInputHandler(java.lang.String)
{
java.util.function.Consumer v;
java.lang.String v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_stringInputHandler_9__10: java.util.function.Consumer bootstrap$(java.lang.String)>(v);
return v;
}
protected java.util.function.Consumer byteInputHandler(byte[])
{
java.util.function.Consumer v;
byte[] v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: byte[];
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_byteInputHandler_10__11: java.util.function.Consumer bootstrap$(byte[])>(v);
return v;
}
protected java.util.function.Consumer stringOutputHandler(java.lang.String)
{
java.util.function.Consumer v;
java.lang.String v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_stringOutputHandler_11__12: java.util.function.Consumer bootstrap$(java.lang.String)>(v);
return v;
}
protected java.lang.String getContent(java.lang.String)
{
byte[] v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: java.lang.String;
v = new java.lang.String;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: byte[] getByteContent(java.lang.String)>(v);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
return v;
}
protected byte[] getByteContent(java.lang.String)
{
byte[] v;
java.io.IOException v;
java.lang.String[] v;
java.lang.RuntimeException v;
java.lang.String v, v;
java.nio.file.Path v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: java.lang.String;
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("src/test/resources/TestConversions/data.int_float_string.\u0001");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = staticinvoke <java.nio.file.Files: byte[] readAllBytes(java.nio.file.Path)>(v);
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
protected java.util.List getRecords(byte[]) throws java.io.IOException, org.apache.nifi.serialization.MalformedRecordException
{
java.lang.Throwable v;
byte[] v;
org.apache.nifi.avro.AvroReaderWithEmbeddedSchema v;
java.util.List v;
java.io.ByteArrayInputStream v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: byte[];
v = new org.apache.nifi.avro.AvroReaderWithEmbeddedSchema;
v = new java.io.ByteArrayInputStream;
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
specialinvoke v.<org.apache.nifi.avro.AvroReaderWithEmbeddedSchema: void <init>(java.io.InputStream)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.List getRecords(org.apache.nifi.serialization.RecordReader)>(v);
label:
interfaceinvoke v.<org.apache.nifi.serialization.RecordReader: void close()>();
return v;
label:
v := @caughtexception;
throw v;
catch java.lang.Throwable from label to label with label;
}
protected java.util.List getRecords(org.apache.nifi.serialization.RecordReader) throws java.io.IOException, org.apache.nifi.serialization.MalformedRecordException
{
org.apache.nifi.serialization.RecordReader v;
java.util.Map v;
org.apache.nifi.serialization.record.Record v;
java.util.ArrayList v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: org.apache.nifi.serialization.RecordReader;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
label:
v = interfaceinvoke v.<org.apache.nifi.serialization.RecordReader: org.apache.nifi.serialization.record.Record nextRecord()>();
if v == null goto label;
v = interfaceinvoke v.<org.apache.nifi.serialization.record.Record: java.util.Map toMap()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
protected void testChain(org.apache.nifi.serialization.RecordSetWriterFactory, org.apache.nifi.serialization.RecordReaderFactory) throws org.apache.nifi.reporting.InitializationException
{
java.util.function.Consumer v, v, v;
org.apache.nifi.serialization.RecordReaderFactory v, v;
org.apache.nifi.serialization.RecordSetWriterFactory v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: org.apache.nifi.serialization.RecordSetWriterFactory;
v := @parameter: org.apache.nifi.serialization.RecordReaderFactory;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: org.apache.nifi.serialization.RecordReaderFactory reader>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer readerConfigurer>;
v = v.<org.apache.nifi.processors.standard.AbstractConversionIT: java.util.function.Consumer inputHandler>;
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_testChain_13__13: java.util.function.Consumer bootstrap$(org.apache.nifi.processors.standard.AbstractConversionIT,org.apache.nifi.serialization.RecordReaderFactory)>(v, v);
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractConversionIT: void testConversion(org.apache.nifi.serialization.RecordReaderFactory,java.util.function.Consumer,org.apache.nifi.serialization.RecordSetWriterFactory,java.util.function.Consumer,java.util.function.Consumer,java.util.function.Consumer)>(v, v, v, null, v, v);
return;
}
protected void testConversion(org.apache.nifi.serialization.RecordReaderFactory, java.util.function.Consumer, org.apache.nifi.serialization.RecordSetWriterFactory, java.util.function.Consumer, java.util.function.Consumer, java.util.function.Consumer) throws org.apache.nifi.reporting.InitializationException
{
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v;
org.apache.nifi.processors.standard.AbstractConversionIT v;
org.apache.nifi.serialization.RecordSetWriterFactory v;
java.util.UUID v, v;
java.util.function.Consumer v, v, v, v, v, v;
java.util.List v;
org.apache.nifi.serialization.RecordReaderFactory v;
java.util.Optional v, v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.AbstractConversionIT;
v := @parameter: org.apache.nifi.serialization.RecordReaderFactory;
v := @parameter: java.util.function.Consumer;
v := @parameter: org.apache.nifi.serialization.RecordSetWriterFactory;
v := @parameter: java.util.function.Consumer;
v := @parameter: java.util.function.Consumer;
v := @parameter: java.util.function.Consumer;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ConvertRecord;");
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>(v, v);
v = staticinvoke <java.util.Optional: java.util.Optional ofNullable(java.lang.Object)>(v);
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_testConversion_14__14: java.util.function.Consumer bootstrap$(org.apache.nifi.util.TestRunner)>(v);
virtualinvoke v.<java.util.Optional: void ifPresent(java.util.function.Consumer)>(v);
v = staticinvoke <java.util.Optional: java.util.Optional ofNullable(java.lang.Object)>(v);
v = staticinvoke <org.apache.nifi.processors.standard.AbstractConversionIT$lambda_testConversion_15__15: java.util.function.Consumer bootstrap$(org.apache.nifi.util.TestRunner)>(v);
virtualinvoke v.<java.util.Optional: void ifPresent(java.util.function.Consumer)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.ConvertRecord: org.apache.nifi.components.PropertyDescriptor RECORD_READER>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.ConvertRecord: org.apache.nifi.components.PropertyDescriptor RECORD_WRITER>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ConvertRecord: 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.ConvertRecord: 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);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
return;
}
}