Package | Description |
---|---|
org.apache.flink.fnexecution.v1 | |
org.apache.flink.streaming.api.utils |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.Builder.build() |
FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.Builder.buildPartial() |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.getDefaultInstance() |
FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.getDefaultInstanceForType() |
FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.Builder.getDefaultInstanceForType() |
FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder.getUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunctions.getUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.getUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.parseDelimitedFrom(InputStream input) |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.parseFrom(byte[] data) |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.parseFrom(ByteBuffer data) |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.parseFrom(com.google.protobuf.ByteString data) |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.parseFrom(com.google.protobuf.CodedInputStream input) |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.parseFrom(InputStream input) |
static FlinkFnApi.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<FlinkFnApi.UserDefinedAggregateFunction> |
FlinkFnApi.UserDefinedAggregateFunction.getParserForType() |
List<FlinkFnApi.UserDefinedAggregateFunction> |
FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder.getUdfsList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
List<FlinkFnApi.UserDefinedAggregateFunction> |
FlinkFnApi.UserDefinedAggregateFunctions.getUdfsList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
List<FlinkFnApi.UserDefinedAggregateFunction> |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.getUdfsList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
static com.google.protobuf.Parser<FlinkFnApi.UserDefinedAggregateFunction> |
FlinkFnApi.UserDefinedAggregateFunction.parser() |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.addUdfs(FlinkFnApi.UserDefinedAggregateFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.addUdfs(int index,
FlinkFnApi.UserDefinedAggregateFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
FlinkFnApi.UserDefinedAggregateFunction.Builder |
FlinkFnApi.UserDefinedAggregateFunction.Builder.mergeFrom(FlinkFnApi.UserDefinedAggregateFunction other) |
static FlinkFnApi.UserDefinedAggregateFunction.Builder |
FlinkFnApi.UserDefinedAggregateFunction.newBuilder(FlinkFnApi.UserDefinedAggregateFunction prototype) |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setUdfs(int index,
FlinkFnApi.UserDefinedAggregateFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.addAllUdfs(Iterable<? extends FlinkFnApi.UserDefinedAggregateFunction> values)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1; |
Modifier and Type | Method and Description |
---|---|
static FlinkFnApi.UserDefinedAggregateFunction |
PythonOperatorUtils.getUserDefinedAggregateFunctionProto(PythonAggregateFunctionInfo pythonFunctionInfo,
DataViewUtils.DataViewSpec[] dataViewSpecs) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.