public class org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy extends org.apache.nifi.processors.standard.enrichment.TestIndexCorrelatedJoinStrategy
{
public void <init>()
{
org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy v;
v := @this: org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy;
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.TestIndexCorrelatedJoinStrategy: void <init>()>();
return;
}
public void testSimpleJoin()
{
org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy v;
org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy v;
org.apache.nifi.serialization.record.RecordSchema v, v, v, v, v;
int v;
org.apache.nifi.serialization.record.Record v, v, v;
java.util.List v;
java.util.Optional v, v;
java.lang.Object v, v, v, v;
org.apache.nifi.mock.MockComponentLogger v;
v := @this: org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy;
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy: org.apache.nifi.serialization.record.RecordSchema getOriginalSchema()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy: org.apache.nifi.serialization.record.RecordSchema getEnrichmentSchema()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy: org.apache.nifi.serialization.record.Record createOriginalRecord(int)>(555);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy: org.apache.nifi.serialization.record.Record createEnrichmentRecord(int,java.lang.String,int)>(555, "John Doe", 100);
v = new org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy;
v = new org.apache.nifi.mock.MockComponentLogger;
specialinvoke v.<org.apache.nifi.mock.MockComponentLogger: void <init>()>();
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: void <init>(org.apache.nifi.logging.ComponentLog)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: org.apache.nifi.serialization.record.RecordSchema createResultSchema(org.apache.nifi.serialization.record.Record,org.apache.nifi.serialization.record.Record)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.RecordSchema: java.util.List getFields()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(2, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.RecordSchema: java.util.Optional getDataType(java.lang.String)>("original");
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.nifi.serialization.record.type.RecordDataType: org.apache.nifi.serialization.record.RecordSchema getChildSchema()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.RecordSchema: java.util.Optional getDataType(java.lang.String)>("enrichment");
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.nifi.serialization.record.type.RecordDataType: org.apache.nifi.serialization.record.RecordSchema getChildSchema()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: org.apache.nifi.serialization.record.Record combineRecords(org.apache.nifi.serialization.record.Record,org.apache.nifi.serialization.record.Record,org.apache.nifi.serialization.record.RecordSchema)>(v, v, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.Record: java.lang.Object getValue(java.lang.String)>("original");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.Record: java.lang.Object getValue(java.lang.String)>("enrichment");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void testNullEnrichment()
{
org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy v;
org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy v;
java.util.List v;
org.apache.nifi.serialization.record.RecordSchema v, v, v;
int v;
java.util.Optional v;
java.lang.Object v, v, v;
org.apache.nifi.mock.MockComponentLogger v;
org.apache.nifi.serialization.record.Record v, v;
v := @this: org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy;
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy: org.apache.nifi.serialization.record.RecordSchema getOriginalSchema()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy: org.apache.nifi.serialization.record.Record createOriginalRecord(int)>(555);
v = new org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy;
v = new org.apache.nifi.mock.MockComponentLogger;
specialinvoke v.<org.apache.nifi.mock.MockComponentLogger: void <init>()>();
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: void <init>(org.apache.nifi.logging.ComponentLog)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: org.apache.nifi.serialization.record.RecordSchema createResultSchema(org.apache.nifi.serialization.record.Record,org.apache.nifi.serialization.record.Record)>(v, null);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.RecordSchema: java.util.List getFields()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.RecordSchema: java.util.Optional getDataType(java.lang.String)>("original");
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.nifi.serialization.record.type.RecordDataType: org.apache.nifi.serialization.record.RecordSchema getChildSchema()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: org.apache.nifi.serialization.record.Record combineRecords(org.apache.nifi.serialization.record.Record,org.apache.nifi.serialization.record.Record,org.apache.nifi.serialization.record.RecordSchema)>(v, null, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.Record: java.lang.Object getValue(java.lang.String)>("original");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.Record: java.lang.Object getValue(java.lang.String)>("enrichment");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(null, v);
return;
}
public void testNullOriginal()
{
org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy v;
org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy v;
java.util.List v;
org.apache.nifi.serialization.record.RecordSchema v, v, v;
int v;
java.util.Optional v;
java.lang.Object v, v, v;
org.apache.nifi.mock.MockComponentLogger v;
org.apache.nifi.serialization.record.Record v, v;
v := @this: org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy;
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy: org.apache.nifi.serialization.record.RecordSchema getEnrichmentSchema()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy: org.apache.nifi.serialization.record.Record createEnrichmentRecord(int,java.lang.String,int)>(555, "John Doe", 100);
v = new org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy;
v = new org.apache.nifi.mock.MockComponentLogger;
specialinvoke v.<org.apache.nifi.mock.MockComponentLogger: void <init>()>();
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: void <init>(org.apache.nifi.logging.ComponentLog)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: org.apache.nifi.serialization.record.RecordSchema createResultSchema(org.apache.nifi.serialization.record.Record,org.apache.nifi.serialization.record.Record)>(null, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.RecordSchema: java.util.List getFields()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.RecordSchema: java.util.Optional getDataType(java.lang.String)>("enrichment");
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.nifi.serialization.record.type.RecordDataType: org.apache.nifi.serialization.record.RecordSchema getChildSchema()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: org.apache.nifi.serialization.record.Record combineRecords(org.apache.nifi.serialization.record.Record,org.apache.nifi.serialization.record.Record,org.apache.nifi.serialization.record.RecordSchema)>(null, v, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.Record: java.lang.Object getValue(java.lang.String)>("original");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(null, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.Record: java.lang.Object getValue(java.lang.String)>("enrichment");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void testCombineNullOriginalNullEnrichment()
{
java.util.List v;
org.apache.nifi.serialization.record.RecordSchema v;
org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy v;
int v;
org.apache.nifi.mock.MockComponentLogger v;
org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy v;
org.apache.nifi.serialization.record.Record v;
v := @this: org.apache.nifi.processors.standard.enrichment.TestWrapperJoinStrategy;
v = new org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy;
v = new org.apache.nifi.mock.MockComponentLogger;
specialinvoke v.<org.apache.nifi.mock.MockComponentLogger: void <init>()>();
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: void <init>(org.apache.nifi.logging.ComponentLog)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: org.apache.nifi.serialization.record.RecordSchema createResultSchema(org.apache.nifi.serialization.record.Record,org.apache.nifi.serialization.record.Record)>(null, null);
v = interfaceinvoke v.<org.apache.nifi.serialization.record.RecordSchema: java.util.List getFields()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: org.apache.nifi.serialization.record.Record combineRecords(org.apache.nifi.serialization.record.Record,org.apache.nifi.serialization.record.Record,org.apache.nifi.serialization.record.RecordSchema)>(null, null, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
return;
}
}