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.BuilderaddAllGrouping(Iterable<? extends Integer> values)The array of the key indexes.FlinkFnApi.UserDefinedAggregateFunctions.BuilderaddAllJobParameters(Iterable<? extends FlinkFnApi.JobParameter> values)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;FlinkFnApi.UserDefinedAggregateFunctions.BuilderaddAllUdfs(Iterable<? extends FlinkFnApi.UserDefinedAggregateFunction> values)repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;FlinkFnApi.UserDefinedAggregateFunctions.BuilderaddGrouping(int value)The array of the key indexes.FlinkFnApi.UserDefinedAggregateFunctions.BuilderaddJobParameters(int index, FlinkFnApi.JobParameter value)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;FlinkFnApi.UserDefinedAggregateFunctions.BuilderaddJobParameters(int index, FlinkFnApi.JobParameter.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;FlinkFnApi.UserDefinedAggregateFunctions.BuilderaddJobParameters(FlinkFnApi.JobParameter value)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;FlinkFnApi.UserDefinedAggregateFunctions.BuilderaddJobParameters(FlinkFnApi.JobParameter.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;FlinkFnApi.JobParameter.BuilderaddJobParametersBuilder()repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;FlinkFnApi.JobParameter.BuilderaddJobParametersBuilder(int index)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;FlinkFnApi.UserDefinedAggregateFunctions.BuilderaddRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)FlinkFnApi.UserDefinedAggregateFunctions.BuilderaddUdfs(int index, FlinkFnApi.UserDefinedAggregateFunction value)repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;FlinkFnApi.UserDefinedAggregateFunctions.BuilderaddUdfs(int index, FlinkFnApi.UserDefinedAggregateFunction.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;FlinkFnApi.UserDefinedAggregateFunctions.BuilderaddUdfs(FlinkFnApi.UserDefinedAggregateFunction value)repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;FlinkFnApi.UserDefinedAggregateFunctions.BuilderaddUdfs(FlinkFnApi.UserDefinedAggregateFunction.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;FlinkFnApi.UserDefinedAggregateFunction.BuilderaddUdfsBuilder()repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;FlinkFnApi.UserDefinedAggregateFunction.BuilderaddUdfsBuilder(int index)repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;FlinkFnApi.UserDefinedAggregateFunctionsbuild()FlinkFnApi.UserDefinedAggregateFunctionsbuildPartial()FlinkFnApi.UserDefinedAggregateFunctions.Builderclear()FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearCountStarInserted()True if the count(*) agg is inserted by the planner.FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearField(com.google.protobuf.Descriptors.FieldDescriptor field)FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearGenerateUpdateBefore()Generate retract messages if true.FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearGrouping()The array of the key indexes.FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearGroupWindow()Group Window.FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearIndexOfCountStar()The index of a count aggregate used to calculate the number of accumulated rows.FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearJobParameters()repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearKeyType()The schema of the grouping keys.FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearMapStateReadCacheSize()The map state read cache size.FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearMapStateWriteCacheSize()The map_state_write_cache_size.FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearMetricEnabled()bool metric_enabled = 2;FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearProfileEnabled()bool profile_enabled = 13;FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearStateCacheSize()The state cache size.FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearStateCleaningEnabled()Cleanup the expired state if true.FlinkFnApi.UserDefinedAggregateFunctions.BuilderclearUdfs()repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;FlinkFnApi.UserDefinedAggregateFunctions.Builderclone()booleangetCountStarInserted()True if the count(*) agg is inserted by the planner.FlinkFnApi.UserDefinedAggregateFunctionsgetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()com.google.protobuf.Descriptors.DescriptorgetDescriptorForType()booleangetGenerateUpdateBefore()Generate retract messages if true.intgetGrouping(int index)The array of the key indexes.intgetGroupingCount()The array of the key indexes.List<Integer>getGroupingList()The array of the key indexes.FlinkFnApi.GroupWindowgetGroupWindow()Group Window.FlinkFnApi.GroupWindow.BuildergetGroupWindowBuilder()Group Window.FlinkFnApi.GroupWindowOrBuildergetGroupWindowOrBuilder()Group Window.intgetIndexOfCountStar()The index of a count aggregate used to calculate the number of accumulated rows.FlinkFnApi.JobParametergetJobParameters(int index)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;FlinkFnApi.JobParameter.BuildergetJobParametersBuilder(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;intgetJobParametersCount()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.JobParameterOrBuildergetJobParametersOrBuilder(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.FieldTypegetKeyType()The schema of the grouping keys.FlinkFnApi.Schema.FieldType.BuildergetKeyTypeBuilder()The schema of the grouping keys.FlinkFnApi.Schema.FieldTypeOrBuildergetKeyTypeOrBuilder()The schema of the grouping keys.intgetMapStateReadCacheSize()The map state read cache size.intgetMapStateWriteCacheSize()The map_state_write_cache_size.booleangetMetricEnabled()bool metric_enabled = 2;booleangetProfileEnabled()bool profile_enabled = 13;intgetStateCacheSize()The state cache size.booleangetStateCleaningEnabled()Cleanup the expired state if true.FlinkFnApi.UserDefinedAggregateFunctiongetUdfs(int index)repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;FlinkFnApi.UserDefinedAggregateFunction.BuildergetUdfsBuilder(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;intgetUdfsCount()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.UserDefinedAggregateFunctionOrBuildergetUdfsOrBuilder(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;booleanhasGroupWindow()Group Window.booleanhasKeyType()The schema of the grouping keys.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()FlinkFnApi.UserDefinedAggregateFunctions.BuildermergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)FlinkFnApi.UserDefinedAggregateFunctions.BuildermergeFrom(com.google.protobuf.Message other)FlinkFnApi.UserDefinedAggregateFunctions.BuildermergeFrom(FlinkFnApi.UserDefinedAggregateFunctions other)FlinkFnApi.UserDefinedAggregateFunctions.BuildermergeGroupWindow(FlinkFnApi.GroupWindow value)Group Window.FlinkFnApi.UserDefinedAggregateFunctions.BuildermergeKeyType(FlinkFnApi.Schema.FieldType value)The schema of the grouping keys.FlinkFnApi.UserDefinedAggregateFunctions.BuildermergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)FlinkFnApi.UserDefinedAggregateFunctions.BuilderremoveJobParameters(int index)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;FlinkFnApi.UserDefinedAggregateFunctions.BuilderremoveUdfs(int index)repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;FlinkFnApi.UserDefinedAggregateFunctions.BuildersetCountStarInserted(boolean value)True if the count(*) agg is inserted by the planner.FlinkFnApi.UserDefinedAggregateFunctions.BuildersetField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)FlinkFnApi.UserDefinedAggregateFunctions.BuildersetGenerateUpdateBefore(boolean value)Generate retract messages if true.FlinkFnApi.UserDefinedAggregateFunctions.BuildersetGrouping(int index, int value)The array of the key indexes.FlinkFnApi.UserDefinedAggregateFunctions.BuildersetGroupWindow(FlinkFnApi.GroupWindow value)Group Window.FlinkFnApi.UserDefinedAggregateFunctions.BuildersetGroupWindow(FlinkFnApi.GroupWindow.Builder builderForValue)Group Window.FlinkFnApi.UserDefinedAggregateFunctions.BuildersetIndexOfCountStar(int value)The index of a count aggregate used to calculate the number of accumulated rows.FlinkFnApi.UserDefinedAggregateFunctions.BuildersetJobParameters(int index, FlinkFnApi.JobParameter value)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;FlinkFnApi.UserDefinedAggregateFunctions.BuildersetJobParameters(int index, FlinkFnApi.JobParameter.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;FlinkFnApi.UserDefinedAggregateFunctions.BuildersetKeyType(FlinkFnApi.Schema.FieldType value)The schema of the grouping keys.FlinkFnApi.UserDefinedAggregateFunctions.BuildersetKeyType(FlinkFnApi.Schema.FieldType.Builder builderForValue)The schema of the grouping keys.FlinkFnApi.UserDefinedAggregateFunctions.BuildersetMapStateReadCacheSize(int value)The map state read cache size.FlinkFnApi.UserDefinedAggregateFunctions.BuildersetMapStateWriteCacheSize(int value)The map_state_write_cache_size.FlinkFnApi.UserDefinedAggregateFunctions.BuildersetMetricEnabled(boolean value)bool metric_enabled = 2;FlinkFnApi.UserDefinedAggregateFunctions.BuildersetProfileEnabled(boolean value)bool profile_enabled = 13;FlinkFnApi.UserDefinedAggregateFunctions.BuildersetRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)FlinkFnApi.UserDefinedAggregateFunctions.BuildersetStateCacheSize(int value)The state cache size.FlinkFnApi.UserDefinedAggregateFunctions.BuildersetStateCleaningEnabled(boolean value)Cleanup the expired state if true.FlinkFnApi.UserDefinedAggregateFunctions.BuildersetUdfs(int index, FlinkFnApi.UserDefinedAggregateFunction value)repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;FlinkFnApi.UserDefinedAggregateFunctions.BuildersetUdfs(int index, FlinkFnApi.UserDefinedAggregateFunction.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;FlinkFnApi.UserDefinedAggregateFunctions.BuildersetUnknownFields(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, internalGetMapFieldReflection, internalGetMutableMapField, internalGetMutableMapFieldReflection, 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:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
clear
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clear()
- Specified by:
clearin interfacecom.google.protobuf.Message.Builder- Specified by:
clearin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clearin classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.Message.Builder- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.MessageOrBuilder- Overrides:
getDescriptorForTypein classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
getDefaultInstanceForType
public FlinkFnApi.UserDefinedAggregateFunctions getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
build
public FlinkFnApi.UserDefinedAggregateFunctions build()
- Specified by:
buildin interfacecom.google.protobuf.Message.Builder- Specified by:
buildin interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
public FlinkFnApi.UserDefinedAggregateFunctions buildPartial()
- Specified by:
buildPartialin interfacecom.google.protobuf.Message.Builder- Specified by:
buildPartialin interfacecom.google.protobuf.MessageLite.Builder
-
clone
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clone()
- Specified by:
clonein interfacecom.google.protobuf.Message.Builder- Specified by:
clonein interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clonein classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
setField
public FlinkFnApi.UserDefinedAggregateFunctions.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
- Specified by:
setFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
setFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
clearField
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
- Specified by:
clearFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
clearFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
clearOneof
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
- Specified by:
clearOneofin interfacecom.google.protobuf.Message.Builder- Overrides:
clearOneofin 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:
setRepeatedFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
setRepeatedFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
addRepeatedField
public FlinkFnApi.UserDefinedAggregateFunctions.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
- Specified by:
addRepeatedFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
addRepeatedFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
mergeFrom
public FlinkFnApi.UserDefinedAggregateFunctions.Builder mergeFrom(com.google.protobuf.Message other)
- Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
mergeFrom
public FlinkFnApi.UserDefinedAggregateFunctions.Builder mergeFrom(FlinkFnApi.UserDefinedAggregateFunctions other)
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin 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:
mergeFromin interfacecom.google.protobuf.Message.Builder- Specified by:
mergeFromin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
mergeFromin 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:
getUdfsListin interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getUdfsCount
public int getUdfsCount()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;- Specified by:
getUdfsCountin interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getUdfs
public FlinkFnApi.UserDefinedAggregateFunction getUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;- Specified by:
getUdfsin 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:
getUdfsOrBuilderin interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getUdfsOrBuilderList
public List<? extends FlinkFnApi.UserDefinedAggregateFunctionOrBuilder> getUdfsOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;- Specified by:
getUdfsOrBuilderListin 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:
getMetricEnabledin 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:
getGroupingListin interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder- Returns:
- A list containing the grouping.
-
getGroupingCount
public int getGroupingCount()
The array of the key indexes.
repeated int32 grouping = 3;- Specified by:
getGroupingCountin 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:
getGroupingin 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:
getGenerateUpdateBeforein 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:
hasKeyTypein 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:
getKeyTypein 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:
getKeyTypeOrBuilderin 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:
getIndexOfCountStarin 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:
getStateCleaningEnabledin 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:
getStateCacheSizein 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:
getMapStateReadCacheSizein 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:
getMapStateWriteCacheSizein 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:
getCountStarInsertedin 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:
hasGroupWindowin 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:
getGroupWindowin 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:
getGroupWindowOrBuilderin interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getProfileEnabled
public boolean getProfileEnabled()
bool profile_enabled = 13;- Specified by:
getProfileEnabledin 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:
getJobParametersListin interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getJobParametersCount
public int getJobParametersCount()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;- Specified by:
getJobParametersCountin interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getJobParameters
public FlinkFnApi.JobParameter getJobParameters(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;- Specified by:
getJobParametersin 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:
getJobParametersOrBuilderin interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getJobParametersOrBuilderList
public List<? extends FlinkFnApi.JobParameterOrBuilder> getJobParametersOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;- Specified by:
getJobParametersOrBuilderListin 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:
setUnknownFieldsin interfacecom.google.protobuf.Message.Builder- Overrides:
setUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
mergeUnknownFields
public final FlinkFnApi.UserDefinedAggregateFunctions.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
- Specified by:
mergeUnknownFieldsin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
-
-