public class org.apache.nifi.processors.standard.ExecuteSQL extends org.apache.nifi.processors.standard.AbstractExecuteSQL
{
public static final org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT;
public void <init>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, 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;
java.util.Set v;
java.util.List v;
org.apache.nifi.processors.standard.ExecuteSQL v;
v := @this: org.apache.nifi.processors.standard.ExecuteSQL;
specialinvoke v.<org.apache.nifi.processors.standard.AbstractExecuteSQL: void <init>()>();
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.ExecuteSQL: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteSQL: 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.ExecuteSQL: java.util.Set relationships> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.ExecuteSQL: org.apache.nifi.components.PropertyDescriptor DBCP_SERVICE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteSQL: org.apache.nifi.components.PropertyDescriptor SQL_PRE_QUERY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteSQL: org.apache.nifi.components.PropertyDescriptor SQL_SELECT_QUERY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteSQL: org.apache.nifi.components.PropertyDescriptor SQL_POST_QUERY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteSQL: org.apache.nifi.components.PropertyDescriptor QUERY_TIMEOUT>;
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.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.processors.standard.ExecuteSQL: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor 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 DEFAULT_SCALE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteSQL: 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.ExecuteSQL: 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.ExecuteSQL: org.apache.nifi.components.PropertyDescriptor FETCH_SIZE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ExecuteSQL: org.apache.nifi.components.PropertyDescriptor AUTO_COMMIT>;
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.ExecuteSQL: 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.flowfile.FlowFile)
{
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;
boolean v, v;
org.apache.nifi.util.db.JdbcCommon$AvroConversionOptions v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.standard.ExecuteSQL 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.ExecuteSQL;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
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.ExecuteSQL: 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(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = <org.apache.nifi.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor DEFAULT_PRECISION>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = <org.apache.nifi.util.db.JdbcProperties: org.apache.nifi.components.PropertyDescriptor DEFAULT_SCALE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = <org.apache.nifi.processors.standard.ExecuteSQL: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT>;
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 = 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 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$Builder codecFactory(java.lang.String)>(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;
}
protected org.apache.nifi.components.PropertyDescriptor getSupportedDynamicPropertyDescriptor(java.lang.String)
{
org.apache.nifi.components.Validator v, v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v;
org.apache.nifi.processors.standard.ExecuteSQL v;
org.apache.nifi.expression.AttributeExpression$ResultType v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.ExecuteSQL;
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 = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dynamic(boolean)>(1);
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 = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
return v;
}
static void <clinit>()
{
org.apache.nifi.expression.ExpressionLanguageScope v;
org.apache.nifi.util.db.AvroUtil$CodecType[] v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v;
org.apache.nifi.util.db.AvroUtil$CodecType v;
java.lang.String 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)>("compression-format");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Compression Format");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Compression type to use when writing Avro files. Default is None.");
v = staticinvoke <org.apache.nifi.util.db.AvroUtil$CodecType: org.apache.nifi.util.db.AvroUtil$CodecType[] values()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.Enum[])>(v);
v = <org.apache.nifi.util.db.AvroUtil$CodecType: org.apache.nifi.util.db.AvroUtil$CodecType NONE>;
v = virtualinvoke v.<org.apache.nifi.util.db.AvroUtil$CodecType: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope NONE>;
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 required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ExecuteSQL: org.apache.nifi.components.PropertyDescriptor COMPRESSION_FORMAT> = v;
return;
}
}