public final class FlinkFnApi extends Object
Modifier and Type | Class and Description |
---|---|
static class |
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
Protobuf type
org.apache.flink.fn_execution.v1.CoderInfoDescriptor |
static interface |
FlinkFnApi.CoderInfoDescriptorOrBuilder |
static class |
FlinkFnApi.GroupWindow
Protobuf type
org.apache.flink.fn_execution.v1.GroupWindow |
static interface |
FlinkFnApi.GroupWindowOrBuilder |
static class |
FlinkFnApi.Input
Protobuf type
org.apache.flink.fn_execution.v1.Input |
static interface |
FlinkFnApi.InputOrBuilder |
static class |
FlinkFnApi.JobParameter
Protobuf type
org.apache.flink.fn_execution.v1.JobParameter |
static interface |
FlinkFnApi.JobParameterOrBuilder |
static class |
FlinkFnApi.OverWindow
Used to describe the info of over window in pandas batch over window aggregation
Protobuf type
org.apache.flink.fn_execution.v1.OverWindow |
static interface |
FlinkFnApi.OverWindowOrBuilder |
static class |
FlinkFnApi.Schema
A representation of the data schema.
|
static interface |
FlinkFnApi.SchemaOrBuilder |
static class |
FlinkFnApi.StateDescriptor
A representation of State
Protobuf type
org.apache.flink.fn_execution.v1.StateDescriptor |
static interface |
FlinkFnApi.StateDescriptorOrBuilder |
static class |
FlinkFnApi.TypeInfo
A representation of the data type information in DataStream.
|
static interface |
FlinkFnApi.TypeInfoOrBuilder |
static class |
FlinkFnApi.UserDefinedAggregateFunction
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction |
static interface |
FlinkFnApi.UserDefinedAggregateFunctionOrBuilder |
static class |
FlinkFnApi.UserDefinedAggregateFunctions
A list of the user-defined aggregate functions to be executed in a group aggregate operation.
|
static interface |
FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder |
static class |
FlinkFnApi.UserDefinedDataStreamFunction
User defined DataStream function definition.
|
static interface |
FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder |
static class |
FlinkFnApi.UserDefinedFunction
User-defined function definition.
|
static interface |
FlinkFnApi.UserDefinedFunctionOrBuilder |
static class |
FlinkFnApi.UserDefinedFunctions
A list of user-defined functions to be executed in a batch.
|
static interface |
FlinkFnApi.UserDefinedFunctionsOrBuilder |
Modifier and Type | Method and Description |
---|---|
static com.google.protobuf.Descriptors.FileDescriptor |
getDescriptor() |
static void |
registerAllExtensions(com.google.protobuf.ExtensionRegistry registry) |
static void |
registerAllExtensions(com.google.protobuf.ExtensionRegistryLite registry) |
public static void registerAllExtensions(com.google.protobuf.ExtensionRegistryLite registry)
public static void registerAllExtensions(com.google.protobuf.ExtensionRegistry registry)
public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.