public class org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy extends org.apache.nifi.processors.standard.enrichment.IndexCorrelatedJoinStrategy
{
private static final java.lang.String ORIGINAL_FIELD_NAME;
private static final java.lang.String ENRICHMENT_FIELD_NAME;
public void <init>(org.apache.nifi.logging.ComponentLog)
{
org.apache.nifi.logging.ComponentLog v;
org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy v;
v := @this: org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy;
v := @parameter: org.apache.nifi.logging.ComponentLog;
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.IndexCorrelatedJoinStrategy: void <init>(org.apache.nifi.logging.ComponentLog)>(v);
return;
}
protected 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)
{
org.apache.nifi.serialization.record.RecordSchema v;
java.util.HashMap v;
org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy v;
org.apache.nifi.serialization.record.Record v, v;
org.apache.nifi.serialization.record.MapRecord v;
v := @this: org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy;
v := @parameter: org.apache.nifi.serialization.record.Record;
v := @parameter: org.apache.nifi.serialization.record.Record;
v := @parameter: org.apache.nifi.serialization.record.RecordSchema;
if v != null goto label;
if v != null goto label;
return null;
label:
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)>("original", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("enrichment", v);
v = new org.apache.nifi.serialization.record.MapRecord;
specialinvoke v.<org.apache.nifi.serialization.record.MapRecord: void <init>(org.apache.nifi.serialization.record.RecordSchema,java.util.Map)>(v, v);
return v;
}
protected org.apache.nifi.serialization.record.RecordSchema createResultSchema(org.apache.nifi.serialization.record.Record, org.apache.nifi.serialization.record.Record)
{
org.apache.nifi.serialization.record.RecordField v, v;
org.apache.nifi.serialization.record.DataType v, v;
org.apache.nifi.serialization.SimpleRecordSchema v;
org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy v;
java.util.ArrayList v;
org.apache.nifi.serialization.record.RecordSchema v, v;
org.apache.nifi.serialization.record.RecordFieldType v, v;
org.apache.nifi.serialization.record.Record v, v;
v := @this: org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy;
v := @parameter: org.apache.nifi.serialization.record.Record;
v := @parameter: org.apache.nifi.serialization.record.Record;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
if v == null goto label;
v = new org.apache.nifi.serialization.record.RecordField;
v = <org.apache.nifi.serialization.record.RecordFieldType: org.apache.nifi.serialization.record.RecordFieldType RECORD>;
v = interfaceinvoke v.<org.apache.nifi.serialization.record.Record: org.apache.nifi.serialization.record.RecordSchema getSchema()>();
v = virtualinvoke v.<org.apache.nifi.serialization.record.RecordFieldType: org.apache.nifi.serialization.record.DataType getRecordDataType(org.apache.nifi.serialization.record.RecordSchema)>(v);
specialinvoke v.<org.apache.nifi.serialization.record.RecordField: void <init>(java.lang.String,org.apache.nifi.serialization.record.DataType)>("original", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
if v == null goto label;
v = new org.apache.nifi.serialization.record.RecordField;
v = <org.apache.nifi.serialization.record.RecordFieldType: org.apache.nifi.serialization.record.RecordFieldType RECORD>;
v = interfaceinvoke v.<org.apache.nifi.serialization.record.Record: org.apache.nifi.serialization.record.RecordSchema getSchema()>();
v = virtualinvoke v.<org.apache.nifi.serialization.record.RecordFieldType: org.apache.nifi.serialization.record.DataType getRecordDataType(org.apache.nifi.serialization.record.RecordSchema)>(v);
specialinvoke v.<org.apache.nifi.serialization.record.RecordField: void <init>(java.lang.String,org.apache.nifi.serialization.record.DataType)>("enrichment", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = new org.apache.nifi.serialization.SimpleRecordSchema;
specialinvoke v.<org.apache.nifi.serialization.SimpleRecordSchema: void <init>(java.util.List)>(v);
return v;
}
}