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.
|
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 |
---|---|
class |
MessageKeyHash
Predefined the available hash function for routing the message.
|
class |
TopicRoutingMode
The routing policy for choosing the desired topic by the given message.
|
Modifier and Type | Class and Description |
---|---|
class |
CursorVerification
The enum class for defining the cursor verify behavior.
|
Modifier and Type | Class and Description |
---|---|
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 |
SavepointFormatType
Describes the binary format in which a savepoint should be taken.
|
Modifier and Type | Class and Description |
---|---|
class |
RestoreMode
Defines how Flink should restore from a given savepoint or retained checkpoint.
|
Modifier and Type | Class and Description |
---|---|
static class |
CheckpointConfig.ExternalizedCheckpointCleanup
Cleanup behaviour for externalized checkpoints when the job is cancelled.
|
Modifier and Type | Class and Description |
---|---|
static class |
KafkaConnectorOptions.ScanStartupMode
Startup mode for the Kafka consumer, see
KafkaConnectorOptions.SCAN_STARTUP_MODE . |
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.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. |
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–2022 The Apache Software Foundation. All rights reserved.