public static interface FlinkFnApi.UserDefinedAggregateFunctionOrBuilder
extends com.google.protobuf.MessageOrBuilder
Modifier and Type | Method and 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
bytes payload = 1; |
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
bool takes_row_as_input = 6; |
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
com.google.protobuf.ByteString getPayload()
The serialized representation of the user-defined function
bytes payload = 1;
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;
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;
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;
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;
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;
List<FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec> getSpecsList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec specs = 3;
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<? extends FlinkFnApi.UserDefinedAggregateFunction.DataViewSpecOrBuilder> getSpecsOrBuilderList()
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;
int getFilterArg()
int32 filter_arg = 4;
boolean getDistinct()
bool distinct = 5;
boolean getTakesRowAsInput()
Whether the UDF takes row as input instead of each columns of a row
bool takes_row_as_input = 6;
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.