Package | Description |
---|---|
org.apache.flink.fnexecution.v1 |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.addAllGrouping(Iterable<? extends Integer> values)
The array of the key indexes.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.addAllUdfs(Iterable<? extends FlinkFnApi.UserDefinedAggregateFunction> values)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.addGrouping(int value)
The array of the key indexes.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.addUdfs(FlinkFnApi.UserDefinedAggregateFunction.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.addUdfs(FlinkFnApi.UserDefinedAggregateFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.addUdfs(int index,
FlinkFnApi.UserDefinedAggregateFunction.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.addUdfs(int index,
FlinkFnApi.UserDefinedAggregateFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clear() |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearCountStarInserted()
True if the count(*) agg is inserted by the planner.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearGenerateUpdateBefore()
Generate retract messages if true.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearGrouping()
The array of the key indexes.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearGroupWindow()
Group Window.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearIndexOfCountStar()
The index of a count aggregate used to calculate the number of accumulated rows.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearKeyType()
The schema of the grouping keys.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearMapStateReadCacheSize()
The map state read cache size.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearMapStateWriteCacheSize()
The map_state_write_cache_size.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearMetricEnabled()
bool metric_enabled = 2; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearProfileEnabled()
bool profile_enabled = 13; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearStateCacheSize()
The state cache size.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearStateCleaningEnabled()
Cleanup the expired state if true.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clearUdfs()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.clone() |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.mergeFrom(FlinkFnApi.UserDefinedAggregateFunctions other) |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.mergeFrom(com.google.protobuf.Message other) |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.mergeGroupWindow(FlinkFnApi.GroupWindow value)
Group Window.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.mergeKeyType(FlinkFnApi.Schema.FieldType value)
The schema of the grouping keys.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
static FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.newBuilder() |
static FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.newBuilder(FlinkFnApi.UserDefinedAggregateFunctions prototype) |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.newBuilderForType() |
protected FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.removeUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setCountStarInserted(boolean value)
True if the count(*) agg is inserted by the planner.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setGenerateUpdateBefore(boolean value)
Generate retract messages if true.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setGrouping(int index,
int value)
The array of the key indexes.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setGroupWindow(FlinkFnApi.GroupWindow.Builder builderForValue)
Group Window.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setGroupWindow(FlinkFnApi.GroupWindow value)
Group Window.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setIndexOfCountStar(int value)
The index of a count aggregate used to calculate the number of accumulated rows.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setKeyType(FlinkFnApi.Schema.FieldType.Builder builderForValue)
The schema of the grouping keys.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setKeyType(FlinkFnApi.Schema.FieldType value)
The schema of the grouping keys.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setMapStateReadCacheSize(int value)
The map state read cache size.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setMapStateWriteCacheSize(int value)
The map_state_write_cache_size.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setMetricEnabled(boolean value)
bool metric_enabled = 2; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setProfileEnabled(boolean value)
bool profile_enabled = 13; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setStateCacheSize(int value)
The state cache size.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setStateCleaningEnabled(boolean value)
Cleanup the expired state if true.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setUdfs(int index,
FlinkFnApi.UserDefinedAggregateFunction.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setUdfs(int index,
FlinkFnApi.UserDefinedAggregateFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.toBuilder() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.