public abstract class org.apache.nifi.processors.standard.AbstractQueryDatabaseTable extends org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor
{
public static final java.lang.String RESULT_TABLENAME;
public static final java.lang.String RESULT_ROW_COUNT;
private static org.apache.nifi.components.AllowableValue TRANSACTION_READ_COMMITTED;
private static org.apache.nifi.components.AllowableValue TRANSACTION_READ_UNCOMMITTED;
private static org.apache.nifi.components.AllowableValue TRANSACTION_REPEATABLE_READ;
private static org.apache.nifi.components.AllowableValue TRANSACTION_NONE;
private static org.apache.nifi.components.AllowableValue TRANSACTION_SERIALIZABLE;
public static final org.apache.nifi.components.PropertyDescriptor FETCH_SIZE;
public static final org.apache.nifi.components.PropertyDescriptor MAX_ROWS_PER_FLOW_FILE;
public static final org.apache.nifi.components.PropertyDescriptor OUTPUT_BATCH_SIZE;
public static final org.apache.nifi.components.PropertyDescriptor MAX_FRAGMENTS;
public static final org.apache.nifi.components.PropertyDescriptor TRANS_ISOLATION_LEVEL;
public static final org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_ALL_ROWS;
public static final org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_NEW_ROWS;
public static final org.apache.nifi.components.PropertyDescriptor INITIAL_LOAD_STRATEGY;
public void <init>()
{
org.apache.nifi.processors.standard.AbstractQueryDatabaseTable v;
v := @this: org.apache.nifi.processors.standard.AbstractQueryDatabaseTable;
specialinvoke v.<org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor: void <init>()>();
return;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.AbstractQueryDatabaseTable v;
v := @this: org.apache.nifi.processors.standard.AbstractQueryDatabaseTable;
v = v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: java.util.Set relationships>;
return v;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.AbstractQueryDatabaseTable v;
v := @this: org.apache.nifi.processors.standard.AbstractQueryDatabaseTable;
v = v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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.processors.standard.AbstractQueryDatabaseTable 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;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.AbstractQueryDatabaseTable;
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 VARIABLE_REGISTRY>;
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)
{
java.lang.Object[] v;
org.apache.nifi.components.ValidationContext v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
java.util.ArrayList v;
org.apache.nifi.components.PropertyValue v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.nifi.components.ValidationResult v;
boolean v, v;
org.apache.nifi.components.ValidationResult$Builder v, v, v, v, v;
java.util.Collection v;
org.apache.nifi.processors.standard.AbstractQueryDatabaseTable v;
org.apache.nifi.components.AllowableValue v, v, v;
v := @this: org.apache.nifi.processors.standard.AbstractQueryDatabaseTable;
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.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor MAX_VALUE_COLUMN_NAMES>;
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()>();
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor INITIAL_LOAD_STRATEGY>;
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: java.lang.String getValue()>();
if v != 0 goto label;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_NEW_ROWS>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
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.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor INITIAL_LOAD_STRATEGY>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getDisplayName()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder subject(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_NEW_ROWS>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getDisplayName()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder input(java.lang.String)>(v);
v = newarray (java.lang.Object)[2];
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_NEW_ROWS>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getDisplayName()>();
v[0] = v;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor MAX_VALUE_COLUMN_NAMES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getDisplayName()>();
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("\'%s\' strategy can only be used when \'%s\' property is also configured", v);
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.processor.ProcessContext v;
org.apache.nifi.processors.standard.AbstractQueryDatabaseTable v;
java.util.Map v;
v := @this: org.apache.nifi.processors.standard.AbstractQueryDatabaseTable;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: java.util.Map getDefaultMaxValueProperties(org.apache.nifi.processor.ProcessContext,org.apache.nifi.flowfile.FlowFile)>(v, null);
v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: java.util.Map maxValueProperties> = v;
return;
}
public void stop()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.nifi.processors.standard.AbstractQueryDatabaseTable v;
v := @this: org.apache.nifi.processors.standard.AbstractQueryDatabaseTable;
v = v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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, v, v, v, v;
byte v, v;
java.lang.Long v, v;
org.apache.nifi.components.state.Scope v, v, v, v;
java.util.Map v, v, v, v, v, v;
java.util.stream.Collector v;
org.apache.nifi.components.AllowableValue v;
java.util.stream.Stream v, v;
org.apache.nifi.controller.ControllerService v;
org.apache.nifi.util.StopWatch v;
java.lang.Object[] v, v, v, v, v, v, v, v;
java.sql.DatabaseMetaData v;
long v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v;
java.io.IOException v, v, v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processors.standard.AbstractQueryDatabaseTable v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.nifi.processors.standard.AbstractQueryDatabaseTable$MaxValueResultSetRowCollector v, v;
java.sql.Connection v, 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, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.sql.SqlWriter v;
java.util.UUID v;
org.apache.nifi.components.state.StateMap v;
java.util.concurrent.atomic.AtomicBoolean v;
java.util.function.Function v;
int 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.processor.ProcessSessionFactory v;
java.lang.Object v, v, v, 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, v, v, v, v;
java.sql.ResultSet v, v;
java.util.Set v, v;
java.lang.Exception v;
java.lang.Throwable v, v, v, v, v, v, v, v, v;
java.util.ArrayList v;
java.sql.SQLException v, v, v;
org.apache.nifi.provenance.ProvenanceReporter 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;
java.sql.Statement v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v, v, v, v, v;
java.util.List v, v;
java.lang.String[] v;
java.util.HashMap v, v;
org.apache.nifi.logging.ComponentLog v, v, v, v, v;
java.util.Iterator v, v;
org.apache.nifi.processor.ProcessContext v;
java.util.concurrent.TimeUnit v, v;
v := @this: org.apache.nifi.processors.standard.AbstractQueryDatabaseTable;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSessionFactory;
v = v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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 = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.logging.ComponentLog getLogger()>();
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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.AbstractQueryDatabaseTable: java.util.Map dbAdapters>;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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.AbstractQueryDatabaseTable: 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()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor SQL_QUERY>;
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()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor INITIAL_LOAD_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.AbstractQueryDatabaseTable: 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()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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()>();
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 = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor FETCH_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()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor MAX_ROWS_PER_FLOW_FILE>;
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()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor OUTPUT_BATCH_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()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
if v != null goto label;
v = 0;
goto label;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
label:
v = v;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor MAX_FRAGMENTS>;
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: boolean isSet()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor MAX_FRAGMENTS>;
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()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
goto label;
label:
v = 0;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor TRANS_ISOLATION_LEVEL>;
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: boolean isSet()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor TRANS_ISOLATION_LEVEL>;
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.Integer asInteger()>();
goto label;
label:
v = null;
label:
v = v;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.processors.standard.sql.SqlWriter configureSqlWriter(org.apache.nifi.processor.ProcessSession,org.apache.nifi.processor.ProcessContext)>(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;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.logging.ComponentLog getLogger()>();
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.AbstractQueryDatabaseTable: 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.AbstractQueryDatabaseTable: 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 = null;
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;
if v == null goto label;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_NEW_ROWS>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable$lambda_onTrigger_0__12: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector joining(java.lang.CharSequence)>(", ");
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(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, null, null, null, null);
label:
v = staticinvoke <java.util.Collections: java.util.Map emptyMap()>();
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:
if v == null goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<java.sql.Connection: void setTransactionIsolation(int)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<java.sql.Statement: void setQueryTimeout(int)>(v);
v = interfaceinvoke v.<java.sql.Statement: java.sql.ResultSet executeQuery(java.lang.String)>(v);
label:
v = interfaceinvoke v.<java.sql.ResultSet: boolean next()>();
if v == 0 goto label;
v = new org.apache.nifi.processors.standard.AbstractQueryDatabaseTable$MaxValueResultSetRowCollector;
specialinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable$MaxValueResultSetRowCollector: void <init>(org.apache.nifi.processors.standard.AbstractQueryDatabaseTable,java.lang.String,java.util.Map,org.apache.nifi.processors.standard.db.DatabaseAdapter)>(v, v, v, v);
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable$MaxValueResultSetRowCollector: void processRow(java.sql.ResultSet)>(v);
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable$MaxValueResultSetRowCollector: void applyStateChanges()>();
label:
interfaceinvoke v.<java.sql.ResultSet: void close()>();
goto label;
label:
v := @caughtexception;
throw 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;
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 {} due to {}", v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: void yield()>();
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: java.lang.String getQuery(org.apache.nifi.processors.standard.db.DatabaseAdapter,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.util.Map)>(v, v, v, v, v, v, v);
v = new org.apache.nifi.util.StopWatch;
specialinvoke v.<org.apache.nifi.util.StopWatch: void <init>(boolean)>(1);
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
label:
v = staticinvoke <java.util.Collections: java.util.Map emptyMap()>();
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:
if v == null goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v <= 0 goto label;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<java.sql.Statement: void setFetchSize(int)>(v);
label:
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v[0] = v;
v = virtualinvoke v.<java.sql.SQLException: java.lang.String getLocalizedMessage()>();
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[],java.lang.Throwable)>("Cannot set fetch size to {} due to {}", v, v);
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<java.sql.Connection: void setTransactionIsolation(int)>(v);
label:
v = "DBCPService";
label:
v = interfaceinvoke v.<java.sql.Connection: java.sql.DatabaseMetaData getMetaData()>();
if v == null goto label;
v = interfaceinvoke v.<java.sql.DatabaseMetaData: java.lang.String getURL()>();
label:
goto label;
label:
v := @caughtexception;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<java.sql.Statement: void setQueryTimeout(int)>(v);
v = interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: boolean isDebugEnabled()>();
if v == 0 goto label;
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 query {}", v);
label:
v = interfaceinvoke v.<java.sql.Statement: java.sql.ResultSet executeQuery(java.lang.String)>(v);
label:
v = 0;
v = new org.apache.nifi.processors.standard.AbstractQueryDatabaseTable$MaxValueResultSetRowCollector;
specialinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable$MaxValueResultSetRowCollector: void <init>(org.apache.nifi.processors.standard.AbstractQueryDatabaseTable,java.lang.String,java.util.Map,org.apache.nifi.processors.standard.db.DatabaseAdapter)>(v, v, v, v);
label:
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create()>();
label:
v = staticinvoke <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable$lambda_onTrigger_1__11: org.apache.nifi.processor.io.OutputStreamCallback bootstrap$(org.apache.nifi.processors.standard.AbstractQueryDatabaseTable,java.util.concurrent.atomic.AtomicLong,org.apache.nifi.processors.standard.sql.SqlWriter,java.sql.ResultSet,org.apache.nifi.processors.standard.AbstractQueryDatabaseTable$MaxValueResultSetRowCollector)>(v, v, v, v, 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);
label:
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
throw v;
label:
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v cmp 0L;
if v <= 0 goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
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)>("querydbtable.row.count", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("tablename", v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v <= 0 goto label;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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.AbstractQueryDatabaseTable: java.lang.String FRAGMENT_INDEX>;
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)>(v, v);
label:
v = interfaceinvoke v.<org.apache.nifi.processors.standard.sql.SqlWriter: java.util.Map getAttributesToAdd()>();
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.<org.apache.nifi.processors.standard.sql.SqlWriter: void updateCounters(org.apache.nifi.processor.ProcessSession)>(v);
v = newarray (java.lang.Object)[2];
v[0] = v;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("{} contains {} records; transferring to \'success\'", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<org.apache.nifi.util.StopWatch: long getElapsed(java.util.concurrent.TimeUnit)>(v);
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void receive(org.apache.nifi.flowfile.FlowFile,java.lang.String,long)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
if v <= 0 goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
if v < v goto label;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync()>();
interfaceinvoke v.<java.util.List: void clear()>();
goto label;
label:
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void remove(org.apache.nifi.flowfile.FlowFile)>(v);
if v != 0 goto label;
interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: void yield()>();
goto label;
label:
v = v + 1;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v <= 0 goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= v goto label;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v != 0 goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v == 0 goto label;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v <= 0 goto label;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v cmp v;
if v >= 0 goto label;
label:
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable$MaxValueResultSetRowCollector: void applyStateChanges()>();
if v != 0 goto label;
v = 0;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
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: int lastIndexOf(java.lang.String)>("@!@");
v = "@!@";
v = virtualinvoke v.<java.lang.String: int length()>();
v = v + v;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
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[])>("maxvalue.\u0001");
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
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, v, v);
interfaceinvoke v.<java.util.List: java.lang.Object set(int,java.lang.Object)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v <= 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: java.lang.String FRAGMENT_COUNT>;
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
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, v, v);
interfaceinvoke v.<java.util.List: java.lang.Object set(int,java.lang.Object)>(v, v);
label:
v = v + 1;
goto label;
label:
if v == null goto label;
interfaceinvoke v.<java.sql.ResultSet: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
throw v;
label:
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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);
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 = <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 = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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 update State Manager, maximum observed values will not be recorded", v);
label:
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync()>();
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[])>("Unable to execute SQL select query {} due to {}", v);
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void remove(java.util.Collection)>(v);
label:
interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: void yield()>();
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 = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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 update State Manager, maximum observed values will not be recorded", v);
label:
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync()>();
goto label;
label:
v := @caughtexception;
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 = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: 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 update State Manager, maximum observed values will not be recorded", v);
label:
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync()>();
throw v;
label:
return;
catch java.io.IOException 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;
catch java.sql.SQLException from label to label with label;
catch java.sql.SQLException from label to label with label;
catch org.apache.nifi.processor.exception.ProcessException 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.lang.Throwable from label to label with label;
catch java.lang.Throwable 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;
catch java.sql.SQLException from label to label with label;
catch java.io.IOException 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.io.IOException from label to label with label;
}
protected java.lang.String getQuery(org.apache.nifi.processors.standard.db.DatabaseAdapter, java.lang.String, java.lang.String, java.util.List, java.lang.String, java.util.Map)
{
org.apache.nifi.processors.standard.db.DatabaseAdapter v;
org.apache.nifi.processors.standard.AbstractQueryDatabaseTable v;
java.util.List v;
java.util.Map v;
java.lang.String v, v, v, v;
v := @this: org.apache.nifi.processors.standard.AbstractQueryDatabaseTable;
v := @parameter: org.apache.nifi.processors.standard.db.DatabaseAdapter;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: java.lang.String getQuery(org.apache.nifi.processors.standard.db.DatabaseAdapter,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.util.Map)>(v, v, null, v, v, v, v);
return v;
}
protected java.lang.String getQuery(org.apache.nifi.processors.standard.db.DatabaseAdapter, java.lang.String, java.lang.String, java.lang.String, java.util.List, java.lang.String, java.util.Map)
{
java.util.stream.IntStream v;
java.util.function.IntConsumer v;
java.util.ArrayList v;
java.util.Map v;
int v;
java.lang.String v, v, v, v, v, v, v, v;
boolean v, v, v, v;
org.apache.nifi.processors.standard.db.DatabaseAdapter v;
org.apache.nifi.processors.standard.AbstractQueryDatabaseTable v;
java.lang.IllegalArgumentException v;
java.util.List v;
java.lang.StringBuilder v, v;
v := @this: org.apache.nifi.processors.standard.AbstractQueryDatabaseTable;
v := @parameter: org.apache.nifi.processors.standard.db.DatabaseAdapter;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Table name must be specified");
throw v;
label:
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = new java.lang.StringBuilder;
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, null, null, null, null);
specialinvoke v.<java.lang.StringBuilder: void <init>(java.lang.String)>(v);
v = v;
goto label;
label:
v = staticinvoke <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: java.lang.StringBuilder getWrappedQuery(org.apache.nifi.processors.standard.db.DatabaseAdapter,java.lang.String,java.lang.String)>(v, v, v);
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v != 0 goto label;
if v == null goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
v = staticinvoke <java.util.stream.IntStream: java.util.stream.IntStream range(int,int)>(0, v);
v = staticinvoke <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable$lambda_getQuery_2__13: java.util.function.IntConsumer bootstrap$(org.apache.nifi.processors.standard.AbstractQueryDatabaseTable,java.util.List,java.lang.String,org.apache.nifi.processors.standard.db.DatabaseAdapter,java.util.Map,java.util.List)>(v, v, v, v, v, v);
interfaceinvoke v.<java.util.stream.IntStream: void forEach(java.util.function.IntConsumer)>(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 = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" WHERE ");
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String join(java.lang.Iterable,java.lang.String)>(v, " AND ");
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
protected abstract org.apache.nifi.processors.standard.sql.SqlWriter configureSqlWriter(org.apache.nifi.processor.ProcessSession, org.apache.nifi.processor.ProcessContext);
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v;
org.apache.nifi.components.AllowableValue v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, 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, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.expression.ExpressionLanguageScope v, v, v, v;
org.apache.nifi.components.AllowableValue[] v, v;
org.apache.nifi.components.Validator v, v, v, v;
v = new org.apache.nifi.components.AllowableValue;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(2);
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String)>(v, "TRANSACTION_READ_COMMITTED");
<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue TRANSACTION_READ_COMMITTED> = v;
v = new org.apache.nifi.components.AllowableValue;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(1);
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String)>(v, "TRANSACTION_READ_UNCOMMITTED");
<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue TRANSACTION_READ_UNCOMMITTED> = v;
v = new org.apache.nifi.components.AllowableValue;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(4);
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String)>(v, "TRANSACTION_REPEATABLE_READ");
<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue TRANSACTION_REPEATABLE_READ> = v;
v = new org.apache.nifi.components.AllowableValue;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(0);
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String)>(v, "TRANSACTION_NONE");
<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue TRANSACTION_NONE> = v;
v = new org.apache.nifi.components.AllowableValue;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(8);
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String)>(v, "TRANSACTION_SERIALIZABLE");
<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue TRANSACTION_SERIALIZABLE> = 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)>("Fetch 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 from the result set at a time. This is a hint to the database driver and may not be honored and/or exact. If the value specified is zero, then the hint is ignored.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("0");
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_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 = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope VARIABLE_REGISTRY>;
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 build()>();
<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor FETCH_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)>("qdbt-max-rows");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Max Rows Per Flow File");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The maximum number of result rows that will be included in a single FlowFile. This will allow you to break up very large result sets into multiple FlowFiles. If the value specified is zero, then all rows are returned in a single FlowFile.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("0");
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_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 = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope VARIABLE_REGISTRY>;
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 build()>();
<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor MAX_ROWS_PER_FLOW_FILE> = 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)>("qdbt-output-batch-size");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Output Batch Size");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The number of output FlowFiles to queue before committing the process session. When set to zero, the session will be committed when all result set rows have been processed and the output FlowFiles are ready for transfer to the downstream relationship. For large result sets, this can cause a large burst of FlowFiles to be transferred at the end of processor execution. If this property is set, then when the specified number of FlowFiles are ready for transfer, then the session will be committed, thus releasing the FlowFiles to the downstream relationship. NOTE: The maxvalue.* and fragment.count attributes will not be set on FlowFiles when this property is set.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("0");
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_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 = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope VARIABLE_REGISTRY>;
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 build()>();
<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor OUTPUT_BATCH_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)>("qdbt-max-frags");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Maximum Number of Fragments");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The maximum number of fragments. If the value specified is zero, then all fragments are returned. This prevents OutOfMemoryError when this processor ingests huge table. NOTE: Setting this property can result in data loss, as the incoming results are not ordered, and fragments may end at arbitrary boundaries where rows are not included in the result set.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("0");
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_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 = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope VARIABLE_REGISTRY>;
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 build()>();
<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor MAX_FRAGMENTS> = 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)>("transaction-isolation-level");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Transaction Isolation Level");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("This setting will set the transaction isolation level for the database connection for drivers that support this setting");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = newarray (org.apache.nifi.components.AllowableValue)[5];
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue TRANSACTION_NONE>;
v[0] = v;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue TRANSACTION_READ_COMMITTED>;
v[1] = v;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue TRANSACTION_READ_UNCOMMITTED>;
v[2] = v;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue TRANSACTION_REPEATABLE_READ>;
v[3] = v;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue TRANSACTION_SERIALIZABLE>;
v[4] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(org.apache.nifi.components.AllowableValue[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor TRANS_ISOLATION_LEVEL> = 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)>("Start at Beginning", "Start at Beginning", "Loads all existing rows from the database table.");
<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_ALL_ROWS> = v;
v = new org.apache.nifi.components.AllowableValue;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor MAX_VALUE_COLUMN_NAMES>;
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[])>("Loads only the newly inserted or updated rows based on the maximum value(s) of the column(s) configured in the \'\u0001\' property.");
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String,java.lang.String)>("Start at Current Maximum Values", "Start at Current Maximum Values", v);
<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_NEW_ROWS> = 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)>("initial-load-strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Initial Load Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("How to handle existing rows in the database table when the processor is started for the first time (or its state has been cleared). The property will be ignored, if any \'initial.maxvalue.*\' dynamic property has also been configured.");
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)[2];
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_ALL_ROWS>;
v[0] = v;
v = <org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_NEW_ROWS>;
v[1] = 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.AbstractQueryDatabaseTable: org.apache.nifi.components.AllowableValue INITIAL_LOAD_STRATEGY_ALL_ROWS>;
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.AbstractQueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor INITIAL_LOAD_STRATEGY> = v;
return;
}
}