Package | Description |
---|---|
org.apache.flink.fnexecution.v1 | |
org.apache.flink.python.util |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.Builder.build() |
FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.Builder.buildPartial() |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.getDefaultInstance() |
FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.getDefaultInstanceForType() |
FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.Builder.getDefaultInstanceForType() |
FlinkFnApi.UserDefinedFunction |
FlinkFnApi.InputOrBuilder.getUdf()
.org.apache.flink.fn_execution.v1.UserDefinedFunction udf = 1; |
FlinkFnApi.UserDefinedFunction |
FlinkFnApi.Input.getUdf()
.org.apache.flink.fn_execution.v1.UserDefinedFunction udf = 1; |
FlinkFnApi.UserDefinedFunction |
FlinkFnApi.Input.Builder.getUdf()
.org.apache.flink.fn_execution.v1.UserDefinedFunction udf = 1; |
FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunctionsOrBuilder.getUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1; |
FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunctions.getUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1; |
FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunctions.Builder.getUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1; |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.parseDelimitedFrom(InputStream input) |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.parseFrom(byte[] data) |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.parseFrom(ByteBuffer data) |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.parseFrom(com.google.protobuf.ByteString data) |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.parseFrom(com.google.protobuf.CodedInputStream input) |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.parseFrom(InputStream input) |
static FlinkFnApi.UserDefinedFunction |
FlinkFnApi.UserDefinedFunction.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<FlinkFnApi.UserDefinedFunction> |
FlinkFnApi.UserDefinedFunction.getParserForType() |
List<FlinkFnApi.UserDefinedFunction> |
FlinkFnApi.UserDefinedFunctionsOrBuilder.getUdfsList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1; |
List<FlinkFnApi.UserDefinedFunction> |
FlinkFnApi.UserDefinedFunctions.getUdfsList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1; |
List<FlinkFnApi.UserDefinedFunction> |
FlinkFnApi.UserDefinedFunctions.Builder.getUdfsList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1; |
static com.google.protobuf.Parser<FlinkFnApi.UserDefinedFunction> |
FlinkFnApi.UserDefinedFunction.parser() |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.UserDefinedFunctions.Builder |
FlinkFnApi.UserDefinedFunctions.Builder.addUdfs(FlinkFnApi.UserDefinedFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1; |
FlinkFnApi.UserDefinedFunctions.Builder |
FlinkFnApi.UserDefinedFunctions.Builder.addUdfs(int index,
FlinkFnApi.UserDefinedFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1; |
FlinkFnApi.UserDefinedFunction.Builder |
FlinkFnApi.UserDefinedFunction.Builder.mergeFrom(FlinkFnApi.UserDefinedFunction other) |
FlinkFnApi.Input.Builder |
FlinkFnApi.Input.Builder.mergeUdf(FlinkFnApi.UserDefinedFunction value)
.org.apache.flink.fn_execution.v1.UserDefinedFunction udf = 1; |
static FlinkFnApi.UserDefinedFunction.Builder |
FlinkFnApi.UserDefinedFunction.newBuilder(FlinkFnApi.UserDefinedFunction prototype) |
FlinkFnApi.Input.Builder |
FlinkFnApi.Input.Builder.setUdf(FlinkFnApi.UserDefinedFunction value)
.org.apache.flink.fn_execution.v1.UserDefinedFunction udf = 1; |
FlinkFnApi.UserDefinedFunctions.Builder |
FlinkFnApi.UserDefinedFunctions.Builder.setUdfs(int index,
FlinkFnApi.UserDefinedFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1; |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.UserDefinedFunctions.Builder |
FlinkFnApi.UserDefinedFunctions.Builder.addAllUdfs(Iterable<? extends FlinkFnApi.UserDefinedFunction> values)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1; |
Modifier and Type | Method and Description |
---|---|
static FlinkFnApi.UserDefinedFunction |
ProtoUtils.createUserDefinedFunctionProto(PythonFunctionInfo pythonFunctionInfo) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.