org.apache.flink.fnexecution.v1

Class FlinkFnApi

java.lang.Object

org.apache.flink.fnexecution.v1.FlinkFnApi

public final class FlinkFnApi
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlinkFnApi.CoderInfoDescriptor A representation of the coder
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
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
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

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

registerAllExtensions

public static void registerAllExtensions(com.google.protobuf.ExtensionRegistryLite registry)

registerAllExtensions

public static void registerAllExtensions(com.google.protobuf.ExtensionRegistry registry)

getDescriptor

public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor()