Package org.apache.flink.fnexecution.v1
Class FlinkFnApi.UserDefinedAggregateFunctions.Builder
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite.Builder
-
- com.google.protobuf.AbstractMessage.Builder<BuilderT>
-
- com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
- org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions.Builder
-
- All Implemented Interfaces:
com.google.protobuf.Message.Builder
,com.google.protobuf.MessageLite.Builder
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Cloneable
,FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Enclosing class:
- FlinkFnApi.UserDefinedAggregateFunctions
public static final class FlinkFnApi.UserDefinedAggregateFunctions.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder> implements FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
A list of the user-defined aggregate functions to be executed in a group aggregate operation.
Protobuf typeorg.apache.flink.fn_execution.v1.UserDefinedAggregateFunctions
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description FlinkFnApi.UserDefinedAggregateFunctions.Builder
addAllGrouping(Iterable<? extends Integer> values)
The array of the key indexes.FlinkFnApi.UserDefinedAggregateFunctions.Builder
addAllJobParameters(Iterable<? extends FlinkFnApi.JobParameter> values)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
addAllUdfs(Iterable<? extends FlinkFnApi.UserDefinedAggregateFunction> values)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
addGrouping(int value)
The array of the key indexes.FlinkFnApi.UserDefinedAggregateFunctions.Builder
addJobParameters(int index, FlinkFnApi.JobParameter value)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
addJobParameters(int index, FlinkFnApi.JobParameter.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
addJobParameters(FlinkFnApi.JobParameter value)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
addJobParameters(FlinkFnApi.JobParameter.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.JobParameter.Builder
addJobParametersBuilder()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.JobParameter.Builder
addJobParametersBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
FlinkFnApi.UserDefinedAggregateFunctions.Builder
addUdfs(int index, FlinkFnApi.UserDefinedAggregateFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
addUdfs(int index, FlinkFnApi.UserDefinedAggregateFunction.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
addUdfs(FlinkFnApi.UserDefinedAggregateFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
addUdfs(FlinkFnApi.UserDefinedAggregateFunction.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunction.Builder
addUdfsBuilder()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunction.Builder
addUdfsBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunctions
build()
FlinkFnApi.UserDefinedAggregateFunctions
buildPartial()
FlinkFnApi.UserDefinedAggregateFunctions.Builder
clear()
FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearCountStarInserted()
True if the count(*) agg is inserted by the planner.FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearGenerateUpdateBefore()
Generate retract messages if true.FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearGrouping()
The array of the key indexes.FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearGroupWindow()
Group Window.FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearIndexOfCountStar()
The index of a count aggregate used to calculate the number of accumulated rows.FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearJobParameters()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearKeyType()
The schema of the grouping keys.FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearMapStateReadCacheSize()
The map state read cache size.FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearMapStateWriteCacheSize()
The map_state_write_cache_size.FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearMetricEnabled()
bool metric_enabled = 2;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearProfileEnabled()
bool profile_enabled = 13;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearStateCacheSize()
The state cache size.FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearStateCleaningEnabled()
Cleanup the expired state if true.FlinkFnApi.UserDefinedAggregateFunctions.Builder
clearUdfs()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
clone()
boolean
getCountStarInserted()
True if the count(*) agg is inserted by the planner.FlinkFnApi.UserDefinedAggregateFunctions
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
com.google.protobuf.Descriptors.Descriptor
getDescriptorForType()
boolean
getGenerateUpdateBefore()
Generate retract messages if true.int
getGrouping(int index)
The array of the key indexes.int
getGroupingCount()
The array of the key indexes.List<Integer>
getGroupingList()
The array of the key indexes.FlinkFnApi.GroupWindow
getGroupWindow()
Group Window.FlinkFnApi.GroupWindow.Builder
getGroupWindowBuilder()
Group Window.FlinkFnApi.GroupWindowOrBuilder
getGroupWindowOrBuilder()
Group Window.int
getIndexOfCountStar()
The index of a count aggregate used to calculate the number of accumulated rows.FlinkFnApi.JobParameter
getJobParameters(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.JobParameter.Builder
getJobParametersBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
List<FlinkFnApi.JobParameter.Builder>
getJobParametersBuilderList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
int
getJobParametersCount()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
List<FlinkFnApi.JobParameter>
getJobParametersList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.JobParameterOrBuilder
getJobParametersOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
List<? extends FlinkFnApi.JobParameterOrBuilder>
getJobParametersOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.Schema.FieldType
getKeyType()
The schema of the grouping keys.FlinkFnApi.Schema.FieldType.Builder
getKeyTypeBuilder()
The schema of the grouping keys.FlinkFnApi.Schema.FieldTypeOrBuilder
getKeyTypeOrBuilder()
The schema of the grouping keys.int
getMapStateReadCacheSize()
The map state read cache size.int
getMapStateWriteCacheSize()
The map_state_write_cache_size.boolean
getMetricEnabled()
bool metric_enabled = 2;
boolean
getProfileEnabled()
bool profile_enabled = 13;
int
getStateCacheSize()
The state cache size.boolean
getStateCleaningEnabled()
Cleanup the expired state if true.FlinkFnApi.UserDefinedAggregateFunction
getUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunction.Builder
getUdfsBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
List<FlinkFnApi.UserDefinedAggregateFunction.Builder>
getUdfsBuilderList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
int
getUdfsCount()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
List<FlinkFnApi.UserDefinedAggregateFunction>
getUdfsList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunctionOrBuilder
getUdfsOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
List<? extends FlinkFnApi.UserDefinedAggregateFunctionOrBuilder>
getUdfsOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
boolean
hasGroupWindow()
Group Window.boolean
hasKeyType()
The schema of the grouping keys.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
boolean
isInitialized()
FlinkFnApi.UserDefinedAggregateFunctions.Builder
mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
FlinkFnApi.UserDefinedAggregateFunctions.Builder
mergeFrom(com.google.protobuf.Message other)
FlinkFnApi.UserDefinedAggregateFunctions.Builder
mergeFrom(FlinkFnApi.UserDefinedAggregateFunctions other)
FlinkFnApi.UserDefinedAggregateFunctions.Builder
mergeGroupWindow(FlinkFnApi.GroupWindow value)
Group Window.FlinkFnApi.UserDefinedAggregateFunctions.Builder
mergeKeyType(FlinkFnApi.Schema.FieldType value)
The schema of the grouping keys.FlinkFnApi.UserDefinedAggregateFunctions.Builder
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
FlinkFnApi.UserDefinedAggregateFunctions.Builder
removeJobParameters(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
removeUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
setCountStarInserted(boolean value)
True if the count(*) agg is inserted by the planner.FlinkFnApi.UserDefinedAggregateFunctions.Builder
setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
FlinkFnApi.UserDefinedAggregateFunctions.Builder
setGenerateUpdateBefore(boolean value)
Generate retract messages if true.FlinkFnApi.UserDefinedAggregateFunctions.Builder
setGrouping(int index, int value)
The array of the key indexes.FlinkFnApi.UserDefinedAggregateFunctions.Builder
setGroupWindow(FlinkFnApi.GroupWindow value)
Group Window.FlinkFnApi.UserDefinedAggregateFunctions.Builder
setGroupWindow(FlinkFnApi.GroupWindow.Builder builderForValue)
Group Window.FlinkFnApi.UserDefinedAggregateFunctions.Builder
setIndexOfCountStar(int value)
The index of a count aggregate used to calculate the number of accumulated rows.FlinkFnApi.UserDefinedAggregateFunctions.Builder
setJobParameters(int index, FlinkFnApi.JobParameter value)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
setJobParameters(int index, FlinkFnApi.JobParameter.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
setKeyType(FlinkFnApi.Schema.FieldType value)
The schema of the grouping keys.FlinkFnApi.UserDefinedAggregateFunctions.Builder
setKeyType(FlinkFnApi.Schema.FieldType.Builder builderForValue)
The schema of the grouping keys.FlinkFnApi.UserDefinedAggregateFunctions.Builder
setMapStateReadCacheSize(int value)
The map state read cache size.FlinkFnApi.UserDefinedAggregateFunctions.Builder
setMapStateWriteCacheSize(int value)
The map_state_write_cache_size.FlinkFnApi.UserDefinedAggregateFunctions.Builder
setMetricEnabled(boolean value)
bool metric_enabled = 2;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
setProfileEnabled(boolean value)
bool profile_enabled = 13;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
FlinkFnApi.UserDefinedAggregateFunctions.Builder
setStateCacheSize(int value)
The state cache size.FlinkFnApi.UserDefinedAggregateFunctions.Builder
setStateCleaningEnabled(boolean value)
Cleanup the expired state if true.FlinkFnApi.UserDefinedAggregateFunctions.Builder
setUdfs(int index, FlinkFnApi.UserDefinedAggregateFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
setUdfs(int index, FlinkFnApi.UserDefinedAggregateFunction.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunctions.Builder
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
-
Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setUnknownFieldSetBuilder, setUnknownFieldsProto3
-
Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder
addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageException
-
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Method Detail
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
clear
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clear()
- Specified by:
clear
in interfacecom.google.protobuf.Message.Builder
- Specified by:
clear
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
clear
in classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
- Specified by:
getDescriptorForType
in interfacecom.google.protobuf.Message.Builder
- Specified by:
getDescriptorForType
in interfacecom.google.protobuf.MessageOrBuilder
- Overrides:
getDescriptorForType
in classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
getDefaultInstanceForType
public FlinkFnApi.UserDefinedAggregateFunctions getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
build
public FlinkFnApi.UserDefinedAggregateFunctions build()
- Specified by:
build
in interfacecom.google.protobuf.Message.Builder
- Specified by:
build
in interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
public FlinkFnApi.UserDefinedAggregateFunctions buildPartial()
- Specified by:
buildPartial
in interfacecom.google.protobuf.Message.Builder
- Specified by:
buildPartial
in interfacecom.google.protobuf.MessageLite.Builder
-
clone
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clone()
- Specified by:
clone
in interfacecom.google.protobuf.Message.Builder
- Specified by:
clone
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
clone
in classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
setField
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
- Specified by:
setField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setField
in classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
clearField
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
- Specified by:
clearField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
clearField
in classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
clearOneof
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
- Specified by:
clearOneof
in interfacecom.google.protobuf.Message.Builder
- Overrides:
clearOneof
in classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
setRepeatedField
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
- Specified by:
setRepeatedField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setRepeatedField
in classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
addRepeatedField
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
- Specified by:
addRepeatedField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
addRepeatedField
in classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
mergeFrom
public FlinkFnApi.UserDefinedAggregateFunctions.Builder mergeFrom(com.google.protobuf.Message other)
- Specified by:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
mergeFrom
public FlinkFnApi.UserDefinedAggregateFunctions.Builder mergeFrom(FlinkFnApi.UserDefinedAggregateFunctions other)
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
mergeFrom
public FlinkFnApi.UserDefinedAggregateFunctions.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Specified by:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Specified by:
mergeFrom
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
- Throws:
IOException
-
getUdfsList
public List<FlinkFnApi.UserDefinedAggregateFunction> getUdfsList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
- Specified by:
getUdfsList
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getUdfsCount
public int getUdfsCount()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
- Specified by:
getUdfsCount
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getUdfs
public FlinkFnApi.UserDefinedAggregateFunction getUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
- Specified by:
getUdfs
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
setUdfs
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setUdfs(int index, FlinkFnApi.UserDefinedAggregateFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
setUdfs
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setUdfs(int index, FlinkFnApi.UserDefinedAggregateFunction.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
addUdfs
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addUdfs(FlinkFnApi.UserDefinedAggregateFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
addUdfs
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addUdfs(int index, FlinkFnApi.UserDefinedAggregateFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
addUdfs
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addUdfs(FlinkFnApi.UserDefinedAggregateFunction.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
addUdfs
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addUdfs(int index, FlinkFnApi.UserDefinedAggregateFunction.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
addAllUdfs
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addAllUdfs(Iterable<? extends FlinkFnApi.UserDefinedAggregateFunction> values)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
clearUdfs
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearUdfs()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
removeUdfs
public FlinkFnApi.UserDefinedAggregateFunctions.Builder removeUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
getUdfsBuilder
public FlinkFnApi.UserDefinedAggregateFunction.Builder getUdfsBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
getUdfsOrBuilder
public FlinkFnApi.UserDefinedAggregateFunctionOrBuilder getUdfsOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
- Specified by:
getUdfsOrBuilder
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getUdfsOrBuilderList
public List<? extends FlinkFnApi.UserDefinedAggregateFunctionOrBuilder> getUdfsOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
- Specified by:
getUdfsOrBuilderList
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
addUdfsBuilder
public FlinkFnApi.UserDefinedAggregateFunction.Builder addUdfsBuilder()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
addUdfsBuilder
public FlinkFnApi.UserDefinedAggregateFunction.Builder addUdfsBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
getUdfsBuilderList
public List<FlinkFnApi.UserDefinedAggregateFunction.Builder> getUdfsBuilderList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
-
getMetricEnabled
public boolean getMetricEnabled()
bool metric_enabled = 2;
- Specified by:
getMetricEnabled
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The metricEnabled.
-
setMetricEnabled
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setMetricEnabled(boolean value)
bool metric_enabled = 2;
- Parameters:
value
- The metricEnabled to set.- Returns:
- This builder for chaining.
-
clearMetricEnabled
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearMetricEnabled()
bool metric_enabled = 2;
- Returns:
- This builder for chaining.
-
getGroupingList
public List<Integer> getGroupingList()
The array of the key indexes.
repeated int32 grouping = 3;
- Specified by:
getGroupingList
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- A list containing the grouping.
-
getGroupingCount
public int getGroupingCount()
The array of the key indexes.
repeated int32 grouping = 3;
- Specified by:
getGroupingCount
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The count of grouping.
-
getGrouping
public int getGrouping(int index)
The array of the key indexes.
repeated int32 grouping = 3;
- Specified by:
getGrouping
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Parameters:
index
- The index of the element to return.- Returns:
- The grouping at the given index.
-
setGrouping
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setGrouping(int index, int value)
The array of the key indexes.
repeated int32 grouping = 3;
- Parameters:
index
- The index to set the value at.value
- The grouping to set.- Returns:
- This builder for chaining.
-
addGrouping
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addGrouping(int value)
The array of the key indexes.
repeated int32 grouping = 3;
- Parameters:
value
- The grouping to add.- Returns:
- This builder for chaining.
-
addAllGrouping
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addAllGrouping(Iterable<? extends Integer> values)
The array of the key indexes.
repeated int32 grouping = 3;
- Parameters:
values
- The grouping to add.- Returns:
- This builder for chaining.
-
clearGrouping
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearGrouping()
The array of the key indexes.
repeated int32 grouping = 3;
- Returns:
- This builder for chaining.
-
getGenerateUpdateBefore
public boolean getGenerateUpdateBefore()
Generate retract messages if true.
bool generate_update_before = 4;
- Specified by:
getGenerateUpdateBefore
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The generateUpdateBefore.
-
setGenerateUpdateBefore
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setGenerateUpdateBefore(boolean value)
Generate retract messages if true.
bool generate_update_before = 4;
- Parameters:
value
- The generateUpdateBefore to set.- Returns:
- This builder for chaining.
-
clearGenerateUpdateBefore
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearGenerateUpdateBefore()
Generate retract messages if true.
bool generate_update_before = 4;
- Returns:
- This builder for chaining.
-
hasKeyType
public boolean hasKeyType()
The schema of the grouping keys.
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 5;
- Specified by:
hasKeyType
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- Whether the keyType field is set.
-
getKeyType
public FlinkFnApi.Schema.FieldType getKeyType()
The schema of the grouping keys.
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 5;
- Specified by:
getKeyType
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The keyType.
-
setKeyType
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setKeyType(FlinkFnApi.Schema.FieldType value)
The schema of the grouping keys.
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 5;
-
setKeyType
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setKeyType(FlinkFnApi.Schema.FieldType.Builder builderForValue)
The schema of the grouping keys.
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 5;
-
mergeKeyType
public FlinkFnApi.UserDefinedAggregateFunctions.Builder mergeKeyType(FlinkFnApi.Schema.FieldType value)
The schema of the grouping keys.
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 5;
-
clearKeyType
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearKeyType()
The schema of the grouping keys.
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 5;
-
getKeyTypeBuilder
public FlinkFnApi.Schema.FieldType.Builder getKeyTypeBuilder()
The schema of the grouping keys.
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 5;
-
getKeyTypeOrBuilder
public FlinkFnApi.Schema.FieldTypeOrBuilder getKeyTypeOrBuilder()
The schema of the grouping keys.
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 5;
- Specified by:
getKeyTypeOrBuilder
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getIndexOfCountStar
public int getIndexOfCountStar()
The index of a count aggregate used to calculate the number of accumulated rows.
int32 index_of_count_star = 6;
- Specified by:
getIndexOfCountStar
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The indexOfCountStar.
-
setIndexOfCountStar
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setIndexOfCountStar(int value)
The index of a count aggregate used to calculate the number of accumulated rows.
int32 index_of_count_star = 6;
- Parameters:
value
- The indexOfCountStar to set.- Returns:
- This builder for chaining.
-
clearIndexOfCountStar
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearIndexOfCountStar()
The index of a count aggregate used to calculate the number of accumulated rows.
int32 index_of_count_star = 6;
- Returns:
- This builder for chaining.
-
getStateCleaningEnabled
public boolean getStateCleaningEnabled()
Cleanup the expired state if true.
bool state_cleaning_enabled = 7;
- Specified by:
getStateCleaningEnabled
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The stateCleaningEnabled.
-
setStateCleaningEnabled
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setStateCleaningEnabled(boolean value)
Cleanup the expired state if true.
bool state_cleaning_enabled = 7;
- Parameters:
value
- The stateCleaningEnabled to set.- Returns:
- This builder for chaining.
-
clearStateCleaningEnabled
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearStateCleaningEnabled()
Cleanup the expired state if true.
bool state_cleaning_enabled = 7;
- Returns:
- This builder for chaining.
-
getStateCacheSize
public int getStateCacheSize()
The state cache size.
int32 state_cache_size = 8;
- Specified by:
getStateCacheSize
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The stateCacheSize.
-
setStateCacheSize
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setStateCacheSize(int value)
The state cache size.
int32 state_cache_size = 8;
- Parameters:
value
- The stateCacheSize to set.- Returns:
- This builder for chaining.
-
clearStateCacheSize
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearStateCacheSize()
The state cache size.
int32 state_cache_size = 8;
- Returns:
- This builder for chaining.
-
getMapStateReadCacheSize
public int getMapStateReadCacheSize()
The map state read cache size.
int32 map_state_read_cache_size = 9;
- Specified by:
getMapStateReadCacheSize
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The mapStateReadCacheSize.
-
setMapStateReadCacheSize
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setMapStateReadCacheSize(int value)
The map state read cache size.
int32 map_state_read_cache_size = 9;
- Parameters:
value
- The mapStateReadCacheSize to set.- Returns:
- This builder for chaining.
-
clearMapStateReadCacheSize
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearMapStateReadCacheSize()
The map state read cache size.
int32 map_state_read_cache_size = 9;
- Returns:
- This builder for chaining.
-
getMapStateWriteCacheSize
public int getMapStateWriteCacheSize()
The map_state_write_cache_size.
int32 map_state_write_cache_size = 10;
- Specified by:
getMapStateWriteCacheSize
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The mapStateWriteCacheSize.
-
setMapStateWriteCacheSize
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setMapStateWriteCacheSize(int value)
The map_state_write_cache_size.
int32 map_state_write_cache_size = 10;
- Parameters:
value
- The mapStateWriteCacheSize to set.- Returns:
- This builder for chaining.
-
clearMapStateWriteCacheSize
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearMapStateWriteCacheSize()
The map_state_write_cache_size.
int32 map_state_write_cache_size = 10;
- Returns:
- This builder for chaining.
-
getCountStarInserted
public boolean getCountStarInserted()
True if the count(*) agg is inserted by the planner.
bool count_star_inserted = 11;
- Specified by:
getCountStarInserted
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The countStarInserted.
-
setCountStarInserted
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setCountStarInserted(boolean value)
True if the count(*) agg is inserted by the planner.
bool count_star_inserted = 11;
- Parameters:
value
- The countStarInserted to set.- Returns:
- This builder for chaining.
-
clearCountStarInserted
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearCountStarInserted()
True if the count(*) agg is inserted by the planner.
bool count_star_inserted = 11;
- Returns:
- This builder for chaining.
-
hasGroupWindow
public boolean hasGroupWindow()
Group Window.
.org.apache.flink.fn_execution.v1.GroupWindow group_window = 12;
- Specified by:
hasGroupWindow
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- Whether the groupWindow field is set.
-
getGroupWindow
public FlinkFnApi.GroupWindow getGroupWindow()
Group Window.
.org.apache.flink.fn_execution.v1.GroupWindow group_window = 12;
- Specified by:
getGroupWindow
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The groupWindow.
-
setGroupWindow
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setGroupWindow(FlinkFnApi.GroupWindow value)
Group Window.
.org.apache.flink.fn_execution.v1.GroupWindow group_window = 12;
-
setGroupWindow
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setGroupWindow(FlinkFnApi.GroupWindow.Builder builderForValue)
Group Window.
.org.apache.flink.fn_execution.v1.GroupWindow group_window = 12;
-
mergeGroupWindow
public FlinkFnApi.UserDefinedAggregateFunctions.Builder mergeGroupWindow(FlinkFnApi.GroupWindow value)
Group Window.
.org.apache.flink.fn_execution.v1.GroupWindow group_window = 12;
-
clearGroupWindow
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearGroupWindow()
Group Window.
.org.apache.flink.fn_execution.v1.GroupWindow group_window = 12;
-
getGroupWindowBuilder
public FlinkFnApi.GroupWindow.Builder getGroupWindowBuilder()
Group Window.
.org.apache.flink.fn_execution.v1.GroupWindow group_window = 12;
-
getGroupWindowOrBuilder
public FlinkFnApi.GroupWindowOrBuilder getGroupWindowOrBuilder()
Group Window.
.org.apache.flink.fn_execution.v1.GroupWindow group_window = 12;
- Specified by:
getGroupWindowOrBuilder
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getProfileEnabled
public boolean getProfileEnabled()
bool profile_enabled = 13;
- Specified by:
getProfileEnabled
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The profileEnabled.
-
setProfileEnabled
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setProfileEnabled(boolean value)
bool profile_enabled = 13;
- Parameters:
value
- The profileEnabled to set.- Returns:
- This builder for chaining.
-
clearProfileEnabled
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearProfileEnabled()
bool profile_enabled = 13;
- Returns:
- This builder for chaining.
-
getJobParametersList
public List<FlinkFnApi.JobParameter> getJobParametersList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
- Specified by:
getJobParametersList
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getJobParametersCount
public int getJobParametersCount()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
- Specified by:
getJobParametersCount
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getJobParameters
public FlinkFnApi.JobParameter getJobParameters(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
- Specified by:
getJobParameters
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
setJobParameters
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setJobParameters(int index, FlinkFnApi.JobParameter value)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
setJobParameters
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setJobParameters(int index, FlinkFnApi.JobParameter.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
addJobParameters
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addJobParameters(FlinkFnApi.JobParameter value)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
addJobParameters
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addJobParameters(int index, FlinkFnApi.JobParameter value)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
addJobParameters
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addJobParameters(FlinkFnApi.JobParameter.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
addJobParameters
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addJobParameters(int index, FlinkFnApi.JobParameter.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
addAllJobParameters
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addAllJobParameters(Iterable<? extends FlinkFnApi.JobParameter> values)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
clearJobParameters
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearJobParameters()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
removeJobParameters
public FlinkFnApi.UserDefinedAggregateFunctions.Builder removeJobParameters(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
getJobParametersBuilder
public FlinkFnApi.JobParameter.Builder getJobParametersBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
getJobParametersOrBuilder
public FlinkFnApi.JobParameterOrBuilder getJobParametersOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
- Specified by:
getJobParametersOrBuilder
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getJobParametersOrBuilderList
public List<? extends FlinkFnApi.JobParameterOrBuilder> getJobParametersOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
- Specified by:
getJobParametersOrBuilderList
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
addJobParametersBuilder
public FlinkFnApi.JobParameter.Builder addJobParametersBuilder()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
addJobParametersBuilder
public FlinkFnApi.JobParameter.Builder addJobParametersBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
getJobParametersBuilderList
public List<FlinkFnApi.JobParameter.Builder> getJobParametersBuilderList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
-
setUnknownFields
public final FlinkFnApi.UserDefinedAggregateFunctions.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
- Specified by:
setUnknownFields
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setUnknownFields
in classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
mergeUnknownFields
public final FlinkFnApi.UserDefinedAggregateFunctions.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
- Specified by:
mergeUnknownFields
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeUnknownFields
in classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
-