public class org.apache.nifi.processors.standard.GenerateTableFetch extends org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor
{
public static final org.apache.nifi.components.PropertyDescriptor PARTITION_SIZE;
static final org.apache.nifi.components.PropertyDescriptor COLUMN_FOR_VALUE_PARTITIONING;
static final org.apache.nifi.components.PropertyDescriptor OUTPUT_EMPTY_FLOWFILE_ON_ZERO_RESULTS;
static final org.apache.nifi.components.PropertyDescriptor CUSTOM_ORDERBY_COLUMN;
public static final org.apache.nifi.processor.Relationship REL_FAILURE;
public void <init>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v;
java.util.ArrayList v;
java.util.HashSet v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processors.standard.GenerateTableFetch v;
java.util.Set v;
java.util.List v;
v := @this: org.apache.nifi.processors.standard.GenerateTableFetch;
specialinvoke v.<org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor: void <init>()>();
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
v.<org.apache.nifi.processors.standard.GenerateTableFetch: java.util.Set relationships> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor DBCP_SERVICE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor DB_TYPE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor COLUMN_NAMES>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor MAX_VALUE_COLUMN_NAMES>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor QUERY_TIMEOUT>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor PARTITION_SIZE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor COLUMN_FOR_VALUE_PARTITIONING>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor WHERE_CLAUSE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor CUSTOM_ORDERBY_COLUMN>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor OUTPUT_EMPTY_FLOWFILE_ON_ZERO_RESULTS>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
v.<org.apache.nifi.processors.standard.GenerateTableFetch: java.util.List propDescriptors> = v;
return;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.GenerateTableFetch v;
v := @this: org.apache.nifi.processors.standard.GenerateTableFetch;
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: java.util.Set relationships>;
return v;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.GenerateTableFetch v;
v := @this: org.apache.nifi.processors.standard.GenerateTableFetch;
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: java.util.List propDescriptors>;
return v;
}
protected org.apache.nifi.components.PropertyDescriptor getSupportedDynamicPropertyDescriptor(java.lang.String)
{
org.apache.nifi.components.Validator v, v;
org.apache.nifi.expression.ExpressionLanguageScope v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v;
org.apache.nifi.expression.AttributeExpression$ResultType v;
org.apache.nifi.processors.standard.GenerateTableFetch v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.GenerateTableFetch;
v := @parameter: java.lang.String;
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)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = <org.apache.nifi.expression.AttributeExpression$ResultType: org.apache.nifi.expression.AttributeExpression$ResultType STRING>;
v = staticinvoke <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator createAttributeExpressionLanguageValidator(org.apache.nifi.expression.AttributeExpression$ResultType,boolean)>(v, 1);
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.processor.util.StandardValidators: org.apache.nifi.components.Validator ATTRIBUTE_KEY_PROPERTY_NAME_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 = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dynamic(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
return v;
}
protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)
{
org.apache.nifi.components.ValidationContext v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.ArrayList v;
org.apache.nifi.components.PropertyValue v;
org.apache.nifi.processors.standard.GenerateTableFetch v;
java.lang.String v, v, v;
org.apache.nifi.components.ValidationResult v;
boolean v, v, v;
org.apache.nifi.components.ValidationResult$Builder v, v, v;
java.util.Collection v;
v := @this: org.apache.nifi.processors.standard.GenerateTableFetch;
v := @parameter: org.apache.nifi.components.ValidationContext;
v = new java.util.ArrayList;
v = specialinvoke v.<org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor: java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)>(v);
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor COLUMN_FOR_VALUE_PARTITIONING>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: boolean isSet()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: boolean isExpressionLanguagePresent()>();
if v != 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>(",");
if v == 0 goto label;
v = new org.apache.nifi.components.ValidationResult$Builder;
specialinvoke v.<org.apache.nifi.components.ValidationResult$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(0);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor COLUMN_FOR_VALUE_PARTITIONING>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getDisplayName()>();
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[])>("\u requires a single column name, but a comma was detected");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return v;
}
public void setup(org.apache.nifi.processor.ProcessContext)
{
org.apache.nifi.processors.standard.GenerateTableFetch v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.logging.ComponentLog v;
boolean v, v;
v := @this: org.apache.nifi.processors.standard.GenerateTableFetch;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: boolean hasIncomingConnection()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: boolean hasNonLoopConnection()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.logging.ComponentLog getLogger()>();
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String)>("The failure relationship can be used only if there is another incoming connection to this processor.");
label:
return;
}
public void stop()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.nifi.processors.standard.GenerateTableFetch v;
v := @this: org.apache.nifi.processors.standard.GenerateTableFetch;
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: java.util.concurrent.atomic.AtomicBoolean setupComplete>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
return;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSessionFactory) throws org.apache.nifi.processor.exception.ProcessException
{
java.lang.Integer v, v, v, v;
byte v, v, v, v, v;
java.lang.Long v, v, v, v, v, v, v, v, v;
org.apache.nifi.components.state.Scope v, v;
java.util.Map v, v, v, v, v, v;
org.apache.nifi.controller.ControllerService v;
java.lang.Object[] v, v, v, v, v;
long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processors.standard.GenerateTableFetch v;
java.io.IOException v, v;
org.apache.nifi.processor.ProcessSession v;
java.sql.Connection v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.UUID v;
org.apache.nifi.components.state.StateMap v;
java.sql.ResultSetMetaData v;
java.util.stream.IntStream v, v;
java.util.concurrent.atomic.AtomicBoolean v;
int v, v, v, v, v, v, v, v, v;
java.lang.Boolean v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.lang.Object v, v, v, v, v, v, v;
org.apache.nifi.processor.io.OutputStreamCallback v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v;
java.sql.ResultSet v;
java.util.Set v;
java.lang.Exception v;
java.lang.Throwable v, v, v, v, v;
java.util.ArrayList v, v, v, v;
java.sql.SQLException v, v;
java.lang.String 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.sql.Statement v;
java.util.function.IntConsumer v, v;
boolean 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;
org.apache.nifi.flowfile.FlowFile v, v, v, v, v, v, v, v, v;
java.util.List v, v;
java.lang.String[] v;
java.util.HashMap v, v, v, v;
org.apache.nifi.logging.ComponentLog v;
org.apache.nifi.processor.exception.ProcessException v, v, v;
java.util.Iterator v;
org.apache.nifi.processor.ProcessContext v;
java.util.concurrent.TimeUnit v;
v := @this: org.apache.nifi.processors.standard.GenerateTableFetch;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSessionFactory;
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: boolean isDynamicTableName>;
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: boolean isDynamicMaxValues>;
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: java.util.concurrent.atomic.AtomicBoolean setupComplete>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
specialinvoke v.<org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor: void setup(org.apache.nifi.processor.ProcessContext)>(v);
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSessionFactory: org.apache.nifi.processor.ProcessSession createSession()>();
v = null;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: boolean hasIncomingConnection()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if v != null goto label;
return;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.GenerateTableFetch: java.util.Map getDefaultMaxValueProperties(org.apache.nifi.processor.ProcessContext,org.apache.nifi.flowfile.FlowFile)>(v, v);
v.<org.apache.nifi.processors.standard.GenerateTableFetch: java.util.Map maxValueProperties> = v;
v = virtualinvoke v.<org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.logging.ComponentLog getLogger()>();
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor DBCP_SERVICE>;
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/dbcp/DBCPService;");
v = <org.apache.nifi.processors.standard.GenerateTableFetch: java.util.Map dbAdapters>;
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor DB_TYPE>;
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 = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
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(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor COLUMN_NAMES>;
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(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor MAX_VALUE_COLUMN_NAMES>;
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(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor PARTITION_SIZE>;
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(org.apache.nifi.flowfile.FlowFile)>(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.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor COLUMN_FOR_VALUE_PARTITIONING>;
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(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor WHERE_CLAUSE>;
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(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor CUSTOM_ORDERBY_COLUMN>;
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(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor OUTPUT_EMPTY_FLOWFILE_ON_ZERO_RESULTS>;
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.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = v;
label:
v = <org.apache.nifi.components.state.Scope: org.apache.nifi.components.state.Scope CLUSTER>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.components.state.StateMap getState(org.apache.nifi.components.state.Scope)>(v);
label:
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Throwable)>("Failed to retrieve observed maximum values from the State Manager. Will not perform query until this is accomplished.", v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: void yield()>();
return;
label:
v = new java.util.HashMap;
v = interfaceinvoke v.<org.apache.nifi.components.state.StateMap: java.util.Map toMap()>();
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: java.util.Map maxValueProperties>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: 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.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = staticinvoke <org.apache.nifi.processors.standard.GenerateTableFetch: java.lang.String getStateKey(java.lang.String,java.lang.String,org.apache.nifi.processors.standard.db.DatabaseAdapter)>(v, v, v);
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
goto label;
label:
interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = new java.util.ArrayList;
v = v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(0);
goto label;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>("\\s*,\\s*");
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
label:
v = v;
v = interfaceinvoke v.<java.util.List: int size()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = null;
v = null;
v = new java.util.ArrayList;
v = v + 1;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
if v != 0 goto label;
if v != 0 goto label;
label:
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("-1");
goto label;
label:
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("COUNT(*)");
label:
v = staticinvoke <java.util.stream.IntStream: java.util.stream.IntStream range(int,int)>(0, v);
v = staticinvoke <org.apache.nifi.processors.standard.GenerateTableFetch$lambda_onTrigger_0__99: java.util.function.IntConsumer bootstrap$(org.apache.nifi.processors.standard.GenerateTableFetch,java.util.List,java.util.List,java.lang.String,java.util.Map,org.apache.nifi.processors.standard.db.DatabaseAdapter,org.apache.nifi.processor.ProcessContext,org.apache.nifi.flowfile.FlowFile,java.util.List)>(v, v, v, v, v, v, v, v, v);
interfaceinvoke v.<java.util.stream.IntStream: void forEach(java.util.function.IntConsumer)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>(",");
if v == 0 goto label;
v = new org.apache.nifi.processor.exception.ProcessException;
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor COLUMN_FOR_VALUE_PARTITIONING>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getDisplayName()>();
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[])>("\u requires a single column name, but a comma was detected");
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.String)>(v);
throw v;
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("MAX(\u) \u0001");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("MIN(\u) MIN_\u0001");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
if v == null goto 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[])>("(\u)");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String join(java.lang.Iterable,java.lang.String)>(v, " AND ");
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String join(java.lang.Iterable,java.lang.String)>(v, ", ");
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long)>(v, v, v, null, null, null);
label:
if v != null goto label;
v = staticinvoke <java.util.Collections: java.util.Map emptyMap()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.util.Map getAttributes()>();
label:
v = interfaceinvoke v.<org.apache.nifi.dbcp.DBCPService: java.sql.Connection getConnection(java.util.Map)>(v);
label:
v = interfaceinvoke v.<java.sql.Connection: java.sql.Statement createStatement()>();
label:
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor QUERY_TIMEOUT>;
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(org.apache.nifi.flowfile.FlowFile)>(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()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<java.sql.Statement: void setQueryTimeout(int)>(v);
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("Executing {}", v);
v = interfaceinvoke v.<java.sql.Statement: java.sql.ResultSet executeQuery(java.lang.String)>(v);
v = interfaceinvoke v.<java.sql.ResultSet: boolean next()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.sql.ResultSet: long getLong(int)>(1);
v = interfaceinvoke v.<java.sql.ResultSet: java.sql.ResultSetMetaData getMetaData()>();
v = 2;
label:
v = v + 1;
if v > v goto label;
v = interfaceinvoke v.<java.sql.ResultSetMetaData: java.lang.String getColumnLabel(int)>(v);
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isNotEmpty(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<java.sql.ResultSetMetaData: java.lang.String getColumnLabel(int)>(v);
goto label;
label:
v = interfaceinvoke v.<java.sql.ResultSetMetaData: java.lang.String getColumnName(int)>(v);
label:
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = staticinvoke <org.apache.nifi.processors.standard.GenerateTableFetch: java.lang.String getStateKey(java.lang.String,java.lang.String,org.apache.nifi.processors.standard.db.DatabaseAdapter)>(v, v, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: boolean isDynamicTableName>;
if v != 0 goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
label:
v = interfaceinvoke v.<java.sql.ResultSetMetaData: int getColumnType(int)>(v);
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: boolean isDynamicTableName>;
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: java.util.Map columnTypeMap>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getName()>();
v = staticinvoke <org.apache.nifi.processors.standard.GenerateTableFetch: java.lang.String getMaxValueFromRow(java.sql.ResultSet,int,java.lang.Integer,java.lang.String,java.lang.String)>(v, v, v, v, v);
if v == null goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, 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.Throwable)>(v);
throw v;
label:
v = v + 1;
goto label;
label:
if v == 0 goto label;
v = interfaceinvoke v.<java.sql.ResultSet: java.lang.Object getObject(int)>(v);
if v != null goto label;
v = null;
goto label;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(java.lang.String)>(v);
label:
v = v;
v = v + 1;
v = interfaceinvoke v.<java.sql.ResultSet: java.lang.Object getObject(int)>(v);
if v != null goto label;
v = null;
goto label;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(java.lang.String)>(v);
label:
v = v;
goto label;
label:
v = new java.sql.SQLException;
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[])>("No rows returned from metadata query: \u0001");
specialinvoke v.<java.sql.SQLException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <java.util.stream.IntStream: java.util.stream.IntStream range(int,int)>(0, v);
v = staticinvoke <org.apache.nifi.processors.standard.GenerateTableFetch$lambda_onTrigger_1__100: java.util.function.IntConsumer bootstrap$(org.apache.nifi.processors.standard.GenerateTableFetch,java.util.List,java.lang.String,java.util.Map,org.apache.nifi.processors.standard.db.DatabaseAdapter,org.apache.nifi.processor.ProcessContext,org.apache.nifi.flowfile.FlowFile,java.util.List)>(v, v, v, v, v, v, v, v);
interfaceinvoke v.<java.util.stream.IntStream: void forEach(java.util.function.IntConsumer)>(v);
if v == 0 goto label;
if v != null goto label;
v = 0L;
goto label;
label:
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v - v;
v = v + 1L;
label:
if v != 0 goto label;
v = 1L;
goto label;
label:
v = v / v;
v = v % v;
v = v cmp 0L;
if v != 0 goto label;
v = 0;
goto label;
label:
v = 1;
label:
v = v + v;
label:
v = v;
goto label;
label:
if v != 0 goto label;
v = 1L;
goto label;
label:
v = v / v;
v = v % v;
v = v cmp 0L;
if v != 0 goto label;
v = 0;
goto label;
label:
v = 1;
label:
v = v + v;
label:
v = v;
label:
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
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)>("generatetablefetch.tableName", v);
if v == null goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("generatetablefetch.columnNames", v);
label:
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String join(java.lang.Iterable,java.lang.String)>(v, ", ");
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isNotBlank(java.lang.CharSequence)>(v);
if v == 0 goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("generatetablefetch.maxColumnNames", v);
label:
v = <org.apache.nifi.processors.standard.GenerateTableFetch: java.lang.String FRAGMENT_ID>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: java.lang.String FRAGMENT_COUNT>;
v = staticinvoke <java.lang.String: java.lang.String valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v cmp 0L;
if v != 0 goto label;
if v == 0 goto label;
if v != null goto label;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create(org.apache.nifi.flowfile.FlowFile)>(v);
label:
v = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = "1=1";
goto label;
label:
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String join(java.lang.Iterable,java.lang.String)>(v, " AND ");
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("generatetablefetch.whereClause", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("generatetablefetch.limit", null);
if v == 0 goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("generatetablefetch.offset", null);
label:
v = <org.apache.nifi.processors.standard.GenerateTableFetch: java.lang.String FRAGMENT_INDEX>;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(0);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(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.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
if v != 0 goto label;
v = null;
goto label;
label:
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
label:
v = v;
v = 0L;
label:
v = v cmp v;
if v >= 0 goto label;
v = v - 1L;
v = v cmp v;
if v != 0 goto label;
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
if v == null goto label;
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.Long)>(v, 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[])>("\u <= \u0001");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = null;
label:
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = "1=1";
goto label;
label:
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String join(java.lang.Iterable,java.lang.String)>(v, " AND ");
label:
v = v;
if v != 0 goto label;
v = null;
goto label;
label:
v = v * v;
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
goto label;
label:
v = 0L;
label:
v = v + v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
label:
v = v;
if v != 0 goto label;
v = null;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = v;
goto label;
label:
v = v;
label:
v = interfaceinvoke v.<org.apache.nifi.processors.standard.db.DatabaseAdapter: java.lang.String getSelectStatement(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Long,java.lang.Long,java.lang.String)>(v, v, v, v, v, v, v);
if v != null goto label;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create(org.apache.nifi.flowfile.FlowFile)>(v);
label:
v = staticinvoke <org.apache.nifi.processors.standard.GenerateTableFetch$lambda_onTrigger_2__101: org.apache.nifi.processor.io.OutputStreamCallback bootstrap$(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile write(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.OutputStreamCallback)>(v, v);
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)>("generatetablefetch.whereClause", v);
if v != null goto label;
v = null;
goto label;
label:
v = virtualinvoke v.<java.lang.Long: java.lang.String toString()>();
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("generatetablefetch.limit", v);
if v == 0 goto label;
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("generatetablefetch.offset", v);
label:
v = <org.apache.nifi.processors.standard.GenerateTableFetch: java.lang.String FRAGMENT_INDEX>;
v = staticinvoke <java.lang.String: java.lang.String valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(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.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1L;
goto label;
label:
v = <org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
if v == null goto label;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void remove(org.apache.nifi.flowfile.FlowFile)>(v);
label:
interfaceinvoke v.<java.sql.Statement: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
interfaceinvoke v.<java.sql.Connection: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
if v == null goto label;
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[])>("Unable to execute SQL select query {}, routing {} to failure", v);
v = virtualinvoke v.<java.sql.SQLException: java.lang.String getMessage()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "generatetablefetch.sql.error", v);
v = <org.apache.nifi.processors.standard.GenerateTableFetch: 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:
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[])>("Unable to execute SQL select query {}", v);
v = new org.apache.nifi.processor.exception.ProcessException;
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = <org.apache.nifi.components.state.Scope: org.apache.nifi.components.state.Scope CLUSTER>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void setState(java.util.Map,org.apache.nifi.components.state.Scope)>(v, v);
label:
goto label;
label:
v := @caughtexception;
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 update State Manager, observed maximum values will not be recorded. Also, any generated SQL statements may be duplicated.", v);
label:
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync()>();
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processor.exception.ProcessException: java.lang.Throwable getCause()>();
if v != null goto label;
v = v;
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.processor.exception.ProcessException: java.lang.Throwable getCause()>();
label:
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Error during processing: {}", v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void rollback()>();
interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: void yield()>();
label:
return;
catch java.io.IOException from label to label with label;
catch java.text.ParseException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.ClassCastException 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.sql.SQLException from label to label with label;
catch java.io.IOException from label to label with label;
catch org.apache.nifi.processor.exception.ProcessException from label to label with label;
}
private java.lang.String getColumnStateMaxValue(java.lang.String, java.util.Map, java.lang.String, org.apache.nifi.processors.standard.db.DatabaseAdapter)
{
org.apache.nifi.processors.standard.db.DatabaseAdapter v;
java.util.Map v;
org.apache.nifi.processors.standard.GenerateTableFetch v;
java.lang.Object v;
java.lang.String v, v, v, v;
boolean v, v;
v := @this: org.apache.nifi.processors.standard.GenerateTableFetch;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.processors.standard.db.DatabaseAdapter;
v = staticinvoke <org.apache.nifi.processors.standard.GenerateTableFetch: java.lang.String getStateKey(java.lang.String,java.lang.String,org.apache.nifi.processors.standard.db.DatabaseAdapter)>(v, v, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: boolean isDynamicTableName>;
if v != 0 goto label;
v = staticinvoke <org.apache.nifi.processors.standard.GenerateTableFetch: java.lang.String getStateKey(java.lang.String,java.lang.String,org.apache.nifi.processors.standard.db.DatabaseAdapter)>(null, v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
label:
return v;
}
private java.lang.Integer getColumnType(java.lang.String, java.lang.String, org.apache.nifi.processors.standard.db.DatabaseAdapter)
{
org.apache.nifi.processors.standard.db.DatabaseAdapter v;
java.util.Map v, v;
org.apache.nifi.processors.standard.GenerateTableFetch v;
java.lang.Object v;
java.lang.String v, v, v, v;
boolean v;
v := @this: org.apache.nifi.processors.standard.GenerateTableFetch;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.processors.standard.db.DatabaseAdapter;
v = staticinvoke <org.apache.nifi.processors.standard.GenerateTableFetch: java.lang.String getStateKey(java.lang.String,java.lang.String,org.apache.nifi.processors.standard.db.DatabaseAdapter)>(v, v, v);
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: java.util.Map columnTypeMap>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: boolean isDynamicTableName>;
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.GenerateTableFetch: java.util.Map columnTypeMap>;
v = staticinvoke <org.apache.nifi.processors.standard.GenerateTableFetch: java.lang.String getStateKey(java.lang.String,java.lang.String,org.apache.nifi.processors.standard.db.DatabaseAdapter)>(null, v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
label:
return v;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, 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;
org.apache.nifi.expression.ExpressionLanguageScope v, v, v;
java.lang.String[] v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.components.Validator v, v, v, v;
org.apache.nifi.processor.Relationship$Builder v, v, 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)>("gen-table-fetch-partition-size");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Partition Size");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The number of result rows to be fetched by each generated SQL statement. The total number of rows in the table divided by the partition size gives the number of SQL statements (i.e. FlowFiles) generated. A value of zero indicates that a single FlowFile is to be generated whose SQL statement will fetch all rows in the table.");
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$Builder required(boolean)>(1);
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.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_INTEGER_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 build()>();
<org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor PARTITION_SIZE> = 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)>("gen-table-column-for-val-partitioning");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Column for Value Partitioning");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The name of a column whose values will be used for partitioning. The default behavior is to use row numbers on the result set for partitioning into \'pages\' to be fetched from the database, using an offset/limit strategy. However for certain databases, it can be more efficient under the right circumstances to use the column values themselves to define the \'pages\'. This property should only be used when the default queries are not performing well, when there is no maximum-value column or a single maximum-value column whose type can be coerced to a long integer (i.e. not date or timestamp), and the column values are evenly distributed and not sparse, for best performance.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
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.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 = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor COLUMN_FOR_VALUE_PARTITIONING> = 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)>("gen-table-output-flowfile-on-zero-results");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Output Empty FlowFile on Zero Results");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Depending on the specified properties, an execution of this processor may not result in any SQL statements generated. When this property is true, an empty FlowFile will be generated (having the parent of the incoming FlowFile if present) and transferred to the \'success\' relationship. When this property is false, no output FlowFiles will be generated.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("false");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator BOOLEAN_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 build()>();
<org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor OUTPUT_EMPTY_FLOWFILE_ON_ZERO_RESULTS> = 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)>("gen-table-custom-orderby-column");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Custom ORDER BY Column");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The name of a column to be used for ordering the results if Max-Value Columns are not provided and partitioning is enabled. This property is ignored if either Max-Value Columns is set or Partition Size = 0. NOTE: If neither Max-Value Columns nor Custom ORDER BY Column is set, then depending on the the database/driver, the processor may report an error and/or the generated SQL may result in missing and/or duplicate rows. This is because without an explicit ordering, fetching each partition is done using an arbitrary ordering.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
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.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 = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.components.PropertyDescriptor CUSTOM_ORDERBY_COLUMN> = 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)>("This relationship is only used when SQL query execution (using an incoming FlowFile) failed. The incoming FlowFile will be penalized and routed to this relationship. If no incoming connection(s) are specified, this relationship is unused.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.GenerateTableFetch: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
return;
}
}