public class org.apache.nifi.processors.standard.JoinEnrichment extends org.apache.nifi.processor.util.bin.BinFiles
{
static final java.lang.String GROUP_ID_ATTRIBUTE;
static final java.lang.String ENRICHMENT_ROLE_ATTRIBUTE;
static final java.lang.String RECORD_COUNT_ATTRIBUTE;
static final org.apache.nifi.components.AllowableValue JOIN_WRAPPER;
static final org.apache.nifi.components.AllowableValue JOIN_SQL;
static final org.apache.nifi.components.AllowableValue JOIN_INSERT_ENRICHMENT_FIELDS;
static final org.apache.nifi.components.PropertyDescriptor ORIGINAL_RECORD_READER;
static final org.apache.nifi.components.PropertyDescriptor ENRICHMENT_RECORD_READER;
static final org.apache.nifi.components.PropertyDescriptor RECORD_WRITER;
static final org.apache.nifi.components.PropertyDescriptor JOIN_STRATEGY;
static final org.apache.nifi.components.PropertyDescriptor SQL;
static final org.apache.nifi.components.PropertyDescriptor DEFAULT_PRECISION;
static final org.apache.nifi.components.PropertyDescriptor DEFAULT_SCALE;
static final org.apache.nifi.components.PropertyDescriptor INSERTION_RECORD_PATH;
static final org.apache.nifi.components.PropertyDescriptor TIMEOUT;
static final org.apache.nifi.components.PropertyDescriptor MAX_BIN_COUNT;
private static final java.util.List properties;
static final org.apache.nifi.processor.Relationship REL_JOINED;
static final org.apache.nifi.processor.Relationship REL_ORIGINAL;
static final org.apache.nifi.processor.Relationship REL_TIMEOUT;
static final org.apache.nifi.processor.Relationship REL_FAILURE;
private static final java.util.Set relationships;
private final org.apache.nifi.processors.standard.enrichment.SqlJoinCache sqlJoinCache;
public void <init>()
{
org.apache.nifi.processors.standard.JoinEnrichment v;
org.apache.nifi.processors.standard.enrichment.SqlJoinCache v;
org.apache.nifi.logging.ComponentLog v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
specialinvoke v.<org.apache.nifi.processor.util.bin.BinFiles: void <init>()>();
v = new org.apache.nifi.processors.standard.enrichment.SqlJoinCache;
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.SqlJoinCache: void <init>(org.apache.nifi.logging.ComponentLog)>(v);
v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processors.standard.enrichment.SqlJoinCache sqlJoinCache> = v;
return;
}
protected java.util.List getSupportedPropertyDescriptors()
{
org.apache.nifi.processors.standard.JoinEnrichment v;
java.util.List v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v = <org.apache.nifi.processors.standard.JoinEnrichment: java.util.List properties>;
return v;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.JoinEnrichment v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v = <org.apache.nifi.processors.standard.JoinEnrichment: java.util.Set relationships>;
return v;
}
public void registerCalciteDriver()
{
org.apache.nifi.processors.standard.JoinEnrichment v;
java.sql.SQLException v;
org.apache.calcite.jdbc.Driver v;
org.apache.nifi.processor.exception.ProcessException v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
label:
v = new org.apache.calcite.jdbc.Driver;
specialinvoke v.<org.apache.calcite.jdbc.Driver: void <init>()>();
staticinvoke <java.sql.DriverManager: void registerDriver(java.sql.Driver)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.nifi.processor.exception.ProcessException;
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.String,java.lang.Throwable)>("Failed to load Calcite JDBC Driver", v);
throw v;
label:
return;
catch java.sql.SQLException from label to label with label;
}
public synchronized void cleanup() throws java.lang.Exception
{
org.apache.nifi.processors.standard.JoinEnrichment v;
org.apache.nifi.processors.standard.enrichment.SqlJoinCache v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v = v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processors.standard.enrichment.SqlJoinCache sqlJoinCache>;
virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.SqlJoinCache: void close()>();
return;
}
protected org.apache.nifi.flowfile.FlowFile preprocessFlowFile(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession, org.apache.nifi.flowfile.FlowFile)
{
org.apache.nifi.processors.standard.JoinEnrichment v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.ProcessSession v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
return v;
}
protected java.lang.String getGroupId(org.apache.nifi.processor.ProcessContext, org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processor.ProcessSession)
{
org.apache.nifi.processors.standard.JoinEnrichment v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.ProcessSession v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>("enrichment.group.id");
return v;
}
protected void setUpBinManager(org.apache.nifi.processor.util.bin.BinManager, org.apache.nifi.processor.ProcessContext)
{
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.util.bin.BinManager v;
org.apache.nifi.processors.standard.JoinEnrichment v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.processor.util.bin.BinManager;
v := @parameter: org.apache.nifi.processor.ProcessContext;
return;
}
protected int getMinEntries(org.apache.nifi.context.PropertyContext)
{
org.apache.nifi.processors.standard.JoinEnrichment v;
org.apache.nifi.context.PropertyContext v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.context.PropertyContext;
return 2;
}
protected int getMaxEntries(org.apache.nifi.context.PropertyContext)
{
org.apache.nifi.processors.standard.JoinEnrichment v;
org.apache.nifi.context.PropertyContext v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.context.PropertyContext;
return 2;
}
protected long getMinBytes(org.apache.nifi.context.PropertyContext)
{
org.apache.nifi.processors.standard.JoinEnrichment v;
org.apache.nifi.context.PropertyContext v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.context.PropertyContext;
return 0L;
}
protected long getMaxBytes(org.apache.nifi.context.PropertyContext)
{
org.apache.nifi.processors.standard.JoinEnrichment v;
org.apache.nifi.context.PropertyContext v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.context.PropertyContext;
return 9223372036854775807L;
}
protected int getMaxBinAgeSeconds(org.apache.nifi.context.PropertyContext)
{
java.util.concurrent.TimeUnit v;
org.apache.nifi.processors.standard.JoinEnrichment v;
java.lang.Long v;
int v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyValue v;
org.apache.nifi.context.PropertyContext v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.context.PropertyContext;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor TIMEOUT>;
v = interfaceinvoke v.<org.apache.nifi.context.PropertyContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: int intValue()>();
return v;
}
protected org.apache.nifi.processor.util.bin.BinProcessingResult processBin(org.apache.nifi.processor.util.bin.Bin, org.apache.nifi.processor.ProcessContext) throws org.apache.nifi.processor.exception.ProcessException
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.serialization.record.RecordSchema v, v, v, v, v;
java.util.Map v, v, v;
org.apache.nifi.serialization.WriteResult v;
java.lang.Exception v, v, v, v;
org.apache.nifi.controller.ControllerService v, v, v;
java.lang.Throwable v, v, v;
java.lang.Object[] v, v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
java.lang.String v, v, v, v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processors.standard.JoinEnrichment v;
org.apache.nifi.processor.util.bin.BinProcessingResult v, v, v, v, v, v, v, v;
org.apache.nifi.serialization.record.RecordSet v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
org.apache.nifi.processors.standard.enrichment.EnrichmentRole v, v, v, v;
org.apache.nifi.processors.standard.enrichment.RecordJoinStrategy v;
org.apache.nifi.components.PropertyValue v, v, v;
org.apache.nifi.processors.standard.enrichment.RecordJoinResult v;
org.apache.nifi.flowfile.FlowFile v, v, v;
org.apache.nifi.processor.util.bin.Bin v;
java.util.List v;
java.util.HashMap v, v;
org.apache.nifi.logging.ComponentLog v, v, v, v, v, v, v;
int v, v;
org.apache.nifi.processors.standard.enrichment.RecordJoinInput v, v;
org.apache.nifi.processor.util.bin.EvictionReason v, v;
java.io.OutputStream v;
org.apache.nifi.processor.ProcessContext v;
java.lang.Object v, v;
org.apache.nifi.serialization.RecordSetWriter v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.processor.util.bin.Bin;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.Bin: org.apache.nifi.processor.ProcessSession getSession()>();
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.Bin: java.util.List getContents()>();
v = interfaceinvoke v.<java.util.List: int size()>();
if v == 2 goto label;
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.Bin: org.apache.nifi.processor.util.bin.EvictionReason getEvictionReason()>();
v = <org.apache.nifi.processor.util.bin.EvictionReason: org.apache.nifi.processor.util.bin.EvictionReason BIN_MANAGER_FULL>;
if v != v goto label;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection)>(v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync()>();
v = new org.apache.nifi.processor.util.bin.BinProcessingResult;
specialinvoke v.<org.apache.nifi.processor.util.bin.BinProcessingResult: void <init>(boolean)>(1);
return v;
label:
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_TIMEOUT>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processors.standard.enrichment.EnrichmentRole getEnrichmentRole(org.apache.nifi.flowfile.FlowFile)>(v);
if v != null goto label;
v = "other";
goto label;
label:
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processors.standard.enrichment.EnrichmentRole getOtherEnrichmentRole(org.apache.nifi.processors.standard.enrichment.EnrichmentRole)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.EnrichmentRole: java.lang.String name()>();
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[3];
v[0] = v;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v[1] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_TIMEOUT>;
v = virtualinvoke v.<org.apache.nifi.processor.Relationship: java.lang.String getName()>();
v[2] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String,java.lang.Object[])>("Timed out waiting for the {} FlowFile to match {}; routing to {}", v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync()>();
v = new org.apache.nifi.processor.util.bin.BinProcessingResult;
specialinvoke v.<org.apache.nifi.processor.util.bin.BinProcessingResult: void <init>(boolean)>(1);
return v;
label:
v = <org.apache.nifi.processors.standard.enrichment.EnrichmentRole: org.apache.nifi.processors.standard.enrichment.EnrichmentRole ORIGINAL>;
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.flowfile.FlowFile getFlowFileWithRole(java.util.Collection,org.apache.nifi.processors.standard.enrichment.EnrichmentRole)>(v, v);
v = <org.apache.nifi.processors.standard.enrichment.EnrichmentRole: org.apache.nifi.processors.standard.enrichment.EnrichmentRole ENRICHMENT>;
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.flowfile.FlowFile getFlowFileWithRole(java.util.Collection,org.apache.nifi.processors.standard.enrichment.EnrichmentRole)>(v, v);
if v == null goto label;
if v != null goto label;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_FAILURE>;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Received two FlowFiles {} but could not find both an \'original\' and an \'enrichment\' FlowFile. The FlowFiles do not appear to have the proper attributes necessary for use with this Processor. Routing to {}", v);
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.util.bin.BinProcessingResult transferFailure(java.util.List,org.apache.nifi.processor.ProcessSession)>(v, v);
return v;
label:
v = new java.util.HashMap;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.util.Map getAttributes()>();
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.util.Map getAttributes()>();
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor ORIGINAL_RECORD_READER>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.controller.ControllerService asControllerService(java.lang.Class)>(class "Lorg/apache/nifi/serialization/RecordReaderFactory;");
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor ENRICHMENT_RECORD_READER>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.controller.ControllerService asControllerService(java.lang.Class)>(class "Lorg/apache/nifi/serialization/RecordReaderFactory;");
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor RECORD_WRITER>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.controller.ControllerService asControllerService(java.lang.Class)>(class "Lorg/apache/nifi/serialization/RecordSetWriterFactory;");
label:
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.serialization.record.RecordSchema getReaderSchema(org.apache.nifi.serialization.RecordReaderFactory,org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.ProcessSession)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to determine Record Schema from \'original\' FlowFile {}; routing to failure", v);
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.util.bin.BinProcessingResult transferFailure(java.util.List,org.apache.nifi.processor.ProcessSession)>(v, v);
return v;
label:
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.serialization.record.RecordSchema getReaderSchema(org.apache.nifi.serialization.RecordReaderFactory,org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.ProcessSession)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to determine Record Schema from \'enrichment\' FlowFile {}; routing to failure", v);
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.util.bin.BinProcessingResult transferFailure(java.util.List,org.apache.nifi.processor.ProcessSession)>(v, v);
return v;
label:
v = staticinvoke <org.apache.nifi.serialization.record.util.DataTypeUtils: org.apache.nifi.serialization.record.RecordSchema merge(org.apache.nifi.serialization.record.RecordSchema,org.apache.nifi.serialization.record.RecordSchema)>(v, v);
label:
v = interfaceinvoke v.<org.apache.nifi.serialization.RecordSetWriterFactory: org.apache.nifi.serialization.record.RecordSchema getSchema(java.util.Map,org.apache.nifi.serialization.record.RecordSchema)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to determine Record Schema for the Record Writer from \'original\' FlowFile {} and \'enrichment\' FLowFile {}; routing to failure", v);
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.util.bin.BinProcessingResult transferFailure(java.util.List,org.apache.nifi.processor.ProcessSession)>(v, v);
return v;
label:
v = new org.apache.nifi.processors.standard.enrichment.RecordJoinInput;
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.RecordJoinInput: void <init>(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.serialization.RecordReaderFactory,org.apache.nifi.serialization.record.RecordSchema)>(v, v, v);
v = new org.apache.nifi.processors.standard.enrichment.RecordJoinInput;
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.RecordJoinInput: void <init>(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.serialization.RecordReaderFactory,org.apache.nifi.serialization.record.RecordSchema)>(v, v, v);
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processors.standard.enrichment.RecordJoinStrategy getJoinStrategy(org.apache.nifi.processor.ProcessContext,java.util.Map)>(v, v);
label:
v = interfaceinvoke v.<org.apache.nifi.processors.standard.enrichment.RecordJoinStrategy: org.apache.nifi.processors.standard.enrichment.RecordJoinResult join(org.apache.nifi.processors.standard.enrichment.RecordJoinInput,org.apache.nifi.processors.standard.enrichment.RecordJoinInput,org.apache.nifi.processor.ProcessSession,org.apache.nifi.serialization.record.RecordSchema)>(v, v, v, v);
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create(java.util.Collection)>(v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: java.io.OutputStream write(org.apache.nifi.flowfile.FlowFile)>(v);
label:
v = interfaceinvoke v.<org.apache.nifi.processors.standard.enrichment.RecordJoinResult: org.apache.nifi.serialization.record.RecordSet getRecordSet()>();
v = interfaceinvoke v.<org.apache.nifi.serialization.record.RecordSet: org.apache.nifi.serialization.record.RecordSchema getSchema()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
v = interfaceinvoke v.<org.apache.nifi.serialization.RecordSetWriterFactory: org.apache.nifi.serialization.RecordSetWriter createWriter(org.apache.nifi.logging.ComponentLog,org.apache.nifi.serialization.record.RecordSchema,java.io.OutputStream,java.util.Map)>(v, v, v, v);
label:
v = interfaceinvoke v.<org.apache.nifi.serialization.RecordSetWriter: org.apache.nifi.serialization.WriteResult write(org.apache.nifi.serialization.record.RecordSet)>(v);
v = interfaceinvoke v.<org.apache.nifi.serialization.RecordSetWriter: java.lang.String getMimeType()>();
label:
interfaceinvoke v.<org.apache.nifi.serialization.RecordSetWriter: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
if v == null goto label;
virtualinvoke v.<java.io.OutputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
interfaceinvoke v.<org.apache.nifi.processors.standard.enrichment.RecordJoinResult: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to join \'original\' FlowFile {} and \'enrichment\' FlowFile {}; routing to failure", v);
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.util.bin.BinProcessingResult transferFailure(java.util.List,org.apache.nifi.processor.ProcessSession)>(v, v);
return v;
label:
v = new java.util.HashMap;
v = interfaceinvoke v.<org.apache.nifi.serialization.WriteResult: java.util.Map getAttributes()>();
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = interfaceinvoke v.<org.apache.nifi.serialization.WriteResult: int getRecordCount()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("record.count", v);
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, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAllAttributes(org.apache.nifi.flowfile.FlowFile,java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void adjustCounter(java.lang.String,long,boolean)>("Records Written", v, 0);
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_JOINED>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = new org.apache.nifi.processor.util.bin.BinProcessingResult;
specialinvoke v.<org.apache.nifi.processor.util.bin.BinProcessingResult: void <init>(boolean)>(0);
return v;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
}
private org.apache.nifi.serialization.record.RecordSchema getReaderSchema(org.apache.nifi.serialization.RecordReaderFactory, org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processor.ProcessSession) throws java.io.IOException, org.apache.nifi.serialization.MalformedRecordException, org.apache.nifi.schema.access.SchemaNotFoundException
{
java.lang.Throwable v;
org.apache.nifi.flowfile.FlowFile v;
long v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.logging.ComponentLog v;
org.apache.nifi.processors.standard.JoinEnrichment v;
org.apache.nifi.serialization.record.RecordSchema v;
org.apache.nifi.serialization.RecordReaderFactory v;
org.apache.nifi.serialization.RecordReader v;
java.util.Map v;
java.io.InputStream v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.serialization.RecordReaderFactory;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: java.io.InputStream read(org.apache.nifi.flowfile.FlowFile)>(v);
label:
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.util.Map getAttributes()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
v = interfaceinvoke v.<org.apache.nifi.serialization.RecordReaderFactory: org.apache.nifi.serialization.RecordReader createRecordReader(java.util.Map,java.io.InputStream,long,org.apache.nifi.logging.ComponentLog)>(v, v, v, v);
v = interfaceinvoke v.<org.apache.nifi.serialization.RecordReader: org.apache.nifi.serialization.record.RecordSchema getSchema()>();
label:
if v == null goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
label:
return v;
label:
v := @caughtexception;
throw v;
catch java.lang.Throwable from label to label with label;
}
private org.apache.nifi.processor.util.bin.BinProcessingResult transferFailure(java.util.List, org.apache.nifi.processor.ProcessSession)
{
org.apache.nifi.processors.standard.JoinEnrichment v;
java.util.List v;
org.apache.nifi.processor.util.bin.BinProcessingResult v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.processor.ProcessSession v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: java.util.List;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync()>();
v = new org.apache.nifi.processor.util.bin.BinProcessingResult;
specialinvoke v.<org.apache.nifi.processor.util.bin.BinProcessingResult: void <init>(boolean)>(1);
return v;
}
private org.apache.nifi.processors.standard.enrichment.RecordJoinStrategy getJoinStrategy(org.apache.nifi.processor.ProcessContext, java.util.Map)
{
org.apache.nifi.processors.standard.enrichment.InsertRecordFieldsJoinStrategy v;
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v;
java.util.Map v;
boolean v, v, v;
org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy v;
org.apache.nifi.components.AllowableValue v, v, v;
org.apache.nifi.processors.standard.enrichment.SqlJoinCache v;
org.apache.nifi.logging.ComponentLog v, v, v;
org.apache.nifi.processor.exception.ProcessException v;
int v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processors.standard.JoinEnrichment v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: java.util.Map;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor JOIN_STRATEGY>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_SQL>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor SQL>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor DEFAULT_PRECISION>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(java.util.Map)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor DEFAULT_SCALE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(java.util.Map)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = new org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy;
v = v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processors.standard.enrichment.SqlJoinCache sqlJoinCache>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy: void <init>(org.apache.nifi.processors.standard.enrichment.SqlJoinCache,java.lang.String,org.apache.nifi.logging.ComponentLog,int,int)>(v, v, v, v, v);
return v;
label:
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_WRAPPER>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = new org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy;
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.WrapperJoinStrategy: void <init>(org.apache.nifi.logging.ComponentLog)>(v);
return v;
label:
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_INSERT_ENRICHMENT_FIELDS>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor INSERTION_RECORD_PATH>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(java.util.Map)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = new org.apache.nifi.processors.standard.enrichment.InsertRecordFieldsJoinStrategy;
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
specialinvoke v.<org.apache.nifi.processors.standard.enrichment.InsertRecordFieldsJoinStrategy: void <init>(org.apache.nifi.logging.ComponentLog,java.lang.String)>(v, v);
return v;
label:
v = new org.apache.nifi.processor.exception.ProcessException;
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[])>("Invalid Join Strategy: \u0001");
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.String)>(v);
throw v;
}
private org.apache.nifi.flowfile.FlowFile getFlowFileWithRole(java.util.Collection, org.apache.nifi.processors.standard.enrichment.EnrichmentRole)
{
org.apache.nifi.processors.standard.JoinEnrichment v;
java.util.Iterator v;
java.util.Collection v;
java.lang.Object v;
org.apache.nifi.processors.standard.enrichment.EnrichmentRole v, v;
boolean v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.nifi.processors.standard.enrichment.EnrichmentRole;
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processors.standard.enrichment.EnrichmentRole getEnrichmentRole(org.apache.nifi.flowfile.FlowFile)>(v);
if v != v goto label;
return v;
label:
return null;
}
private org.apache.nifi.processors.standard.enrichment.EnrichmentRole getEnrichmentRole(org.apache.nifi.flowfile.FlowFile)
{
org.apache.nifi.processors.standard.JoinEnrichment v;
org.apache.nifi.flowfile.FlowFile v;
java.lang.String v;
org.apache.nifi.processors.standard.enrichment.EnrichmentRole v, v, v;
java.lang.Exception v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>("enrichment.role");
if v != null goto label;
v = <org.apache.nifi.processors.standard.enrichment.EnrichmentRole: org.apache.nifi.processors.standard.enrichment.EnrichmentRole UNKNOWN>;
return v;
label:
v = staticinvoke <org.apache.nifi.processors.standard.enrichment.EnrichmentRole: org.apache.nifi.processors.standard.enrichment.EnrichmentRole valueOf(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
v = <org.apache.nifi.processors.standard.enrichment.EnrichmentRole: org.apache.nifi.processors.standard.enrichment.EnrichmentRole UNKNOWN>;
return v;
catch java.lang.Exception from label to label with label;
}
private org.apache.nifi.processors.standard.enrichment.EnrichmentRole getOtherEnrichmentRole(org.apache.nifi.processors.standard.enrichment.EnrichmentRole)
{
org.apache.nifi.processors.standard.JoinEnrichment v;
int[] v;
int v, v;
org.apache.nifi.processors.standard.enrichment.EnrichmentRole v, v, v, v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.processors.standard.enrichment.EnrichmentRole;
if v != null goto label;
return null;
label:
v = <org.apache.nifi.processors.standard.JoinEnrichment$1: int[] $SwitchMap$org$apache$nifi$processors$standard$enrichment$EnrichmentRole>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.enrichment.EnrichmentRole: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = <org.apache.nifi.processors.standard.enrichment.EnrichmentRole: org.apache.nifi.processors.standard.enrichment.EnrichmentRole ORIGINAL>;
return v;
label:
v = <org.apache.nifi.processors.standard.enrichment.EnrichmentRole: org.apache.nifi.processors.standard.enrichment.EnrichmentRole ENRICHMENT>;
return v;
label:
v = <org.apache.nifi.processors.standard.enrichment.EnrichmentRole: org.apache.nifi.processors.standard.enrichment.EnrichmentRole UNKNOWN>;
return v;
label:
return null;
}
protected int processBins(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSessionFactory)
{
java.lang.Integer v, v;
byte v;
boolean v, v, v, v;
java.lang.Exception v;
java.util.List v, v, v, v, v, v;
java.util.Queue v;
java.lang.Throwable v;
java.lang.Object[] v, v;
long v, v, v;
org.apache.nifi.logging.ComponentLog v;
org.apache.nifi.processor.Relationship v, v;
int v, v, v, v, v, v;
java.util.Iterator v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.ProcessSession v, v, v, v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.function.Consumer v;
org.apache.nifi.processors.standard.JoinEnrichment v;
org.apache.nifi.processor.util.bin.BinProcessingResult v;
java.lang.Object v, v, v;
v := @this: org.apache.nifi.processors.standard.JoinEnrichment;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSessionFactory;
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: java.util.Queue getReadyBins()>();
v = interfaceinvoke v.<java.util.Queue: int size()>();
if v > 1 goto label;
v = specialinvoke v.<org.apache.nifi.processor.util.bin.BinFiles: int processBins(org.apache.nifi.processor.ProcessContext,org.apache.nifi.processor.ProcessSessionFactory)>(v, v);
return v;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.logging.ComponentLog getLogger()>();
v = 0;
v = 0L;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSessionFactory: org.apache.nifi.processor.ProcessSession createSession()>();
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: boolean isScheduled()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Queue: java.lang.Object poll()>();
if v == null goto label;
v = 0L;
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.Bin: java.util.List getContents()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = v + v;
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.util.bin.BinProcessingResult processBin(org.apache.nifi.processor.util.bin.Bin,org.apache.nifi.processor.ProcessContext)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.Bin: java.util.List getContents()>();
v = interfaceinvoke v.<java.util.List: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to process bundle of {} files", v);
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.Bin: org.apache.nifi.processor.ProcessSession getSession()>();
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.Bin: java.util.List getContents()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync()>();
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.Bin: java.util.List getContents()>();
v = interfaceinvoke v.<java.util.List: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to process bundle of {} files; rolling back sessions", v);
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.Bin: org.apache.nifi.processor.ProcessSession getSession()>();
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void rollback()>();
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.BinProcessingResult: boolean isCommitted()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.Bin: org.apache.nifi.processor.ProcessSession getSession()>();
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.Bin: java.util.List getContents()>();
v = staticinvoke <org.apache.nifi.processors.standard.JoinEnrichment$lambda_processBins_0__113: java.util.function.Consumer bootstrap$(org.apache.nifi.processor.ProcessSession,org.apache.nifi.processor.util.bin.BinProcessingResult)>(v, v);
interfaceinvoke v.<java.util.List: void forEach(java.util.function.Consumer)>(v);
v = virtualinvoke v.<org.apache.nifi.processor.util.bin.Bin: java.util.List getContents()>();
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void migrate(org.apache.nifi.processor.ProcessSession)>(v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync()>();
label:
v = v + 1;
v = v + v;
v = v % 100;
if v == 0 goto label;
v = v cmp 5000000L;
if v <= 0 goto label;
label:
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync()>();
label:
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync()>();
return v;
catch org.apache.nifi.processor.exception.ProcessException from label to label with label;
catch java.lang.Exception from label to label with label;
}
static void <clinit>()
{
org.apache.nifi.record.path.validation.RecordPathValidator v;
org.apache.nifi.components.AllowableValue v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v;
org.apache.nifi.expression.ExpressionLanguageScope v, v;
org.apache.nifi.processor.Relationship[] v;
java.util.HashSet v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Set v;
java.lang.String v;
org.apache.nifi.components.PropertyDescriptor[] v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.List v, v, v;
org.apache.nifi.components.AllowableValue[] v, v, v, v, v;
org.apache.nifi.components.Validator v, v;
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v, v, v, v, v, v, v, v;
v = new org.apache.nifi.components.AllowableValue;
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String,java.lang.String)>("Wrapper", "Wrapper", "The output is a Record that contains two fields: (1) \'original\', containing the Record from the original FlowFile and (2) \'enrichment\' containing the corresponding Record from the enrichment FlowFile. Records will be correlated based on their index in the FlowFile. If one FlowFile has more Records than the other, a null value will be used.");
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_WRAPPER> = v;
v = new org.apache.nifi.components.AllowableValue;
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String,java.lang.String)>("SQL", "SQL", "The output is derived by evaluating a SQL SELECT statement that allows for two tables: \'original\' and \'enrichment\'. This allows for SQL JOIN statements to be used in order to correlate the Records of the two FlowFiles, so the index in which the Record is encountered in the FlowFile does not matter.");
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_SQL> = v;
v = new org.apache.nifi.components.AllowableValue;
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String,java.lang.String)>("Insert Enrichment Fields", "Insert Enrichment Fields", "The enrichment is joined together with the original FlowFile by placing all fields of the enrichment Record into the corresponding Record from the original FlowFile. Records will be correlated based on their index in the FlowFile.");
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_INSERT_ENRICHMENT_FIELDS> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Original Record Reader");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Original Record Reader");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The Record Reader for reading the \'original\' FlowFile");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder identifiesControllerService(java.lang.Class)>(class "Lorg/apache/nifi/serialization/RecordReaderFactory;");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor ORIGINAL_RECORD_READER> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Enrichment Record Reader");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Enrichment Record Reader");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The Record Reader for reading the \'enrichment\' FlowFile");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder identifiesControllerService(java.lang.Class)>(class "Lorg/apache/nifi/serialization/RecordReaderFactory;");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor ENRICHMENT_RECORD_READER> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Record Writer");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Record Writer");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The Record Writer to use for writing the results. If the Record Writer is configured to inherit the schema from the Record, the schema that it will inherit will be the result of merging both the \'original\' record schema and the \'enrichment\' record schema.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder identifiesControllerService(java.lang.Class)>(class "Lorg/apache/nifi/serialization/RecordSetWriterFactory;");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor RECORD_WRITER> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Join Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Join Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies how to join the two FlowFiles into a single FlowFile");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (org.apache.nifi.components.AllowableValue)[3];
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_WRAPPER>;
v[0] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_SQL>;
v[1] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_INSERT_ENRICHMENT_FIELDS>;
v[2] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(org.apache.nifi.components.AllowableValue[])>(v);
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_WRAPPER>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor JOIN_STRATEGY> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("SQL");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("SQL");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The SQL SELECT statement to evaluate. Expression Language may be provided, but doing so may result in poorer performance. Because this Processor is dealing with two FlowFiles at a time, it\'s also important to understand how attributes will be referenced. If both FlowFiles have an attribute with the same name but different values, the Expression Language will resolve to the value provided by the \'enrichment\' FlowFile.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor JOIN_STRATEGY>;
v = newarray (org.apache.nifi.components.AllowableValue)[1];
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_SQL>;
v[0] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue[])>(v, v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("SELECT original.*, enrichment.* \nFROM original \nLEFT OUTER JOIN enrichment \nON original.id = enrichment.id");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor SQL> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = <org.apache.nifi.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor DEFAULT_PRECISION>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder fromPropertyDescriptor(org.apache.nifi.components.PropertyDescriptor)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor JOIN_STRATEGY>;
v = newarray (org.apache.nifi.components.AllowableValue)[1];
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_SQL>;
v[0] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue[])>(v, v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor DEFAULT_PRECISION> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = <org.apache.nifi.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor DEFAULT_SCALE>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder fromPropertyDescriptor(org.apache.nifi.components.PropertyDescriptor)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor JOIN_STRATEGY>;
v = newarray (org.apache.nifi.components.AllowableValue)[1];
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_SQL>;
v[0] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue[])>(v, v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor DEFAULT_SCALE> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Insertion Record Path");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Insertion Record Path");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies where in the \'original\' Record the \'enrichment\' Record\'s fields should be inserted. Note that if the RecordPath does not point to any existing field in the original Record, the enrichment will not be inserted.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = new org.apache.nifi.record.path.validation.RecordPathValidator;
specialinvoke v.<org.apache.nifi.record.path.validation.RecordPathValidator: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("/");
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor JOIN_STRATEGY>;
v = newarray (org.apache.nifi.components.AllowableValue)[1];
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.AllowableValue JOIN_INSERT_ENRICHMENT_FIELDS>;
v[0] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue[])>(v, v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor INSERTION_RECORD_PATH> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Timeout");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Timeout");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies the maximum amount of time to wait for the second FlowFile once the first arrives at the processor, after which point the first FlowFile will be routed to the \'timeout\' relationship.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator TIME_PERIOD_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("10 min");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor TIMEOUT> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = <org.apache.nifi.processor.util.bin.BinFiles: org.apache.nifi.components.PropertyDescriptor MAX_BIN_COUNT>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder fromPropertyDescriptor(org.apache.nifi.components.PropertyDescriptor)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("10000");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor MAX_BIN_COUNT> = v;
v = newarray (org.apache.nifi.components.PropertyDescriptor)[10];
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor ORIGINAL_RECORD_READER>;
v[0] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor ENRICHMENT_RECORD_READER>;
v[1] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor RECORD_WRITER>;
v[2] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor JOIN_STRATEGY>;
v[3] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor SQL>;
v[4] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor DEFAULT_PRECISION>;
v[5] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor DEFAULT_SCALE>;
v[6] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor INSERTION_RECORD_PATH>;
v[7] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor MAX_BIN_COUNT>;
v[8] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.components.PropertyDescriptor TIMEOUT>;
v[9] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
<org.apache.nifi.processors.standard.JoinEnrichment: java.util.List properties> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("joined");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("The resultant FlowFile with Records joined together from both the original and enrichment FlowFiles will be routed to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_JOINED> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("original");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("Both of the incoming FlowFiles (\'original\' and \'enrichment\') will be routed to this Relationship. I.e., this is the \'original\' version of both of these FlowFiles.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder autoTerminateDefault(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_ORIGINAL> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("timeout");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("If one of the incoming FlowFiles (i.e., the \'original\' FlowFile or the \'enrichment\' FlowFile) arrives to this Processor but the other does not arrive within the configured Timeout period, the FlowFile that did arrive is routed to this relationship.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_TIMEOUT> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("failure");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("If both the \'original\' and \'enrichment\' FlowFiles arrive at the processor but there was a failure in joining the records, both of those FlowFiles will be routed to this relationship.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
v = new java.util.HashSet;
v = newarray (org.apache.nifi.processor.Relationship)[4];
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_JOINED>;
v[0] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v[1] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_TIMEOUT>;
v[2] = v;
v = <org.apache.nifi.processors.standard.JoinEnrichment: org.apache.nifi.processor.Relationship REL_FAILURE>;
v[3] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
<org.apache.nifi.processors.standard.JoinEnrichment: java.util.Set relationships> = v;
return;
}
}