Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
FlinkFnApi.CoderInfoDescriptor.ArrowType
Protobuf type
org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType |
FlinkFnApi.CoderInfoDescriptor.ArrowType.Builder
Protobuf type
org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType |
FlinkFnApi.CoderInfoDescriptor.ArrowTypeOrBuilder |
FlinkFnApi.CoderInfoDescriptor.Builder
A representation of the coder
|
FlinkFnApi.CoderInfoDescriptor.DataTypeCase |
FlinkFnApi.CoderInfoDescriptor.FlattenRowType
for Table & SQL
|
FlinkFnApi.CoderInfoDescriptor.FlattenRowType.Builder
for Table & SQL
|
FlinkFnApi.CoderInfoDescriptor.FlattenRowTypeOrBuilder |
FlinkFnApi.CoderInfoDescriptor.Mode
Protobuf enum
org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode |
FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType
only used in batch over window
the data consists of [window data][arrow data]
|
FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType.Builder
only used in batch over window
the data consists of [window data][arrow data]
|
FlinkFnApi.CoderInfoDescriptor.OverWindowArrowTypeOrBuilder |
FlinkFnApi.CoderInfoDescriptor.RawType
for DataStream
|
FlinkFnApi.CoderInfoDescriptor.RawType.Builder
for DataStream
|
FlinkFnApi.CoderInfoDescriptor.RawTypeOrBuilder |
FlinkFnApi.CoderInfoDescriptor.RowType
Protobuf type
org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType |
FlinkFnApi.CoderInfoDescriptor.RowType.Builder
Protobuf type
org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType |
FlinkFnApi.CoderInfoDescriptor.RowTypeOrBuilder |
FlinkFnApi.CoderInfoDescriptorOrBuilder |
FlinkFnApi.GroupWindow
Protobuf type
org.apache.flink.fn_execution.v1.GroupWindow |
FlinkFnApi.GroupWindow.Builder
Protobuf type
org.apache.flink.fn_execution.v1.GroupWindow |
FlinkFnApi.GroupWindow.WindowProperty
Protobuf enum
org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty |
FlinkFnApi.GroupWindow.WindowType
Protobuf enum
org.apache.flink.fn_execution.v1.GroupWindow.WindowType |
FlinkFnApi.GroupWindowOrBuilder |
FlinkFnApi.Input
Protobuf type
org.apache.flink.fn_execution.v1.Input |
FlinkFnApi.Input.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Input |
FlinkFnApi.Input.InputCase |
FlinkFnApi.InputOrBuilder |
FlinkFnApi.OverWindow
Used to describe the info of over window in pandas batch over window aggregation
|
FlinkFnApi.OverWindow.Builder
Used to describe the info of over window in pandas batch over window aggregation
|
FlinkFnApi.OverWindow.WindowType
Protobuf enum
org.apache.flink.fn_execution.v1.OverWindow.WindowType |
FlinkFnApi.OverWindowOrBuilder |
FlinkFnApi.Schema
A representation of the data schema.
|
FlinkFnApi.Schema.BinaryInfo
Protobuf type
org.apache.flink.fn_execution.v1.Schema.BinaryInfo |
FlinkFnApi.Schema.BinaryInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Schema.BinaryInfo |
FlinkFnApi.Schema.BinaryInfoOrBuilder |
FlinkFnApi.Schema.Builder
A representation of the data schema.
|
FlinkFnApi.Schema.CharInfo
Protobuf type
org.apache.flink.fn_execution.v1.Schema.CharInfo |
FlinkFnApi.Schema.CharInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Schema.CharInfo |
FlinkFnApi.Schema.CharInfoOrBuilder |
FlinkFnApi.Schema.DecimalInfo
Protobuf type
org.apache.flink.fn_execution.v1.Schema.DecimalInfo |
FlinkFnApi.Schema.DecimalInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Schema.DecimalInfo |
FlinkFnApi.Schema.DecimalInfoOrBuilder |
FlinkFnApi.Schema.Field
Protobuf type
org.apache.flink.fn_execution.v1.Schema.Field |
FlinkFnApi.Schema.Field.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Schema.Field |
FlinkFnApi.Schema.FieldOrBuilder |
FlinkFnApi.Schema.FieldType
Protobuf type
org.apache.flink.fn_execution.v1.Schema.FieldType |
FlinkFnApi.Schema.FieldType.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Schema.FieldType |
FlinkFnApi.Schema.FieldType.TypeInfoCase |
FlinkFnApi.Schema.FieldTypeOrBuilder |
FlinkFnApi.Schema.LocalZonedTimestampInfo
Protobuf type
org.apache.flink.fn_execution.v1.Schema.LocalZonedTimestampInfo |
FlinkFnApi.Schema.LocalZonedTimestampInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Schema.LocalZonedTimestampInfo |
FlinkFnApi.Schema.LocalZonedTimestampInfoOrBuilder |
FlinkFnApi.Schema.MapInfo
Protobuf type
org.apache.flink.fn_execution.v1.Schema.MapInfo |
FlinkFnApi.Schema.MapInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Schema.MapInfo |
FlinkFnApi.Schema.MapInfoOrBuilder |
FlinkFnApi.Schema.TimeInfo
Protobuf type
org.apache.flink.fn_execution.v1.Schema.TimeInfo |
FlinkFnApi.Schema.TimeInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Schema.TimeInfo |
FlinkFnApi.Schema.TimeInfoOrBuilder |
FlinkFnApi.Schema.TimestampInfo
Protobuf type
org.apache.flink.fn_execution.v1.Schema.TimestampInfo |
FlinkFnApi.Schema.TimestampInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Schema.TimestampInfo |
FlinkFnApi.Schema.TimestampInfoOrBuilder |
FlinkFnApi.Schema.TypeName
Protobuf enum
org.apache.flink.fn_execution.v1.Schema.TypeName |
FlinkFnApi.Schema.VarBinaryInfo
Protobuf type
org.apache.flink.fn_execution.v1.Schema.VarBinaryInfo |
FlinkFnApi.Schema.VarBinaryInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Schema.VarBinaryInfo |
FlinkFnApi.Schema.VarBinaryInfoOrBuilder |
FlinkFnApi.Schema.VarCharInfo
Protobuf type
org.apache.flink.fn_execution.v1.Schema.VarCharInfo |
FlinkFnApi.Schema.VarCharInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Schema.VarCharInfo |
FlinkFnApi.Schema.VarCharInfoOrBuilder |
FlinkFnApi.Schema.ZonedTimestampInfo
Protobuf type
org.apache.flink.fn_execution.v1.Schema.ZonedTimestampInfo |
FlinkFnApi.Schema.ZonedTimestampInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.Schema.ZonedTimestampInfo |
FlinkFnApi.Schema.ZonedTimestampInfoOrBuilder |
FlinkFnApi.SchemaOrBuilder |
FlinkFnApi.StateDescriptor
A representation of State
|
FlinkFnApi.StateDescriptor.Builder
A representation of State
|
FlinkFnApi.StateDescriptor.StateTTLConfig
Protobuf type
org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig |
FlinkFnApi.StateDescriptor.StateTTLConfig.Builder
Protobuf type
org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig |
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies
TTL cleanup strategies.
|
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Builder
TTL cleanup strategies.
|
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.EmptyCleanupStrategy
Protobuf enum
org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig.CleanupStrategies.EmptyCleanupStrategy |
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.IncrementalCleanupStrategy
Configuration of cleanup strategy while taking the full snapshot.
|
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.IncrementalCleanupStrategy.Builder
Configuration of cleanup strategy while taking the full snapshot.
|
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.IncrementalCleanupStrategyOrBuilder |
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry
Protobuf type
org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry |
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry.Builder
Protobuf type
org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry |
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry.CleanupStrategyCase |
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntryOrBuilder |
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.RocksdbCompactFilterCleanupStrategy
Configuration of cleanup strategy using custom compaction filter in RocksDB.
|
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.RocksdbCompactFilterCleanupStrategy.Builder
Configuration of cleanup strategy using custom compaction filter in RocksDB.
|
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.RocksdbCompactFilterCleanupStrategyOrBuilder |
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Strategies
Fixed strategies ordinals in strategies config field.
|
FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategiesOrBuilder |
FlinkFnApi.StateDescriptor.StateTTLConfig.StateVisibility
This option configures whether expired user value can be returned or not.
|
FlinkFnApi.StateDescriptor.StateTTLConfig.TtlTimeCharacteristic
This option configures time scale to use for ttl.
|
FlinkFnApi.StateDescriptor.StateTTLConfig.UpdateType
This option value configures when to update last access timestamp which prolongs state TTL.
|
FlinkFnApi.StateDescriptor.StateTTLConfigOrBuilder |
FlinkFnApi.StateDescriptorOrBuilder |
FlinkFnApi.TypeInfo
A representation of the data type information in DataStream.
|
FlinkFnApi.TypeInfo.AvroTypeInfo
Protobuf type
org.apache.flink.fn_execution.v1.TypeInfo.AvroTypeInfo |
FlinkFnApi.TypeInfo.AvroTypeInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.TypeInfo.AvroTypeInfo |
FlinkFnApi.TypeInfo.AvroTypeInfoOrBuilder |
FlinkFnApi.TypeInfo.Builder
A representation of the data type information in DataStream.
|
FlinkFnApi.TypeInfo.MapTypeInfo
Protobuf type
org.apache.flink.fn_execution.v1.TypeInfo.MapTypeInfo |
FlinkFnApi.TypeInfo.MapTypeInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.TypeInfo.MapTypeInfo |
FlinkFnApi.TypeInfo.MapTypeInfoOrBuilder |
FlinkFnApi.TypeInfo.RowTypeInfo
Protobuf type
org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo |
FlinkFnApi.TypeInfo.RowTypeInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo |
FlinkFnApi.TypeInfo.RowTypeInfo.Field
Protobuf type
org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field |
FlinkFnApi.TypeInfo.RowTypeInfo.Field.Builder
Protobuf type
org.apache.flink.fn_execution.v1.TypeInfo.RowTypeInfo.Field |
FlinkFnApi.TypeInfo.RowTypeInfo.FieldOrBuilder |
FlinkFnApi.TypeInfo.RowTypeInfoOrBuilder |
FlinkFnApi.TypeInfo.TupleTypeInfo
Protobuf type
org.apache.flink.fn_execution.v1.TypeInfo.TupleTypeInfo |
FlinkFnApi.TypeInfo.TupleTypeInfo.Builder
Protobuf type
org.apache.flink.fn_execution.v1.TypeInfo.TupleTypeInfo |
FlinkFnApi.TypeInfo.TupleTypeInfoOrBuilder |
FlinkFnApi.TypeInfo.TypeInfoCase |
FlinkFnApi.TypeInfo.TypeName
Protobuf enum
org.apache.flink.fn_execution.v1.TypeInfo.TypeName |
FlinkFnApi.TypeInfoOrBuilder |
FlinkFnApi.UserDefinedAggregateFunction
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.Builder
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.Builder
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.DataViewCase |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListView
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec.ListView |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListView.Builder
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec.ListView |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListViewOrBuilder |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec.MapView |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction.DataViewSpec.MapView |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapViewOrBuilder |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpecOrBuilder |
FlinkFnApi.UserDefinedAggregateFunctionOrBuilder |
FlinkFnApi.UserDefinedAggregateFunctions
A list of the user-defined aggregate functions to be executed in a group aggregate operation.
|
FlinkFnApi.UserDefinedAggregateFunctions.Builder
A list of the user-defined aggregate functions to be executed in a group aggregate operation.
|
FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder |
FlinkFnApi.UserDefinedDataStreamFunction
User defined DataStream function definition.
|
FlinkFnApi.UserDefinedDataStreamFunction.Builder
User defined DataStream function definition.
|
FlinkFnApi.UserDefinedDataStreamFunction.FunctionType
Protobuf enum
org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.FunctionType |
FlinkFnApi.UserDefinedDataStreamFunction.JobParameter
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.JobParameter |
FlinkFnApi.UserDefinedDataStreamFunction.JobParameter.Builder
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.JobParameter |
FlinkFnApi.UserDefinedDataStreamFunction.JobParameterOrBuilder |
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.RuntimeContext |
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.RuntimeContext |
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder |
FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder |
FlinkFnApi.UserDefinedFunction
User-defined function definition.
|
FlinkFnApi.UserDefinedFunction.Builder
User-defined function definition.
|
FlinkFnApi.UserDefinedFunctionOrBuilder |
FlinkFnApi.UserDefinedFunctions
A list of user-defined functions to be executed in a batch.
|
FlinkFnApi.UserDefinedFunctions.Builder
A list of user-defined functions to be executed in a batch.
|
FlinkFnApi.UserDefinedFunctionsOrBuilder |
Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
FlinkFnApi.CoderInfoDescriptor.Mode
Protobuf enum
org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode |
FlinkFnApi.StateDescriptor.StateTTLConfig
Protobuf type
org.apache.flink.fn_execution.v1.StateDescriptor.StateTTLConfig |
FlinkFnApi.UserDefinedAggregateFunction
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction |
FlinkFnApi.UserDefinedDataStreamFunction
User defined DataStream function definition.
|
FlinkFnApi.UserDefinedFunction
User-defined function definition.
|
FlinkFnApi.UserDefinedFunctions
A list of user-defined functions to be executed in a batch.
|
Class and Description |
---|
FlinkFnApi.UserDefinedDataStreamFunction
User defined DataStream function definition.
|
Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
FlinkFnApi.UserDefinedDataStreamFunction
User defined DataStream function definition.
|
Class and Description |
---|
FlinkFnApi.TypeInfo
A representation of the data type information in DataStream.
|
Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
FlinkFnApi.UserDefinedFunctions
A list of user-defined functions to be executed in a batch.
|
Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
FlinkFnApi.GroupWindow.WindowType
Protobuf enum
org.apache.flink.fn_execution.v1.GroupWindow.WindowType |
FlinkFnApi.UserDefinedAggregateFunctions
A list of the user-defined aggregate functions to be executed in a group aggregate operation.
|
Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
FlinkFnApi.UserDefinedFunctions
A list of user-defined functions to be executed in a batch.
|
Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
FlinkFnApi.UserDefinedFunctions
A list of user-defined functions to be executed in a batch.
|
Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
FlinkFnApi.UserDefinedFunctions
A list of user-defined functions to be executed in a batch.
|
Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
FlinkFnApi.UserDefinedFunctions
A list of user-defined functions to be executed in a batch.
|
Class and Description |
---|
FlinkFnApi.CoderInfoDescriptor
A representation of the coder
|
Class and Description |
---|
FlinkFnApi.Schema.FieldType
Protobuf type
org.apache.flink.fn_execution.v1.Schema.FieldType |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.