public class org.apache.nifi.processors.standard.QueryDatabaseTable extends org.apache.nifi.processors.standard.AbstractQueryDatabaseTable
{
public void <init>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.ArrayList v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v;
java.util.HashSet v;
org.apache.nifi.processors.standard.QueryDatabaseTable v;
org.apache.nifi.processor.Relationship v;
java.util.Set v;
java.util.List v;
v := @this: org.apache.nifi.processors.standard.QueryDatabaseTable;
specialinvoke v.<org.apache.nifi.processors.standard.AbstractQueryDatabaseTable: void <init>()>();
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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.QueryDatabaseTable: java.util.Set relationships> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor DBCP_SERVICE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor DB_TYPE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor TABLE_NAME>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder fromPropertyDescriptor(org.apache.nifi.components.PropertyDescriptor)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The name of the database table to be queried. When a custom query is used, this property is used to alias the query and appears as an attribute on the FlowFile.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor COLUMN_NAMES>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor WHERE_CLAUSE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor SQL_QUERY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: 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.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor INITIAL_LOAD_STRATEGY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor QUERY_TIMEOUT>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor FETCH_SIZE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor MAX_ROWS_PER_FLOW_FILE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor OUTPUT_BATCH_SIZE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor MAX_FRAGMENTS>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor NORMALIZE_NAMES_FOR_AVRO>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: org.apache.nifi.components.PropertyDescriptor TRANS_ISOLATION_LEVEL>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor USE_AVRO_LOGICAL_TYPES>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor VARIABLE_REGISTRY_ONLY_DEFAULT_PRECISION>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor VARIABLE_REGISTRY_ONLY_DEFAULT_SCALE>;
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.QueryDatabaseTable: java.util.List propDescriptors> = v;
return;
}
protected org.apache.nifi.processors.standard.sql.SqlWriter configureSqlWriter(org.apache.nifi.processor.ProcessSession, org.apache.nifi.processor.ProcessContext)
{
org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder v, v, v, v, v, v, v;
java.lang.Integer v, v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v;
boolean v, v;
org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions v;
org.apache.nifi.processors.standard.QueryDatabaseTable v;
int v, v, v;
java.lang.Boolean v, v;
java.lang.String v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processors.standard.sql.DefaultAvroSqlWriter v;
v := @this: org.apache.nifi.processors.standard.QueryDatabaseTable;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = <org.apache.nifi.processors.standard.QueryDatabaseTable: 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.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor NORMALIZE_NAMES_FOR_AVRO>;
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 = <org.apache.nifi.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor USE_AVRO_LOGICAL_TYPES>;
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 = <org.apache.nifi.processors.standard.QueryDatabaseTable: 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.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor VARIABLE_REGISTRY_ONLY_DEFAULT_PRECISION>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = <org.apache.nifi.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor VARIABLE_REGISTRY_ONLY_DEFAULT_SCALE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions()>();
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = staticinvoke <org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions: org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder builder()>();
v = virtualinvoke v.<org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder: org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder recordName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder: org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder convertNames(boolean)>(v);
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = virtualinvoke v.<org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder: org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder useLogicalTypes(boolean)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder: org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder defaultPrecision(int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder: org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder defaultScale(int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder: org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder maxRows(int)>(v);
v = virtualinvoke v.<org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions$Builder: org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions build()>();
v = new org.apache.nifi.processors.standard.sql.DefaultAvroSqlWriter;
specialinvoke v.<org.apache.nifi.processors.standard.sql.DefaultAvroSqlWriter: void <init>(org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions)>(v);
return v;
}
}