public static final class FlinkFnApi.UserDefinedFunction.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder> implements FlinkFnApi.UserDefinedFunctionOrBuilder
User-defined function definition. It supports chaining functions, that's, the execution result of one user-defined function as the input of another user-defined function.Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedFunction
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.UserDefinedFunction.Builder |
addAllInputs(Iterable<? extends FlinkFnApi.Input> values)
The input arguments of the user-defined function, it could be one of the following:
1.
|
FlinkFnApi.UserDefinedFunction.Builder |
addInputs(FlinkFnApi.Input.Builder builderForValue)
The input arguments of the user-defined function, it could be one of the following:
1.
|
FlinkFnApi.UserDefinedFunction.Builder |
addInputs(FlinkFnApi.Input value)
The input arguments of the user-defined function, it could be one of the following:
1.
|
FlinkFnApi.UserDefinedFunction.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.UserDefinedFunction.Builder |
addInputs(int index,
FlinkFnApi.Input value)
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.UserDefinedFunction.Builder |
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
FlinkFnApi.UserDefinedFunction |
build() |
FlinkFnApi.UserDefinedFunction |
buildPartial() |
FlinkFnApi.UserDefinedFunction.Builder |
clear() |
FlinkFnApi.UserDefinedFunction.Builder |
clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
FlinkFnApi.UserDefinedFunction.Builder |
clearInputs()
The input arguments of the user-defined function, it could be one of the following:
1.
|
FlinkFnApi.UserDefinedFunction.Builder |
clearIsPandasUdf()
Whether it's pandas UDF
bool is_pandas_udf = 5; |
FlinkFnApi.UserDefinedFunction.Builder |
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
FlinkFnApi.UserDefinedFunction.Builder |
clearPayload()
The serialized representation of the user-defined function
bytes payload = 1; |
FlinkFnApi.UserDefinedFunction.Builder |
clearTakesRowAsInput()
Whether the UDF takes row as input instead of each columns of a row
bool takes_row_as_input = 4; |
FlinkFnApi.UserDefinedFunction.Builder |
clearWindowIndex()
The index of the over window used in pandas batch over window aggregation
int32 window_index = 3; |
FlinkFnApi.UserDefinedFunction.Builder |
clone() |
FlinkFnApi.UserDefinedFunction |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
com.google.protobuf.Descriptors.Descriptor |
getDescriptorForType() |
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.
|
boolean |
getIsPandasUdf()
Whether it's pandas UDF
bool is_pandas_udf = 5; |
com.google.protobuf.ByteString |
getPayload()
The serialized representation of the user-defined function
bytes payload = 1; |
boolean |
getTakesRowAsInput()
Whether the UDF takes row as input instead of each columns of a row
bool takes_row_as_input = 4; |
int |
getWindowIndex()
The index of the over window used in pandas batch over window aggregation
int32 window_index = 3; |
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
FlinkFnApi.UserDefinedFunction.Builder |
mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
FlinkFnApi.UserDefinedFunction.Builder |
mergeFrom(FlinkFnApi.UserDefinedFunction other) |
FlinkFnApi.UserDefinedFunction.Builder |
mergeFrom(com.google.protobuf.Message other) |
FlinkFnApi.UserDefinedFunction.Builder |
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
FlinkFnApi.UserDefinedFunction.Builder |
removeInputs(int index)
The input arguments of the user-defined function, it could be one of the following:
1.
|
FlinkFnApi.UserDefinedFunction.Builder |
setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
FlinkFnApi.UserDefinedFunction.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.UserDefinedFunction.Builder |
setInputs(int index,
FlinkFnApi.Input value)
The input arguments of the user-defined function, it could be one of the following:
1.
|
FlinkFnApi.UserDefinedFunction.Builder |
setIsPandasUdf(boolean value)
Whether it's pandas UDF
bool is_pandas_udf = 5; |
FlinkFnApi.UserDefinedFunction.Builder |
setPayload(com.google.protobuf.ByteString value)
The serialized representation of the user-defined function
bytes payload = 1; |
FlinkFnApi.UserDefinedFunction.Builder |
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
FlinkFnApi.UserDefinedFunction.Builder |
setTakesRowAsInput(boolean value)
Whether the UDF takes row as input instead of each columns of a row
bool takes_row_as_input = 4; |
FlinkFnApi.UserDefinedFunction.Builder |
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
FlinkFnApi.UserDefinedFunction.Builder |
setWindowIndex(int value)
The index of the over window used in pandas batch over window aggregation
int32 window_index = 3; |
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setUnknownFieldSetBuilder, setUnknownFieldsProto3
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString
addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, newUninitializedMessageException
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder>
public FlinkFnApi.UserDefinedFunction.Builder clear()
clear
in interface com.google.protobuf.Message.Builder
clear
in interface com.google.protobuf.MessageLite.Builder
clear
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder>
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.Message.Builder
getDescriptorForType
in interface com.google.protobuf.MessageOrBuilder
getDescriptorForType
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder>
public FlinkFnApi.UserDefinedFunction getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
public FlinkFnApi.UserDefinedFunction build()
build
in interface com.google.protobuf.Message.Builder
build
in interface com.google.protobuf.MessageLite.Builder
public FlinkFnApi.UserDefinedFunction buildPartial()
buildPartial
in interface com.google.protobuf.Message.Builder
buildPartial
in interface com.google.protobuf.MessageLite.Builder
public FlinkFnApi.UserDefinedFunction.Builder clone()
clone
in interface com.google.protobuf.Message.Builder
clone
in interface com.google.protobuf.MessageLite.Builder
clone
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder>
public FlinkFnApi.UserDefinedFunction.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
setField
in interface com.google.protobuf.Message.Builder
setField
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder>
public FlinkFnApi.UserDefinedFunction.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
clearField
in interface com.google.protobuf.Message.Builder
clearField
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder>
public FlinkFnApi.UserDefinedFunction.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
clearOneof
in interface com.google.protobuf.Message.Builder
clearOneof
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder>
public FlinkFnApi.UserDefinedFunction.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
setRepeatedField
in interface com.google.protobuf.Message.Builder
setRepeatedField
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder>
public FlinkFnApi.UserDefinedFunction.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
addRepeatedField
in interface com.google.protobuf.Message.Builder
addRepeatedField
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder>
public FlinkFnApi.UserDefinedFunction.Builder mergeFrom(com.google.protobuf.Message other)
mergeFrom
in interface com.google.protobuf.Message.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<FlinkFnApi.UserDefinedFunction.Builder>
public FlinkFnApi.UserDefinedFunction.Builder mergeFrom(FlinkFnApi.UserDefinedFunction other)
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder>
public FlinkFnApi.UserDefinedFunction.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
mergeFrom
in interface com.google.protobuf.Message.Builder
mergeFrom
in interface com.google.protobuf.MessageLite.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<FlinkFnApi.UserDefinedFunction.Builder>
IOException
public com.google.protobuf.ByteString getPayload()
The serialized representation of the user-defined function
bytes payload = 1;
getPayload
in interface FlinkFnApi.UserDefinedFunctionOrBuilder
public FlinkFnApi.UserDefinedFunction.Builder setPayload(com.google.protobuf.ByteString value)
The serialized representation of the user-defined function
bytes payload = 1;
value
- The payload to set.public FlinkFnApi.UserDefinedFunction.Builder clearPayload()
The serialized representation of the user-defined function
bytes payload = 1;
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;
getInputsList
in interface FlinkFnApi.UserDefinedFunctionOrBuilder
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;
getInputsCount
in interface FlinkFnApi.UserDefinedFunctionOrBuilder
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;
getInputs
in interface FlinkFnApi.UserDefinedFunctionOrBuilder
public FlinkFnApi.UserDefinedFunction.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;
public FlinkFnApi.UserDefinedFunction.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;
public FlinkFnApi.UserDefinedFunction.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;
public FlinkFnApi.UserDefinedFunction.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;
public FlinkFnApi.UserDefinedFunction.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;
public FlinkFnApi.UserDefinedFunction.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;
public FlinkFnApi.UserDefinedFunction.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;
public FlinkFnApi.UserDefinedFunction.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;
public FlinkFnApi.UserDefinedFunction.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;
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;
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;
getInputsOrBuilder
in interface FlinkFnApi.UserDefinedFunctionOrBuilder
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;
getInputsOrBuilderList
in interface FlinkFnApi.UserDefinedFunctionOrBuilder
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;
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;
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;
public int getWindowIndex()
The index of the over window used in pandas batch over window aggregation
int32 window_index = 3;
getWindowIndex
in interface FlinkFnApi.UserDefinedFunctionOrBuilder
public FlinkFnApi.UserDefinedFunction.Builder setWindowIndex(int value)
The index of the over window used in pandas batch over window aggregation
int32 window_index = 3;
value
- The windowIndex to set.public FlinkFnApi.UserDefinedFunction.Builder clearWindowIndex()
The index of the over window used in pandas batch over window aggregation
int32 window_index = 3;
public boolean getTakesRowAsInput()
Whether the UDF takes row as input instead of each columns of a row
bool takes_row_as_input = 4;
getTakesRowAsInput
in interface FlinkFnApi.UserDefinedFunctionOrBuilder
public FlinkFnApi.UserDefinedFunction.Builder setTakesRowAsInput(boolean value)
Whether the UDF takes row as input instead of each columns of a row
bool takes_row_as_input = 4;
value
- The takesRowAsInput to set.public FlinkFnApi.UserDefinedFunction.Builder clearTakesRowAsInput()
Whether the UDF takes row as input instead of each columns of a row
bool takes_row_as_input = 4;
public boolean getIsPandasUdf()
Whether it's pandas UDF
bool is_pandas_udf = 5;
getIsPandasUdf
in interface FlinkFnApi.UserDefinedFunctionOrBuilder
public FlinkFnApi.UserDefinedFunction.Builder setIsPandasUdf(boolean value)
Whether it's pandas UDF
bool is_pandas_udf = 5;
value
- The isPandasUdf to set.public FlinkFnApi.UserDefinedFunction.Builder clearIsPandasUdf()
Whether it's pandas UDF
bool is_pandas_udf = 5;
public final FlinkFnApi.UserDefinedFunction.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
setUnknownFields
in interface com.google.protobuf.Message.Builder
setUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder>
public final FlinkFnApi.UserDefinedFunction.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
mergeUnknownFields
in interface com.google.protobuf.Message.Builder
mergeUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.UserDefinedFunction.Builder>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.