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