Package org.apache.flink.fnexecution.v1

Class FlinkFnApi.UserDefinedAggregateFunction.Builder

java.lang.Object

com.google.protobuf.AbstractMessageLite.Builder

com.google.protobuf.AbstractMessage.Builder<BuilderT>

com.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedAggregateFunction.Builder>

org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.Builder

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable, FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

Enclosing class:

FlinkFnApi.UserDefinedAggregateFunction

public static final class FlinkFnApi.UserDefinedAggregateFunction.Builder
extends com.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedAggregateFunction.Builder>
implements FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

Protobuf type org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction

Method Summary

Modifier and Type	Method	Description
FlinkFnApi.UserDefinedAggregateFunction.Builder	addAllInputs(Iterable<? extends FlinkFnApi.Input> values)	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.UserDefinedAggregateFunction.Builder	addAllSpecs(Iterable<? extends FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec> values)	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction.Builder	addInputs(int index, FlinkFnApi.Input value)	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.UserDefinedAggregateFunction.Builder	addInputs(int index, FlinkFnApi.Input.Builder builderForValue)	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.UserDefinedAggregateFunction.Builder	addInputs(FlinkFnApi.Input value)	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.UserDefinedAggregateFunction.Builder	addInputs(FlinkFnApi.Input.Builder builderForValue)	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.Input.Builder	addInputsBuilder()	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.Input.Builder	addInputsBuilder(int index)	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.UserDefinedAggregateFunction.Builder	addSpecs(int index, FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec value)	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction.Builder	addSpecs(int index, FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder builderForValue)	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction.Builder	addSpecs(FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec value)	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction.Builder	addSpecs(FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder builderForValue)	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder	addSpecsBuilder()	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder	addSpecsBuilder(int index)	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction	build()
FlinkFnApi.UserDefinedAggregateFunction	buildPartial()
FlinkFnApi.UserDefinedAggregateFunction.Builder	clear()
FlinkFnApi.UserDefinedAggregateFunction.Builder	clearDistinct()	bool distinct = 5;
FlinkFnApi.UserDefinedAggregateFunction.Builder	clearFilterArg()	int32 filter_arg = 4;
FlinkFnApi.UserDefinedAggregateFunction.Builder	clearInputs()	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.UserDefinedAggregateFunction.Builder	clearPayload()	The serialized representation of the user-defined function
FlinkFnApi.UserDefinedAggregateFunction.Builder	clearSpecs()	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction.Builder	clearTakesRowAsInput()	Whether the UDF takes row as input instead of each columns of a row
FlinkFnApi.UserDefinedAggregateFunction	getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
boolean	getDistinct()	bool distinct = 5;
int	getFilterArg()	int32 filter_arg = 4;
FlinkFnApi.Input	getInputs(int index)	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.Input.Builder	getInputsBuilder(int index)	The input arguments of the user-defined function, it could be one of the following: 1.
List<FlinkFnApi.Input.Builder>	getInputsBuilderList()	The input arguments of the user-defined function, it could be one of the following: 1.
int	getInputsCount()	The input arguments of the user-defined function, it could be one of the following: 1.
List<FlinkFnApi.Input>	getInputsList()	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.InputOrBuilder	getInputsOrBuilder(int index)	The input arguments of the user-defined function, it could be one of the following: 1.
List<? extends FlinkFnApi.InputOrBuilder>	getInputsOrBuilderList()	The input arguments of the user-defined function, it could be one of the following: 1.
com.google.protobuf.ByteString	getPayload()	The serialized representation of the user-defined function
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec	getSpecs(int index)	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder	getSpecsBuilder(int index)	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
List<FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder>	getSpecsBuilderList()	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
int	getSpecsCount()	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
List<FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec>	getSpecsList()	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpecOrBuilder	getSpecsOrBuilder(int index)	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
List<? extends FlinkFnApi.UserDefinedAggregateFunction.DataViewSpecOrBuilder>	getSpecsOrBuilderList()	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
boolean	getTakesRowAsInput()	Whether the UDF takes row as input instead of each columns of a row
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable	internalGetFieldAccessorTable()
boolean	isInitialized()
FlinkFnApi.UserDefinedAggregateFunction.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
FlinkFnApi.UserDefinedAggregateFunction.Builder	mergeFrom(com.google.protobuf.Message other)
FlinkFnApi.UserDefinedAggregateFunction.Builder	mergeFrom(FlinkFnApi.UserDefinedAggregateFunction other)
FlinkFnApi.UserDefinedAggregateFunction.Builder	removeInputs(int index)	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.UserDefinedAggregateFunction.Builder	removeSpecs(int index)	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction.Builder	setDistinct(boolean value)	bool distinct = 5;
FlinkFnApi.UserDefinedAggregateFunction.Builder	setFilterArg(int value)	int32 filter_arg = 4;
FlinkFnApi.UserDefinedAggregateFunction.Builder	setInputs(int index, FlinkFnApi.Input value)	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.UserDefinedAggregateFunction.Builder	setInputs(int index, FlinkFnApi.Input.Builder builderForValue)	The input arguments of the user-defined function, it could be one of the following: 1.
FlinkFnApi.UserDefinedAggregateFunction.Builder	setPayload(com.google.protobuf.ByteString value)	The serialized representation of the user-defined function
FlinkFnApi.UserDefinedAggregateFunction.Builder	setSpecs(int index, FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec value)	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction.Builder	setSpecs(int index, FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder builderForValue)	repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
FlinkFnApi.UserDefinedAggregateFunction.Builder	setTakesRowAsInput(boolean value)	Whether the UDF takes row as input instead of each columns of a row

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

addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMapFieldReflection, internalGetMutableMapField, internalGetMutableMapFieldReflection, isClean, markClean, mergeUnknownFields, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setField, setRepeatedField, setUnknownFields, 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

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

mergeDelimitedFrom, mergeDelimitedFrom

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

mergeFrom

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Method Detail

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

internalGetFieldAccessorTable

protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()

Specified by:

internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedAggregateFunction.Builder>

clear

public FlinkFnApi.UserDefinedAggregateFunction.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.GeneratedMessage.Builder<FlinkFnApi.UserDefinedAggregateFunction.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.GeneratedMessage.Builder<FlinkFnApi.UserDefinedAggregateFunction.Builder>

getDefaultInstanceForType

public FlinkFnApi.UserDefinedAggregateFunction getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public FlinkFnApi.UserDefinedAggregateFunction build()

Specified by:

build in interface com.google.protobuf.Message.Builder

Specified by:

build in interface com.google.protobuf.MessageLite.Builder

buildPartial

public FlinkFnApi.UserDefinedAggregateFunction buildPartial()

Specified by:

buildPartial in interface com.google.protobuf.Message.Builder

Specified by:

buildPartial in interface com.google.protobuf.MessageLite.Builder

mergeFrom

public FlinkFnApi.UserDefinedAggregateFunction.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.UserDefinedAggregateFunction.Builder>

mergeFrom

public FlinkFnApi.UserDefinedAggregateFunction.Builder mergeFrom(FlinkFnApi.UserDefinedAggregateFunction other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedAggregateFunction.Builder>

mergeFrom

public FlinkFnApi.UserDefinedAggregateFunction.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.UserDefinedAggregateFunction.Builder>

Throws:

IOException

getPayload

public com.google.protobuf.ByteString getPayload()

 The serialized representation of the user-defined function
 

bytes payload = 1;

Specified by:

getPayload in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

Returns:

The payload.

setPayload

public FlinkFnApi.UserDefinedAggregateFunction.Builder setPayload(com.google.protobuf.ByteString value)

 The serialized representation of the user-defined function
 

bytes payload = 1;

Parameters:

value - The payload to set.

Returns:

This builder for chaining.

clearPayload

public FlinkFnApi.UserDefinedAggregateFunction.Builder clearPayload()

 The serialized representation of the user-defined function
 

bytes payload = 1;

Returns:

This builder for chaining.

getInputsList

public List<FlinkFnApi.Input> getInputsList()

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

Specified by:

getInputsList in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

getInputsCount

public int getInputsCount()

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

Specified by:

getInputsCount in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

getInputs

public FlinkFnApi.Input getInputs(int index)

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

Specified by:

getInputs in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

setInputs

public FlinkFnApi.UserDefinedAggregateFunction.Builder setInputs(int index,
                                                                 FlinkFnApi.Input value)

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

setInputs

public FlinkFnApi.UserDefinedAggregateFunction.Builder setInputs(int index,
                                                                 FlinkFnApi.Input.Builder builderForValue)

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

addInputs

public FlinkFnApi.UserDefinedAggregateFunction.Builder addInputs(FlinkFnApi.Input value)

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

addInputs

public FlinkFnApi.UserDefinedAggregateFunction.Builder addInputs(int index,
                                                                 FlinkFnApi.Input value)

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

addInputs

public FlinkFnApi.UserDefinedAggregateFunction.Builder addInputs(FlinkFnApi.Input.Builder builderForValue)

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

addInputs

public FlinkFnApi.UserDefinedAggregateFunction.Builder addInputs(int index,
                                                                 FlinkFnApi.Input.Builder builderForValue)

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

addAllInputs

public FlinkFnApi.UserDefinedAggregateFunction.Builder addAllInputs(Iterable<? extends FlinkFnApi.Input> values)

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

clearInputs

public FlinkFnApi.UserDefinedAggregateFunction.Builder clearInputs()

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

removeInputs

public FlinkFnApi.UserDefinedAggregateFunction.Builder removeInputs(int index)

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

getInputsBuilder

public FlinkFnApi.Input.Builder getInputsBuilder(int index)

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

getInputsOrBuilder

public FlinkFnApi.InputOrBuilder getInputsOrBuilder(int index)

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

Specified by:

getInputsOrBuilder in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

getInputsOrBuilderList

public List<? extends FlinkFnApi.InputOrBuilder> getInputsOrBuilderList()

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

Specified by:

getInputsOrBuilderList in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

addInputsBuilder

public FlinkFnApi.Input.Builder addInputsBuilder()

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

addInputsBuilder

public FlinkFnApi.Input.Builder addInputsBuilder(int index)

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

getInputsBuilderList

public List<FlinkFnApi.Input.Builder> getInputsBuilderList()

 The input arguments of the user-defined function, it could be one of the following:
 1. A column from the input row
 2. The result of another user-defined function
 3. The constant value of the column
 

repeated .org.apache.flink.fn_execution.v1.Input inputs = 2;

getSpecsList

public List<FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec> getSpecsList()

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

Specified by:

getSpecsList in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

getSpecsCount

public int getSpecsCount()

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

Specified by:

getSpecsCount in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

getSpecs

public FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec getSpecs(int index)

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

Specified by:

getSpecs in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

setSpecs

public FlinkFnApi.UserDefinedAggregateFunction.Builder setSpecs(int index,
                                                                FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec value)

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

setSpecs

public FlinkFnApi.UserDefinedAggregateFunction.Builder setSpecs(int index,
                                                                FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder builderForValue)

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

addSpecs

public FlinkFnApi.UserDefinedAggregateFunction.Builder addSpecs(FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec value)

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

addSpecs

public FlinkFnApi.UserDefinedAggregateFunction.Builder addSpecs(int index,
                                                                FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec value)

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

addSpecs

public FlinkFnApi.UserDefinedAggregateFunction.Builder addSpecs(FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder builderForValue)

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

addSpecs

public FlinkFnApi.UserDefinedAggregateFunction.Builder addSpecs(int index,
                                                                FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder builderForValue)

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

addAllSpecs

public FlinkFnApi.UserDefinedAggregateFunction.Builder addAllSpecs(Iterable<? extends FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec> values)

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

clearSpecs

public FlinkFnApi.UserDefinedAggregateFunction.Builder clearSpecs()

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

removeSpecs

public FlinkFnApi.UserDefinedAggregateFunction.Builder removeSpecs(int index)

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

getSpecsBuilder

public FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder getSpecsBuilder(int index)

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

getSpecsOrBuilder

public FlinkFnApi.UserDefinedAggregateFunction.DataViewSpecOrBuilder getSpecsOrBuilder(int index)

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

Specified by:

getSpecsOrBuilder in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

getSpecsOrBuilderList

public List<? extends FlinkFnApi.UserDefinedAggregateFunction.DataViewSpecOrBuilder> getSpecsOrBuilderList()

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

Specified by:

getSpecsOrBuilderList in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

addSpecsBuilder

public FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder addSpecsBuilder()

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

addSpecsBuilder

public FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder addSpecsBuilder(int index)

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

getSpecsBuilderList

public List<FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder> getSpecsBuilderList()

repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;

getFilterArg

public int getFilterArg()

int32 filter_arg = 4;

Specified by:

getFilterArg in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

Returns:

The filterArg.

setFilterArg

public FlinkFnApi.UserDefinedAggregateFunction.Builder setFilterArg(int value)

int32 filter_arg = 4;

Parameters:

value - The filterArg to set.

Returns:

This builder for chaining.

clearFilterArg

public FlinkFnApi.UserDefinedAggregateFunction.Builder clearFilterArg()

int32 filter_arg = 4;

Returns:

This builder for chaining.

getDistinct

public boolean getDistinct()

bool distinct = 5;

Specified by:

getDistinct in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

Returns:

The distinct.

setDistinct

public FlinkFnApi.UserDefinedAggregateFunction.Builder setDistinct(boolean value)

bool distinct = 5;

Parameters:

value - The distinct to set.

Returns:

This builder for chaining.

clearDistinct

public FlinkFnApi.UserDefinedAggregateFunction.Builder clearDistinct()

bool distinct = 5;

Returns:

This builder for chaining.

getTakesRowAsInput

public boolean getTakesRowAsInput()

 Whether the UDF takes row as input instead of each columns of a row
 

bool takes_row_as_input = 6;

Specified by:

getTakesRowAsInput in interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

Returns:

The takesRowAsInput.

setTakesRowAsInput

public FlinkFnApi.UserDefinedAggregateFunction.Builder setTakesRowAsInput(boolean value)

 Whether the UDF takes row as input instead of each columns of a row
 

bool takes_row_as_input = 6;

Parameters:

value - The takesRowAsInput to set.

Returns:

This builder for chaining.

clearTakesRowAsInput

public FlinkFnApi.UserDefinedAggregateFunction.Builder clearTakesRowAsInput()

 Whether the UDF takes row as input instead of each columns of a row
 

bool takes_row_as_input = 6;

Returns:

This builder for chaining.