Modifier and Type | Class and Description |
---|---|
class |
BatchShuffleMode
Defines how data is exchanged between tasks in batch
ExecutionOptions.RUNTIME_MODE if the
shuffling behavior has not been set explicitly for an individual exchange. |
static class |
ExecutionConfig.ClosureCleanerLevel
Configuration settings for the closure cleaner.
|
Modifier and Type | Class and Description |
---|---|
static class |
ClusterOptions.UserSystemExitMode
The mode of how to handle user code attempting to exit JVM.
|
class |
ExternalizedCheckpointRetention
Cleanup behaviour for externalized checkpoints when the job is cancelled.
|
static class |
JobManagerOptions.SchedulerType
Type of scheduler implementation.
|
static class |
MetricOptions.JobStatusMetrics
Enum describing the different kinds of job status metrics.
|
Modifier and Type | Class and Description |
---|---|
class |
DeliveryGuarantee
DeliverGuarantees that can be chosen.
|
Modifier and Type | Class and Description |
---|---|
static class |
FileSystemConnectorOptions.FileStatisticsType
Statistics types for file system, see
FileSystemConnectorOptions.SOURCE_REPORT_STATISTICS . |
static class |
FileSystemConnectorOptions.PartitionCommitTriggerType
Trigger types for partition commit, see
FileSystemConnectorOptions.SINK_PARTITION_COMMIT_TRIGGER . |
Modifier and Type | Class and Description |
---|---|
static class |
HiveOptions.InferMode
Infer mode used for
HiveOptions.TABLE_EXEC_HIVE_INFER_SOURCE_PARALLELISM_MODE . |
static class |
HiveOptions.PartitionOrder
Partition order used for
HiveOptions.STREAMING_SOURCE_PARTITION_ORDER . |
Modifier and Type | Class and Description |
---|---|
static class |
EmbeddedRocksDBStateBackend.PriorityQueueStateType
The options to chose for the type of priority queue state.
|
Modifier and Type | Class and Description |
---|---|
class |
CheckpointType
Describes the type in which a checkpoint should be taken.
|
class |
RestoreMode
Defines state files ownership when Flink restore from a given savepoint or retained checkpoint.
|
class |
SavepointFormatType
Describes the binary format in which a savepoint should be taken.
|
Modifier and Type | Class and Description |
---|---|
static class |
AvroFormatOptions.AvroEncoding
Serialization types for Avro encoding, see
AvroFormatOptions.AVRO_ENCODING . |
Modifier and Type | Class and Description |
---|---|
static class |
CheckpointConfig.ExternalizedCheckpointCleanup
Deprecated.
This class has been moved to
ExternalizedCheckpointRetention . |
Modifier and Type | Class and Description |
---|---|
static class |
ExecutionConfigOptions.LegacyCastBehaviour
Deprecated.
|
static class |
ExecutionConfigOptions.NotNullEnforcer
The enforcer to guarantee NOT NULL column constraint when writing data into sink.
|
static class |
ExecutionConfigOptions.RowtimeInserter
Rowtime attribute insertion strategy for the sink.
|
static class |
ExecutionConfigOptions.TypeLengthEnforcer
The enforcer to guarantee that length of CHAR/VARCHAR/BINARY/VARBINARY columns is respected
when writing data into a sink.
|
static class |
ExecutionConfigOptions.UidGeneration
Strategy for generating transformation UIDs for remapping state to operators during restore.
|
static class |
TableConfigOptions.CatalogPlanCompilation
Strategy to compile
Catalog objects into a plan. |
static class |
TableConfigOptions.CatalogPlanRestore
Strategy to restore
Catalog objects using the plan and lookups if necessary. |
static class |
TableConfigOptions.ColumnExpansionStrategy
Strategy to expand columns in
SELECT * queries. |
Modifier and Type | Class and Description |
---|---|
class |
ResultMode
The mode when display the result of the query in the sql client.
|
Modifier and Type | Class and Description |
---|---|
static class |
YarnConfigOptions.UserJarInclusion |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.