FlinkFnApi.UserDefinedAggregateFunctions.Builder (Flink : 1.16-SNAPSHOT API)

java.lang.Object
- com.google.protobuf.AbstractMessageLite.Builder
- - com.google.protobuf.AbstractMessage.Builder<BuilderType>
  - - 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 type org.apache.flink.fn_execution.v1.UserDefinedAggregateFunctions

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`FlinkFnApi.UserDefinedAggregateFunctions.Builder`	`addAllGrouping(Iterable<? extends Integer> values)` The array of the key indexes.
`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`	`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`	`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.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`	`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`	`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)`

Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, newBuilderForField, onBuilt, onChanged, setUnknownFieldsProto3

Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder
addAll, addAll, mergeFrom, newUninitializedMessageException

Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Methods inherited from interface com.google.protobuf.MessageLite.Builder
mergeFrom

- Method Detail
  - getDescriptor
```
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
```
  - internalGetFieldAccessorTable
```
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
```
    Specified by:
    
    internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
  - clear
```
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clear()
```
    Specified by:
    
    clear in interface com.google.protobuf.Message.Builder
    
    Specified by:
    
    clear in interface com.google.protobuf.MessageLite.Builder
    
    Overrides:
    
    clear in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
  - getDescriptorForType
```
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
```
    Specified by:
    
    getDescriptorForType in interface com.google.protobuf.Message.Builder
    
    Specified by:
    
    getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
    
    Overrides:
    
    getDescriptorForType in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
  - getDefaultInstanceForType
```
public FlinkFnApi.UserDefinedAggregateFunctions getDefaultInstanceForType()
```
    Specified by:
    
    getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
    
    Specified by:
    
    getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder
  - build
```
public FlinkFnApi.UserDefinedAggregateFunctions build()
```
    Specified by:
    
    build in interface com.google.protobuf.Message.Builder
    
    Specified by:
    
    build in interface com.google.protobuf.MessageLite.Builder
  - buildPartial
```
public FlinkFnApi.UserDefinedAggregateFunctions buildPartial()
```
    Specified by:
    
    buildPartial in interface com.google.protobuf.Message.Builder
    
    Specified by:
    
    buildPartial in interface com.google.protobuf.MessageLite.Builder
  - clone
```
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clone()
```
    Specified by:
    
    clone in interface com.google.protobuf.Message.Builder
    
    Specified by:
    
    clone in interface com.google.protobuf.MessageLite.Builder
    
    Overrides:
    
    clone in class com.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 interface com.google.protobuf.Message.Builder
    
    Overrides:
    
    setField in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
  - clearField
```
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
```
    Specified by:
    
    clearField in interface com.google.protobuf.Message.Builder
    
    Overrides:
    
    clearField in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
  - clearOneof
```
public FlinkFnApi.UserDefinedAggregateFunctions.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
```
    Specified by:
    
    clearOneof in interface com.google.protobuf.Message.Builder
    
    Overrides:
    
    clearOneof in class com.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 interface com.google.protobuf.Message.Builder
    
    Overrides:
    
    setRepeatedField in class com.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 interface com.google.protobuf.Message.Builder
    
    Overrides:
    
    addRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
  - mergeFrom
```
public FlinkFnApi.UserDefinedAggregateFunctions.Builder mergeFrom(com.google.protobuf.Message other)
```
    Specified by:
    
    mergeFrom in interface com.google.protobuf.Message.Builder
    
    Overrides:
    
    mergeFrom in class com.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 interface com.google.protobuf.MessageLiteOrBuilder
    
    Overrides:
    
    isInitialized in class com.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 interface com.google.protobuf.Message.Builder
    
    Specified by:
    
    mergeFrom in interface com.google.protobuf.MessageLite.Builder
    
    Overrides:
    
    mergeFrom in class com.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 interface FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
  - getUdfsCount
```
public int getUdfsCount()
```
    repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
    
    Specified by:
    
    getUdfsCount in interface FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
  - getUdfs
```
public FlinkFnApi.UserDefinedAggregateFunction getUdfs(int index)
```
    repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
    
    Specified by:
    
    getUdfs in interface FlinkFnApi.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 interface FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
  - getUdfsOrBuilderList
```
public List<? extends FlinkFnApi.UserDefinedAggregateFunctionOrBuilder> getUdfsOrBuilderList()
```
    repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
    
    Specified by:
    
    getUdfsOrBuilderList in interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.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 interface FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
  - getProfileEnabled
```
public boolean getProfileEnabled()
```
    bool profile_enabled = 13;
    
    Specified by:
    
    getProfileEnabled in interface FlinkFnApi.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.
  - setUnknownFields
```
public final FlinkFnApi.UserDefinedAggregateFunctions.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
```
    Specified by:
    
    setUnknownFields in interface com.google.protobuf.Message.Builder
    
    Overrides:
    
    setUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>
  - mergeUnknownFields
```
public final FlinkFnApi.UserDefinedAggregateFunctions.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
```
    Specified by:
    
    mergeUnknownFields in interface com.google.protobuf.Message.Builder
    
    Overrides:
    
    mergeUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedAggregateFunctions.Builder>

Back to Flink Website

Class FlinkFnApi.UserDefinedAggregateFunctions.Builder

Method Summary

Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder

Methods inherited from class com.google.protobuf.AbstractMessage.Builder

Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder

Methods inherited from class java.lang.Object

Methods inherited from interface com.google.protobuf.MessageOrBuilder

Methods inherited from interface com.google.protobuf.MessageLite.Builder

Method Detail

getDescriptor

internalGetFieldAccessorTable

clear

getDescriptorForType

getDefaultInstanceForType

build

buildPartial

clone

setField

clearField

clearOneof

setRepeatedField

addRepeatedField

mergeFrom

mergeFrom

isInitialized

mergeFrom

getUdfsList

getUdfsCount

getUdfs

setUdfs

setUdfs

addUdfs

addUdfs

addUdfs

addUdfs

addAllUdfs

clearUdfs

removeUdfs

getUdfsBuilder

getUdfsOrBuilder

getUdfsOrBuilderList

addUdfsBuilder

addUdfsBuilder

getUdfsBuilderList

getMetricEnabled

setMetricEnabled

clearMetricEnabled

getGroupingList

getGroupingCount

getGrouping

setGrouping

addGrouping

addAllGrouping

clearGrouping

getGenerateUpdateBefore

setGenerateUpdateBefore

clearGenerateUpdateBefore

hasKeyType

getKeyType

setKeyType

setKeyType

mergeKeyType

clearKeyType

getKeyTypeBuilder

getKeyTypeOrBuilder

getIndexOfCountStar

setIndexOfCountStar

clearIndexOfCountStar

getStateCleaningEnabled

setStateCleaningEnabled

clearStateCleaningEnabled

getStateCacheSize

setStateCacheSize

clearStateCacheSize

getMapStateReadCacheSize

setMapStateReadCacheSize

clearMapStateReadCacheSize

getMapStateWriteCacheSize

setMapStateWriteCacheSize