Package org.apache.flink.fnexecution.v1

Interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder

All Superinterfaces:

com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder

All Known Implementing Classes:

FlinkFnApi.UserDefinedAggregateFunction, FlinkFnApi.UserDefinedAggregateFunction.Builder

Enclosing class:

FlinkFnApi

public static interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder
extends com.google.protobuf.MessageOrBuilder

Method Summary

Modifier and Type	Method	Description
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.
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;
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

Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

isInitialized

Methods inherited from interface com.google.protobuf.MessageOrBuilder

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

Method Detail

getPayload

com.google.protobuf.ByteString getPayload()

 The serialized representation of the user-defined function
 

bytes payload = 1;

Returns:

The payload.

getInputsList

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;

getInputs

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;

getInputsCount

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;

getInputsOrBuilderList

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;

getInputsOrBuilder

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;

getSpecsList

List<FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec> getSpecsList()

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

getSpecs

FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec getSpecs(int index)

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

getSpecsCount

int getSpecsCount()

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

getSpecsOrBuilderList

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

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

getSpecsOrBuilder

FlinkFnApi.UserDefinedAggregateFunction.DataViewSpecOrBuilder getSpecsOrBuilder(int index)

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

getFilterArg

int getFilterArg()

int32 filter_arg = 4;

Returns:

The filterArg.

getDistinct

boolean getDistinct()

bool distinct = 5;

Returns:

The distinct.

getTakesRowAsInput

boolean getTakesRowAsInput()

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

bool takes_row_as_input = 6;

Returns:

The takesRowAsInput.