Modifier and Type | Field and Description |
---|---|
static ConfigOption<java.time.Duration> |
ClientOptions.CLIENT_RETRY_PERIOD |
static ConfigOption<java.time.Duration> |
ClientOptions.CLIENT_TIMEOUT |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<List<String>> |
ApplicationConfiguration.APPLICATION_ARGS |
static ConfigOption<String> |
ApplicationConfiguration.APPLICATION_MAIN_CLASS |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
WebOptions.ACCESS_CONTROL_ALLOW_ORIGIN
The config parameter defining the Access-Control-Allow-Origin header for all responses from
the web-frontend.
|
static ConfigOption<String> |
JobManagerOptions.ADDRESS
The config parameter defining the network address to connect to for communication with the
job manager.
|
static ConfigOption<String> |
RestOptions.ADDRESS
The address that should be used by clients to connect to the server.
|
static ConfigOption<String> |
WebOptions.ADDRESS
Deprecated.
|
static ConfigOption<String> |
CoreOptions.ALLOWED_FALLBACK_FILESYSTEMS |
static ConfigOption<String> |
CoreOptions.ALWAYS_PARENT_FIRST_LOADER_PATTERNS
The namespace patterns for classes that are loaded with a preference from the parent
classloader, meaning the application class path, rather than any user code jar file.
|
static ConfigOption<String> |
CoreOptions.ALWAYS_PARENT_FIRST_LOADER_PATTERNS_ADDITIONAL |
static ConfigOption<Integer> |
WebOptions.ARCHIVE_COUNT
The config parameter defining the number of archived jobs for the JobManager.
|
static ConfigOption<String> |
JobManagerOptions.ARCHIVE_DIR
The location where the JobManager stores the archives of completed jobs.
|
static ConfigOption<String> |
AkkaOptions.ASK_TIMEOUT
Timeout for akka ask calls.
|
static ConfigOption<Boolean> |
CheckpointingOptions.ASYNC_SNAPSHOTS
Deprecated.
Checkpoints are aways asynchronous.
|
static ConfigOption<Boolean> |
DeploymentOptions.ATTACHED |
static ConfigOption<Boolean> |
PipelineOptions.AUTO_GENERATE_UIDS |
static ConfigOption<Boolean> |
PipelineOptions.AUTO_TYPE_REGISTRATION |
static ConfigOption<java.time.Duration> |
PipelineOptions.AUTO_WATERMARK_INTERVAL |
static ConfigOption<Long> |
RestOptions.AWAIT_LEADER_TIMEOUT
The time in ms that the client waits for the leader address, e.g., Dispatcher or
WebMonitorEndpoint.
|
static ConfigOption<Integer> |
WebOptions.BACKPRESSURE_CLEANUP_INTERVAL
Deprecated.
- no longer used.
|
static ConfigOption<Integer> |
WebOptions.BACKPRESSURE_DELAY
Deprecated.
- no longer used.
|
static ConfigOption<Integer> |
WebOptions.BACKPRESSURE_NUM_SAMPLES
Deprecated.
- no longer used.
|
static ConfigOption<Integer> |
WebOptions.BACKPRESSURE_REFRESH_INTERVAL
Deprecated.
- no longer used.
|
static ConfigOption<String> |
RestOptions.BIND_ADDRESS
The address that the server binds itself to.
|
static ConfigOption<String> |
JobManagerOptions.BIND_HOST
The local address of the network interface that the job manager binds to.
|
static ConfigOption<String> |
TaskManagerOptions.BIND_HOST
The local address of the network interface that the task manager binds to.
|
static ConfigOption<String> |
RestOptions.BIND_PORT
The port range that the server could bind itself to.
|
static ConfigOption<Boolean> |
NettyShuffleEnvironmentOptions.BLOCKING_SHUFFLE_COMPRESSION_ENABLED
Boolean flag indicating whether the shuffle data will be compressed for blocking shuffle
mode.
|
static ConfigOption<java.time.Duration> |
ExecutionOptions.BUFFER_TIMEOUT |
static ConfigOption<List<String>> |
PipelineOptions.CACHED_FILES |
static ConfigOption<Boolean> |
AkkaOptions.CAPTURE_ASK_CALLSTACK
Flag whether to capture call stacks for RPC ask calls.
|
static ConfigOption<Boolean> |
CoreOptions.CHECK_LEAKED_CLASSLOADER |
static ConfigOption<String> |
CheckpointingOptions.CHECKPOINT_STORAGE
The checkpoint storage used to checkpoint state for recovery.
|
static ConfigOption<String> |
CheckpointingOptions.CHECKPOINTS_DIRECTORY
The default directory used for storing the data files and meta data of checkpoints in a Flink
supported filesystem.
|
static ConfigOption<Integer> |
WebOptions.CHECKPOINTS_HISTORY_SIZE
Config parameter defining the number of checkpoints to remember for recent history.
|
static ConfigOption<String> |
CoreOptions.CLASSLOADER_RESOLVE_ORDER
Defines the class resolution strategy when loading classes from user code, meaning whether to
first check the user code jar (
"child-first" ) or the application classpath ("parent-first" ) |
static ConfigOption<List<String>> |
PipelineOptions.CLASSPATHS
A list of URLs that are added to the classpath of each user code classloader of the program.
|
static ConfigOption<Long> |
BlobServerOptions.CLEANUP_INTERVAL
Cleanup interval of the blob caches at the task managers (in seconds).
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.CLIENT_CONNECT_TIMEOUT_SECONDS |
static ConfigOption<Integer> |
RestOptions.CLIENT_MAX_CONTENT_LENGTH
The maximum content length that the client will handle.
|
static ConfigOption<Integer> |
QueryableStateOptions.CLIENT_NETWORK_THREADS
Number of network (event loop) threads for the KvState client (0 => Use number of available
cores).
|
static ConfigOption<Double> |
AkkaOptions.CLIENT_SOCKET_WORKER_POOL_SIZE_FACTOR |
static ConfigOption<Integer> |
AkkaOptions.CLIENT_SOCKET_WORKER_POOL_SIZE_MAX |
static ConfigOption<Integer> |
AkkaOptions.CLIENT_SOCKET_WORKER_POOL_SIZE_MIN |
static ConfigOption<String> |
AkkaOptions.CLIENT_TIMEOUT
Deprecated.
Use the
ClientOptions.CLIENT_TIMEOUT instead. |
static ConfigOption<ExecutionConfig.ClosureCleanerLevel> |
PipelineOptions.CLOSURE_CLEANER_LEVEL |
static ConfigOption<Integer> |
ClusterOptions.CLUSTER_IO_EXECUTOR_POOL_SIZE |
static ConfigOption<Long> |
ClusterOptions.CLUSTER_SERVICES_SHUTDOWN_TIMEOUT |
static ConfigOption<String> |
DeploymentOptionsInternal.CONF_DIR |
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.CONNECT_BACKLOG |
static ConfigOption<Integer> |
BlobServerOptions.CONNECT_TIMEOUT
The connection timeout in milliseconds for the blob client.
|
static ConfigOption<Long> |
RestOptions.CONNECTION_TIMEOUT
The maximum time in ms for the client to establish a TCP connection.
|
static ConfigOption<Double> |
TaskManagerOptions.CPU_CORES
This config option describes number of cpu cores of task executors.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.DATA_BIND_PORT
The local network port that the task manager listen at for data exchange.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.DATA_PORT
The default network port the task manager expects to receive transfer envelopes on.
|
static ConfigOption<Boolean> |
NettyShuffleEnvironmentOptions.DATA_SSL_ENABLED
Config parameter to override SSL support for taskmanager's data transport.
|
static ConfigOption<Boolean> |
TaskManagerOptions.DEBUG_MEMORY_LOG |
static ConfigOption<Long> |
TaskManagerOptions.DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS |
static ConfigOption<String> |
CoreOptions.DEFAULT_FILESYSTEM_SCHEME
The default filesystem scheme, used for paths that do not declare a scheme explicitly.
|
static ConfigOption<String> |
ConfigConstants.DEFAULT_JOB_MANAGER_WEB_FRONTEND_ADDRESS
Deprecated.
use
WebOptions.ADDRESS instead |
static ConfigOption<Integer> |
CoreOptions.DEFAULT_PARALLELISM |
static ConfigOption<Integer> |
OptimizerOptions.DELIMITED_FORMAT_MAX_LINE_SAMPLES
The maximum number of line samples taken by the compiler for delimited inputs.
|
static ConfigOption<Integer> |
OptimizerOptions.DELIMITED_FORMAT_MAX_SAMPLE_LEN
The maximal length of a line sample that the compiler takes for delimited inputs.
|
static ConfigOption<Integer> |
OptimizerOptions.DELIMITED_FORMAT_MIN_LINE_SAMPLES
The minimum number of line samples taken by the compiler for delimited inputs.
|
static ConfigOption<Integer> |
AkkaOptions.DISPATCHER_THROUGHPUT
Maximum number of messages until another actor is executed by the same thread.
|
static ConfigOption<Boolean> |
ClusterOptions.ENABLE_DECLARATIVE_RESOURCE_MANAGEMENT |
static ConfigOption<Boolean> |
ClusterOptions.ENABLE_FINE_GRAINED_RESOURCE_MANAGEMENT |
static ConfigOption<Boolean> |
RestOptions.ENABLE_FLAMEGRAPH
Enables the experimental flame graph feature.
|
static ConfigOption<Boolean> |
QueryableStateOptions.ENABLE_QUERYABLE_STATE_PROXY_SERVER
Option whether the queryable state proxy and server should be enabled where possible and
configurable.
|
static ConfigOption<Boolean> |
CheckpointingOptions.ENABLE_STATE_CHANGE_LOG
Whether to enable state change log.
|
static ConfigOption<Long> |
ClusterOptions.ERROR_REGISTRATION_DELAY |
static ConfigOption<Boolean> |
ClusterOptions.EVENLY_SPREAD_OUT_SLOTS_STRATEGY |
static ConfigOption<String> |
JobManagerOptions.EXECUTION_FAILOVER_STRATEGY
This option specifies the failover strategy, i.e.
|
static ConfigOption<Boolean> |
TaskManagerOptions.EXIT_ON_FATAL_AKKA_ERROR
Deprecated.
|
static ConfigOption<Long> |
ExternalResourceOptions.EXTERNAL_RESOURCE_AMOUNT
The amount for the external resource specified by >resource_name< per TaskExecutor.
|
static ConfigOption<String> |
ExternalResourceOptions.EXTERNAL_RESOURCE_DRIVER_FACTORY_CLASS
Defines the factory class name for the external resource identified by >resource_name<.
|
static ConfigOption<String> |
ExternalResourceOptions.EXTERNAL_RESOURCE_DRIVER_PARAM
The naming pattern of custom config options for the external resource specified by
>resource_name<.
|
static ConfigOption<List<String>> |
ExternalResourceOptions.EXTERNAL_RESOURCE_LIST
List of the resource_name of all external resources with delimiter ";", e.g.
|
static ConfigOption<Boolean> |
CoreOptions.FAIL_ON_USER_CLASS_LOADING_METASPACE_OOM |
static ConfigOption<Integer> |
BlobServerOptions.FETCH_BACKLOG
The config parameter defining the backlog of BLOB fetches on the JobManager.
|
static ConfigOption<Integer> |
BlobServerOptions.FETCH_CONCURRENT
The config parameter defining the maximum number of concurrent BLOB fetches that the
JobManager serves.
|
static ConfigOption<Integer> |
BlobServerOptions.FETCH_RETRIES
The config parameter defining number of retires for failed BLOB fetches.
|
static ConfigOption<Boolean> |
CoreOptions.FILESYSTEM_OUTPUT_ALWAYS_CREATE_DIRECTORY
Specifies whether the file systems should always create a directory for the output, even with
a parallelism of one.
|
static ConfigOption<Boolean> |
CoreOptions.FILESYTEM_DEFAULT_OVERRIDE
Specifies whether file output writers should overwrite existing files by default.
|
static ConfigOption<java.time.Duration> |
RestOptions.FLAMEGRAPH_CLEANUP_INTERVAL
"Time after which cached stats are cleaned up if not accessed.
|
static ConfigOption<java.time.Duration> |
RestOptions.FLAMEGRAPH_DELAY
Delay between individual stack trace samples taken for building a FlameGraph.
|
static ConfigOption<Integer> |
RestOptions.FLAMEGRAPH_NUM_SAMPLES
Number of samples to take to build a FlameGraph.
|
static ConfigOption<java.time.Duration> |
RestOptions.FLAMEGRAPH_REFRESH_INTERVAL
Time after which available stats are deprecated and need to be refreshed (by resampling).
|
static ConfigOption<Integer> |
RestOptions.FLAMEGRAPH_STACK_TRACE_DEPTH
Maximum depth of stack traces used to create FlameGraphs.
|
static ConfigOption<String> |
CoreOptions.FLINK_CLI_JVM_OPTIONS |
static ConfigOption<String> |
CoreOptions.FLINK_HADOOP_CONF_DIR
This options is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<String> |
CoreOptions.FLINK_HBASE_CONF_DIR
This options is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<String> |
CoreOptions.FLINK_HS_JVM_OPTIONS |
static ConfigOption<String> |
CoreOptions.FLINK_JM_JVM_OPTIONS |
static ConfigOption<String> |
CoreOptions.FLINK_JVM_OPTIONS |
static ConfigOption<String> |
CoreOptions.FLINK_LOG_DIR
This options is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<Integer> |
CoreOptions.FLINK_LOG_MAX
This options is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<String> |
CoreOptions.FLINK_PID_DIR
The config parameter defining the directory for Flink PID file.
|
static ConfigOption<String> |
CoreOptions.FLINK_SSH_OPTIONS
This options is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<String> |
CoreOptions.FLINK_TM_JVM_OPTIONS |
static ConfigOption<String> |
CoreOptions.FLINK_YARN_CONF_DIR
This options is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<Boolean> |
PipelineOptions.FORCE_AVRO |
static ConfigOption<Boolean> |
PipelineOptions.FORCE_KRYO |
static ConfigOption<Double> |
AkkaOptions.FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR |
static ConfigOption<Integer> |
AkkaOptions.FORK_JOIN_EXECUTOR_PARALLELISM_MAX |
static ConfigOption<Integer> |
AkkaOptions.FORK_JOIN_EXECUTOR_PARALLELISM_MIN |
static ConfigOption<String> |
AkkaOptions.FRAMESIZE
Maximum framesize of akka messages.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.FRAMEWORK_HEAP_MEMORY
Framework Heap Memory size for TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.FRAMEWORK_OFF_HEAP_MEMORY
Framework Off-Heap Memory size for TaskExecutors.
|
static ConfigOption<MemorySize> |
CheckpointingOptions.FS_SMALL_FILE_THRESHOLD
The minimum size of state data files.
|
static ConfigOption<Integer> |
CheckpointingOptions.FS_WRITE_BUFFER_SIZE
The default size of the write buffer for the checkpoint streams that write to file systems.
|
static ConfigOption<Boolean> |
PipelineOptions.GENERIC_TYPES |
static ConfigOption<Map<String,String>> |
PipelineOptions.GLOBAL_JOB_PARAMETERS |
static ConfigOption<String> |
HighAvailabilityOptions.HA_CLUSTER_ID
The ID of the Flink cluster, used to separate multiple Flink clusters Needs to be set for
standalone clusters, is automatically inferred in YARN and Mesos.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_JOB_DELAY
Deprecated.
Don't use this option anymore. It has no effect on Flink.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_JOB_MANAGER_PORT_RANGE
Optional port (range) used by the job manager in high-availability mode.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_MODE
Defines high-availability mode used for the cluster execution.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_STORAGE_PATH
File system path (URI) where Flink persists metadata in high-availability setups.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH
ZooKeeper root path (ZNode) for checkpoint counters.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_CHECKPOINTS_PATH
ZooKeeper root path (ZNode) for completed checkpoints.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_JOBGRAPHS_PATH
ZooKeeper root path (ZNode) for job graphs.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_LATCH_PATH |
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_LEADER_PATH |
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_MESOS_WORKERS_PATH
ZooKeeper root path (ZNode) for Mesos workers.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_QUORUM
The ZooKeeper quorum to use, when running Flink in a high-availability mode with ZooKeeper.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_ROOT
The root path under which Flink stores its entries in ZooKeeper.
|
static ConfigOption<Boolean> |
ClusterOptions.HALT_ON_FATAL_ERROR |
static ConfigOption<Boolean> |
AlgorithmOptions.HASH_JOIN_BLOOM_FILTERS |
static ConfigOption<Long> |
HeartbeatManagerOptions.HEARTBEAT_INTERVAL
Time interval for requesting heartbeat from sender side.
|
static ConfigOption<Long> |
HeartbeatManagerOptions.HEARTBEAT_TIMEOUT
Timeout for requesting and receiving heartbeat for both sender and receiver sides.
|
static ConfigOption<String> |
HistoryServerOptions.HISTORY_SERVER_ARCHIVE_DIRS
Comma-separated list of directories which the HistoryServer polls for new archives.
|
static ConfigOption<Long> |
HistoryServerOptions.HISTORY_SERVER_ARCHIVE_REFRESH_INTERVAL
The interval at which the HistoryServer polls
HistoryServerOptions.HISTORY_SERVER_ARCHIVE_DIRS for new archives. |
static ConfigOption<Boolean> |
HistoryServerOptions.HISTORY_SERVER_CLEANUP_EXPIRED_JOBS
If this option is enabled then deleted job archives are also deleted from HistoryServer.
|
static ConfigOption<Integer> |
HistoryServerOptions.HISTORY_SERVER_RETAINED_JOBS |
static ConfigOption<String> |
HistoryServerOptions.HISTORY_SERVER_WEB_ADDRESS
The address under which the HistoryServer web-frontend is accessible.
|
static ConfigOption<String> |
HistoryServerOptions.HISTORY_SERVER_WEB_DIR
The local directory used by the HistoryServer web-frontend.
|
static ConfigOption<Integer> |
HistoryServerOptions.HISTORY_SERVER_WEB_PORT
The port under which the HistoryServer web-frontend is accessible.
|
static ConfigOption<Long> |
HistoryServerOptions.HISTORY_SERVER_WEB_REFRESH_INTERVAL
The refresh interval for the HistoryServer web-frontend in milliseconds.
|
static ConfigOption<Boolean> |
HistoryServerOptions.HISTORY_SERVER_WEB_SSL_ENABLED
Enables/Disables SSL support for the HistoryServer web-frontend.
|
static ConfigOption<String> |
TaskManagerOptions.HOST
The external address of the network interface where the TaskManager is exposed.
|
static ConfigOption<String> |
TaskManagerOptions.HOST_BIND_POLICY
The config parameter for automatically defining the TaskManager's binding address, if
TaskManagerOptions.HOST configuration option is not set. |
static ConfigOption<Long> |
RestOptions.IDLENESS_TIMEOUT
The maximum time in ms for a connection to stay idle before failing.
|
static ConfigOption<Boolean> |
CheckpointingOptions.INCREMENTAL_CHECKPOINTS
Option whether the state backend should create incremental checkpoints, if possible.
|
static ConfigOption<java.time.Duration> |
TaskManagerOptions.INITIAL_REGISTRATION_BACKOFF
Deprecated.
use
ClusterOptions.INITIAL_REGISTRATION_TIMEOUT instead |
static ConfigOption<Long> |
ClusterOptions.INITIAL_REGISTRATION_TIMEOUT |
static ConfigOption<ClusterOptions.UserSystemExitMode> |
ClusterOptions.INTERCEPT_USER_SYSTEM_EXIT |
static ConfigOption<Integer> |
ResourceManagerOptions.IPC_PORT
Defines the network port to connect to for communication with the resource manager.
|
static ConfigOption<List<String>> |
PipelineOptions.JARS
A list of jar files that contain the user-defined function (UDF) classes and all classes used
from within the UDFs.
|
static ConfigOption<String> |
JMXServerOptions.JMX_SERVER_PORT
Port configured to enable JMX server for metrics and debugging.
|
static ConfigOption<List<String>> |
DeploymentOptions.JOB_LISTENERS |
static ConfigOption<MemorySize> |
JobManagerOptions.JOB_MANAGER_HEAP_MEMORY
Deprecated.
use
JobManagerOptions.TOTAL_FLINK_MEMORY for standalone setups and JobManagerOptions.TOTAL_PROCESS_MEMORY for containerized setups. |
static ConfigOption<Integer> |
JobManagerOptions.JOB_MANAGER_HEAP_MEMORY_MB
Deprecated.
use
JobManagerOptions.TOTAL_FLINK_MEMORY for standalone setups and JobManagerOptions.TOTAL_PROCESS_MEMORY for containerized setups. |
static ConfigOption<Long> |
JobManagerOptions.JOB_STORE_CACHE_SIZE
The job store cache size in bytes which is used to keep completed jobs in memory.
|
static ConfigOption<Long> |
JobManagerOptions.JOB_STORE_EXPIRATION_TIME
The time in seconds after which a completed job expires and is purged from the job store.
|
static ConfigOption<Integer> |
JobManagerOptions.JOB_STORE_MAX_CAPACITY
The max number of completed jobs that can be kept in the job store.
|
static ConfigOption<String> |
ResourceManagerOptions.JOB_TIMEOUT
Timeout for jobs which don't have a job manager as leader assigned.
|
static ConfigOption<Boolean> |
JobManagerOptions.JVM_DIRECT_MEMORY_LIMIT_ENABLED
Off-heap Memory size for the JobManager.
|
static ConfigOption<Boolean> |
AkkaOptions.JVM_EXIT_ON_FATAL_ERROR
Exit JVM on fatal Akka errors.
|
static ConfigOption<MemorySize> |
JobManagerOptions.JVM_HEAP_MEMORY
JVM Heap Memory size for the JobManager.
|
static ConfigOption<MemorySize> |
JobManagerOptions.JVM_METASPACE
JVM Metaspace Size for the JobManager.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.JVM_METASPACE
JVM Metaspace Size for the TaskExecutors.
|
static ConfigOption<Float> |
JobManagerOptions.JVM_OVERHEAD_FRACTION
Fraction of Total Process Memory to be reserved for JVM Overhead.
|
static ConfigOption<Float> |
TaskManagerOptions.JVM_OVERHEAD_FRACTION
Fraction of Total Process Memory to be reserved for JVM Overhead.
|
static ConfigOption<MemorySize> |
JobManagerOptions.JVM_OVERHEAD_MAX
Max JVM Overhead size for the TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.JVM_OVERHEAD_MAX
Max JVM Overhead size for the TaskExecutors.
|
static ConfigOption<MemorySize> |
JobManagerOptions.JVM_OVERHEAD_MIN
Min JVM Overhead size for the JobManager.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.JVM_OVERHEAD_MIN
Min JVM Overhead size for the TaskExecutors.
|
static ConfigOption<String> |
SecurityOptions.KERBEROS_KRB5_PATH |
static ConfigOption<String> |
SecurityOptions.KERBEROS_LOGIN_CONTEXTS |
static ConfigOption<String> |
SecurityOptions.KERBEROS_LOGIN_KEYTAB |
static ConfigOption<String> |
SecurityOptions.KERBEROS_LOGIN_PRINCIPAL |
static ConfigOption<Boolean> |
SecurityOptions.KERBEROS_LOGIN_USETICKETCACHE |
static ConfigOption<Boolean> |
TaskManagerOptions.KILL_ON_OUT_OF_MEMORY
Whether to kill the TaskManager when the task thread throws an OutOfMemoryError.
|
static ConfigOption<List<String>> |
PipelineOptions.KRYO_DEFAULT_SERIALIZERS |
static ConfigOption<List<String>> |
PipelineOptions.KRYO_REGISTERED_CLASSES |
static ConfigOption<Integer> |
MetricOptions.LATENCY_HISTORY_SIZE
The number of measured latencies to maintain at each operator.
|
static ConfigOption<Long> |
MetricOptions.LATENCY_INTERVAL |
static ConfigOption<String> |
MetricOptions.LATENCY_SOURCE_GRANULARITY |
static ConfigOption<Boolean> |
StateBackendOptions.LATENCY_TRACK_ENABLED |
static ConfigOption<Integer> |
StateBackendOptions.LATENCY_TRACK_HISTORY_SIZE |
static ConfigOption<Integer> |
StateBackendOptions.LATENCY_TRACK_SAMPLE_INTERVAL |
static ConfigOption<Boolean> |
StateBackendOptions.LATENCY_TRACK_STATE_NAME_AS_VARIABLE |
static ConfigOption<Integer> |
ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER
Deprecated.
|
static ConfigOption<Boolean> |
CheckpointingOptions.LOCAL_RECOVERY
This option configures local recovery for this state backend.
|
static ConfigOption<String> |
CheckpointingOptions.LOCAL_RECOVERY_TASK_MANAGER_STATE_ROOT_DIRS
The config parameter defining the root directories for storing file-based state for local
recovery.
|
static ConfigOption<Boolean> |
AkkaOptions.LOG_LIFECYCLE_EVENTS
Log lifecycle events.
|
static ConfigOption<String> |
WebOptions.LOG_PATH
The log file location (may be in /log for standalone but under log directory when using
YARN).
|
static ConfigOption<String> |
AkkaOptions.LOOKUP_TIMEOUT
Timeout for all blocking calls that look up remote actors.
|
static ConfigOption<Map<String,String>> |
TaskManagerOptions.MANAGED_MEMORY_CONSUMER_WEIGHTS
Weights of managed memory consumers.
|
static ConfigOption<Float> |
TaskManagerOptions.MANAGED_MEMORY_FRACTION
Fraction of Total Flink Memory to be used as Managed Memory, if
TaskManagerOptions.MANAGED_MEMORY_SIZE
is not specified. |
static ConfigOption<MemorySize> |
TaskManagerOptions.MANAGED_MEMORY_SIZE
Managed Memory size for TaskExecutors.
|
static ConfigOption<Integer> |
JobManagerOptions.MAX_ATTEMPTS_HISTORY_SIZE
The maximum number of prior execution attempts kept in history.
|
static ConfigOption<Integer> |
WebOptions.MAX_EXCEPTION_HISTORY_SIZE
The maximum number of failures kept in the exception history.
|
static ConfigOption<Integer> |
PipelineOptions.MAX_PARALLELISM |
static ConfigOption<Long> |
ClusterOptions.MAX_REGISTRATION_TIMEOUT |
static ConfigOption<Integer> |
CheckpointingOptions.MAX_RETAINED_CHECKPOINTS
The maximum number of completed checkpoints to retain.
|
static ConfigOption<Integer> |
ResourceManagerOptions.MAX_SLOT_NUM |
static ConfigOption<Double> |
ResourceManagerOptions.MAX_TOTAL_CPU |
static ConfigOption<MemorySize> |
ResourceManagerOptions.MAX_TOTAL_MEM |
static ConfigOption<MemorySize> |
TaskManagerOptions.MEMORY_SEGMENT_SIZE
Size of memory buffers used by the network stack and the memory manager.
|
static ConfigOption<Long> |
MetricOptions.METRIC_FETCHER_UPDATE_INTERVAL
The config parameter defining the update interval for the metric fetcher used by the web UI
in milliseconds.
|
static ConfigOption<Integer> |
JobManagerOptions.MIN_PARALLELISM_INCREASE |
static ConfigOption<String> |
PipelineOptions.NAME
The job name used for printing and logging.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.NETWORK_BATCH_SHUFFLE_READ_MEMORY
Size of direct memory used by blocking shuffle for shuffle data read (currently only used by
sort-merge shuffle).
|
static ConfigOption<String> |
NettyShuffleEnvironmentOptions.NETWORK_BLOCKING_SHUFFLE_TYPE |
static ConfigOption<Float> |
NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_MEMORY_FRACTION
Deprecated.
use
TaskManagerOptions.NETWORK_MEMORY_FRACTION instead |
static ConfigOption<String> |
NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_MEMORY_MAX
Deprecated.
use
TaskManagerOptions.NETWORK_MEMORY_MAX instead |
static ConfigOption<String> |
NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_MEMORY_MIN
Deprecated.
use
TaskManagerOptions.NETWORK_MEMORY_MIN instead |
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_PER_CHANNEL
Number of network buffers to use for each outgoing/incoming channel (subpartition/input
channel).
|
static ConfigOption<Boolean> |
NettyShuffleEnvironmentOptions.NETWORK_DETAILED_METRICS
Boolean flag to enable/disable more detailed metrics about inbound/outbound network queue
lengths.
|
static ConfigOption<Long> |
NettyShuffleEnvironmentOptions.NETWORK_EXCLUSIVE_BUFFERS_REQUEST_TIMEOUT_MILLISECONDS
The timeout for requesting exclusive buffers for each channel.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_EXTRA_BUFFERS_PER_GATE
Number of extra network buffers to use for each outgoing/incoming gate (result
partition/input gate).
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_MAX_BUFFERS_PER_CHANNEL
Number of max buffers can be used for each output subparition.
|
static ConfigOption<Float> |
TaskManagerOptions.NETWORK_MEMORY_FRACTION
Fraction of Total Flink Memory to be used as Network Memory.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.NETWORK_MEMORY_MAX
Max Network Memory size for TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.NETWORK_MEMORY_MIN
Min Network Memory size for TaskExecutors.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_NUM_BUFFERS
Deprecated.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_REQUEST_BACKOFF_INITIAL
Minimum backoff for partition requests of input channels.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_REQUEST_BACKOFF_MAX
Maximum backoff for partition requests of input channels.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_RETRIES |
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_SORT_SHUFFLE_MIN_BUFFERS
Minimum number of network buffers required per sort-merge blocking result partition.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_SORT_SHUFFLE_MIN_PARALLELISM
Parallelism threshold to switch between sort-merge based blocking shuffle and the default
hash-based blocking shuffle.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NUM_ARENAS |
static ConfigOption<Integer> |
TaskManagerOptions.NUM_TASK_SLOTS
The config parameter defining the number of task slots of a task manager.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NUM_THREADS_CLIENT |
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NUM_THREADS_SERVER |
static ConfigOption<Boolean> |
PipelineOptions.OBJECT_REUSE |
static ConfigOption<MemorySize> |
JobManagerOptions.OFF_HEAP_MEMORY
Off-heap Memory size for the JobManager.
|
static ConfigOption<Integer> |
BlobServerOptions.OFFLOAD_MINSIZE
The minimum size for messages to be offloaded to the BlobServer.
|
static ConfigOption<Boolean> |
PipelineOptions.OPERATOR_CHAINING |
static ConfigOption<Boolean> |
JobManagerOptions.PARTITION_RELEASE_DURING_JOB_EXECUTION
Config parameter controlling whether partitions should already be released during the job
execution.
|
static ConfigOption<String> |
PipelineOptionsInternal.PIPELINE_FIXED_JOB_ID |
static ConfigOption<String> |
CoreOptions.PLUGIN_ALWAYS_PARENT_FIRST_LOADER_PATTERNS
Plugin-specific option of
CoreOptions.ALWAYS_PARENT_FIRST_LOADER_PATTERNS . |
static ConfigOption<String> |
CoreOptions.PLUGIN_ALWAYS_PARENT_FIRST_LOADER_PATTERNS_ADDITIONAL |
static ConfigOption<List<String>> |
PipelineOptions.POJO_REGISTERED_CLASSES |
static ConfigOption<Integer> |
JobManagerOptions.PORT
The config parameter defining the network port to connect to for communication with the job
manager.
|
static ConfigOption<String> |
BlobServerOptions.PORT
The config parameter defining the server port of the blob service.
|
static ConfigOption<Integer> |
RestOptions.PORT
The port that the REST client connects to and the REST server binds to if
RestOptions.BIND_PORT
has not been specified. |
static ConfigOption<Integer> |
WebOptions.PORT
Deprecated.
Use
RestOptions.PORT instead |
static ConfigOption<Integer> |
QueryableStateOptions.PROXY_ASYNC_QUERY_THREADS
Number of async query threads for the client proxy (0 => #slots).
|
static ConfigOption<Integer> |
QueryableStateOptions.PROXY_NETWORK_THREADS
Number of network (event loop) threads for the client proxy (0 => #slots).
|
static ConfigOption<String> |
QueryableStateOptions.PROXY_PORT_RANGE
The config parameter defining the server port range of the queryable state proxy.
|
static ConfigOption<String> |
MetricOptions.QUERY_SERVICE_PORT
The default network port range for Flink's internal metric query service.
|
static ConfigOption<Integer> |
MetricOptions.QUERY_SERVICE_THREAD_PRIORITY
The thread priority for Flink's internal metric query service.
|
static ConfigOption<Integer> |
ResourceManagerOptions.REDUNDANT_TASK_MANAGER_NUM
The number of redundant task managers.
|
static ConfigOption<Long> |
WebOptions.REFRESH_INTERVAL
The config parameter defining the refresh interval for the web-frontend in milliseconds.
|
static ConfigOption<java.time.Duration> |
TaskManagerOptions.REFUSED_REGISTRATION_BACKOFF
Deprecated.
use
ClusterOptions.REFUSED_REGISTRATION_DELAY instead |
static ConfigOption<Long> |
ClusterOptions.REFUSED_REGISTRATION_DELAY |
static ConfigOption<java.time.Duration> |
TaskManagerOptions.REGISTRATION_MAX_BACKOFF
Deprecated.
use
ClusterOptions.MAX_REGISTRATION_TIMEOUT instead |
static ConfigOption<java.time.Duration> |
TaskManagerOptions.REGISTRATION_TIMEOUT
Defines the timeout it can take for the TaskManager registration.
|
static ConfigOption<String> |
MetricOptions.REPORTER_CLASS |
static ConfigOption<String> |
MetricOptions.REPORTER_CONFIG_PARAMETER |
static ConfigOption<java.time.Duration> |
MetricOptions.REPORTER_INTERVAL |
static ConfigOption<String> |
MetricOptions.REPORTERS_LIST
An optional list of reporter names.
|
static ConfigOption<java.time.Duration> |
JobManagerOptions.RESOURCE_STABILIZATION_TIMEOUT |
static ConfigOption<java.time.Duration> |
JobManagerOptions.RESOURCE_WAIT_TIMEOUT |
static ConfigOption<String> |
RestartStrategyOptions.RESTART_STRATEGY |
static ConfigOption<Double> |
RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_BACKOFF_MULTIPLIER |
static ConfigOption<java.time.Duration> |
RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_INITIAL_BACKOFF |
static ConfigOption<Double> |
RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_JITTER_FACTOR |
static ConfigOption<java.time.Duration> |
RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_MAX_BACKOFF |
static ConfigOption<java.time.Duration> |
RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_RESET_BACKOFF_THRESHOLD |
static ConfigOption<java.time.Duration> |
RestartStrategyOptions.RESTART_STRATEGY_FAILURE_RATE_DELAY |
static ConfigOption<java.time.Duration> |
RestartStrategyOptions.RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL |
static ConfigOption<Integer> |
RestartStrategyOptions.RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL |
static ConfigOption<Integer> |
RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS |
static ConfigOption<String> |
ConfigConstants.RESTART_STRATEGY_FIXED_DELAY_DELAY
Deprecated.
|
static ConfigOption<java.time.Duration> |
RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_DELAY |
static ConfigOption<Boolean> |
JobManagerOptions.RETRIEVE_TASK_MANAGER_HOSTNAME
Flag indicating whether JobManager would retrieve canonical host name of TaskManager during
registration.
|
static ConfigOption<Long> |
RestOptions.RETRY_DELAY
The time in ms that the client waits between retries.
|
static ConfigOption<Long> |
AkkaOptions.RETRY_GATE_CLOSED_FOR
Milliseconds a gate should be closed for after a remote connection was disconnected.
|
static ConfigOption<Integer> |
RestOptions.RETRY_MAX_ATTEMPTS
The number of retries the client will attempt if a retryable operations fails.
|
static ConfigOption<Integer> |
JobManagerOptions.RPC_BIND_PORT
The local port that the job manager binds to.
|
static ConfigOption<Integer> |
TaskManagerOptions.RPC_BIND_PORT
The local port that the task manager binds to.
|
static ConfigOption<String> |
TaskManagerOptions.RPC_PORT
The default network port range the task manager expects incoming IPC connections.
|
static ConfigOption<RuntimeExecutionMode> |
ExecutionOptions.RUNTIME_MODE |
static ConfigOption<String> |
CheckpointingOptions.SAVEPOINT_DIRECTORY
The default directory for savepoints.
|
static ConfigOption<JobManagerOptions.SchedulerType> |
JobManagerOptions.SCHEDULER
Config parameter determining the scheduler implementation.
|
static ConfigOption<SchedulerExecutionMode> |
JobManagerOptions.SCHEDULER_MODE |
static ConfigOption<String> |
MetricOptions.SCOPE_DELIMITER
The delimiter used to assemble the metric identifier.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_JM
The scope format string that is applied to all metrics scoped to a JobManager.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_JM_JOB
The scope format string that is applied to all metrics scoped to a job on a JobManager.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_OPERATOR
The scope format string that is applied to all metrics scoped to an operator.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_TASK
The scope format string that is applied to all metrics scoped to a task.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_TM
The scope format string that is applied to all metrics scoped to a TaskManager.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_TM_JOB
The scope format string that is applied to all metrics scoped to a job on a TaskManager.
|
static ConfigOption<List<String>> |
SecurityOptions.SECURITY_CONTEXT_FACTORY_CLASSES |
static ConfigOption<List<String>> |
SecurityOptions.SECURITY_MODULE_FACTORY_CLASSES |
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.SEND_RECEIVE_BUFFER_SIZE |
static ConfigOption<Integer> |
QueryableStateOptions.SERVER_ASYNC_QUERY_THREADS
Number of async query threads for the KvStateServerHandler (0 => #slots).
|
static ConfigOption<Integer> |
RestOptions.SERVER_MAX_CONTENT_LENGTH
The maximum content length that the server will handle.
|
static ConfigOption<Integer> |
QueryableStateOptions.SERVER_NETWORK_THREADS
Number of network (event loop) threads for the KvState server (0 => #slots).
|
static ConfigOption<Integer> |
RestOptions.SERVER_NUM_THREADS |
static ConfigOption<String> |
QueryableStateOptions.SERVER_PORT_RANGE
The config parameter defining the server port range of the queryable state server.
|
static ConfigOption<Double> |
AkkaOptions.SERVER_SOCKET_WORKER_POOL_SIZE_FACTOR |
static ConfigOption<Integer> |
AkkaOptions.SERVER_SOCKET_WORKER_POOL_SIZE_MAX |
static ConfigOption<Integer> |
AkkaOptions.SERVER_SOCKET_WORKER_POOL_SIZE_MIN |
static ConfigOption<Integer> |
RestOptions.SERVER_THREAD_PRIORITY |
static ConfigOption<String> |
NettyShuffleEnvironmentOptions.SHUFFLE_COMPRESSION_CODEC
The codec to be used when compressing shuffle data.
|
static ConfigOption<Boolean> |
DeploymentOptions.SHUTDOWN_IF_ATTACHED |
static ConfigOption<Long> |
JobManagerOptions.SLOT_IDLE_TIMEOUT
The timeout in milliseconds for a idle slot in Slot Pool.
|
static ConfigOption<Long> |
ResourceManagerOptions.SLOT_MANAGER_TASK_MANAGER_TIMEOUT
Deprecated.
|
static ConfigOption<Long> |
JobManagerOptions.SLOT_REQUEST_TIMEOUT
The timeout in milliseconds for requesting a slot from Slot Pool.
|
static ConfigOption<Long> |
ResourceManagerOptions.SLOT_REQUEST_TIMEOUT
Deprecated.
|
static ConfigOption<java.time.Duration> |
TaskManagerOptions.SLOT_TIMEOUT
Timeout for identifying inactive slots.
|
static ConfigOption<Boolean> |
ExecutionOptions.SNAPSHOT_COMPRESSION
Should be moved to
ExecutionCheckpointingOptions along with ExecutionConfig#useSnapshotCompression , which should be put into CheckpointConfig . |
static ConfigOption<Integer> |
BlobServerOptions.SO_TIMEOUT
The socket timeout in milliseconds for the blob client.
|
static ConfigOption<Boolean> |
ExecutionOptions.SORT_INPUTS |
static ConfigOption<Float> |
AlgorithmOptions.SORT_SPILLING_THRESHOLD |
static ConfigOption<Integer> |
AlgorithmOptions.SPILLING_MAX_FAN |
static ConfigOption<String> |
SecurityOptions.SSL_ALGORITHMS
The standard SSL algorithms to be supported.
|
static ConfigOption<Boolean> |
AkkaOptions.SSL_ENABLED
Override SSL support for the Akka transport.
|
static ConfigOption<Boolean> |
BlobServerOptions.SSL_ENABLED
Flag to override ssl support for the blob service transport.
|
static ConfigOption<Boolean> |
WebOptions.SSL_ENABLED
Deprecated.
|
static ConfigOption<Boolean> |
SecurityOptions.SSL_ENABLED
Deprecated.
Use
SecurityOptions.SSL_INTERNAL_ENABLED and SecurityOptions.SSL_REST_ENABLED instead. |
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_CERT_FINGERPRINT
For internal SSL, the sha1 fingerprint of the internal certificate to verify the client.
|
static ConfigOption<Integer> |
SecurityOptions.SSL_INTERNAL_CLOSE_NOTIFY_FLUSH_TIMEOUT
SSL session timeout after flushing the close_notify message.
|
static ConfigOption<Boolean> |
SecurityOptions.SSL_INTERNAL_ENABLED
Enable SSL for internal communication (akka rpc, netty data transport, blob server).
|
static ConfigOption<Integer> |
SecurityOptions.SSL_INTERNAL_HANDSHAKE_TIMEOUT
SSL session timeout during handshakes.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_KEY_PASSWORD
For internal SSL, the password to decrypt the private key.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_KEYSTORE
For internal SSL, the Java keystore file containing the private key and certificate.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_KEYSTORE_PASSWORD
For internal SSL, the password to decrypt the keystore file containing the certificate.
|
static ConfigOption<Integer> |
SecurityOptions.SSL_INTERNAL_SESSION_CACHE_SIZE
SSL session cache size.
|
static ConfigOption<Integer> |
SecurityOptions.SSL_INTERNAL_SESSION_TIMEOUT
SSL session timeout.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_TRUSTSTORE
For internal SSL, the truststore file containing the public CA certificates to verify the ssl
peers.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_TRUSTSTORE_PASSWORD
For internal SSL, the secret to decrypt the truststore.
|
static ConfigOption<String> |
SecurityOptions.SSL_KEY_PASSWORD
Secret to decrypt the server key.
|
static ConfigOption<String> |
SecurityOptions.SSL_KEYSTORE
The Java keystore file containing the flink endpoint key and certificate.
|
static ConfigOption<String> |
SecurityOptions.SSL_KEYSTORE_PASSWORD
Secret to decrypt the keystore file.
|
static ConfigOption<String> |
SecurityOptions.SSL_PROTOCOL
SSL protocol version to be supported.
|
static ConfigOption<String> |
SecurityOptions.SSL_PROVIDER
SSL engine provider.
|
static ConfigOption<Boolean> |
SecurityOptions.SSL_REST_AUTHENTICATION_ENABLED
Enable mututal SSL authentication for external REST endpoints.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_CERT_FINGERPRINT
For external (REST) SSL, the sha1 fingerprint of the rest client certificate to verify.
|
static ConfigOption<Boolean> |
SecurityOptions.SSL_REST_ENABLED
Enable SSL for external REST endpoints.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_KEY_PASSWORD
For external (REST) SSL, the password to decrypt the private key.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_KEYSTORE
For external (REST) SSL, the Java keystore file containing the private key and certificate.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_KEYSTORE_PASSWORD
For external (REST) SSL, the password to decrypt the keystore file containing the
certificate.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_TRUSTSTORE
For external (REST) SSL, the truststore file containing the public CA certificates to verify
the ssl peers.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_TRUSTSTORE_PASSWORD
For external (REST) SSL, the secret to decrypt the truststore.
|
static ConfigOption<String> |
SecurityOptions.SSL_TRUSTSTORE
The truststore file containing the public CA certificates to verify the ssl peers.
|
static ConfigOption<String> |
SecurityOptions.SSL_TRUSTSTORE_PASSWORD
Secret to decrypt the truststore.
|
static ConfigOption<Boolean> |
SecurityOptions.SSL_VERIFY_HOSTNAME
Flag to enable/disable hostname verification for the ssl connections.
|
static ConfigOption<Long> |
ResourceManagerOptions.STANDALONE_CLUSTER_STARTUP_PERIOD_TIME
Time in milliseconds of the start-up period of a standalone cluster.
|
static ConfigOption<Double> |
ResourceManagerOptions.START_WORKER_MAX_FAILURE_RATE
The maximum number of start worker failures (Native Kubernetes / Yarn / Mesos) per minute
before pausing requesting new workers.
|
static ConfigOption<java.time.Duration> |
ResourceManagerOptions.START_WORKER_RETRY_INTERVAL
The time to wait before requesting new workers (Native Kubernetes / Yarn / Mesos) once the
max failure rate of starting workers (
ResourceManagerOptions.START_WORKER_MAX_FAILURE_RATE ) is reached. |
static ConfigOption<String> |
AkkaOptions.STARTUP_TIMEOUT
Timeout for the startup of the actor system.
|
static ConfigOption<String> |
CheckpointingOptions.STATE_BACKEND
Deprecated.
|
static ConfigOption<String> |
StateBackendOptions.STATE_BACKEND
The checkpoint storage used to store operator state locally within the cluster during
execution.
|
static ConfigOption<String> |
BlobServerOptions.STORAGE_DIRECTORY
The config parameter defining the storage directory to be used by the blob server.
|
static ConfigOption<Boolean> |
WebOptions.SUBMIT_ENABLE
Config parameter indicating whether jobs can be uploaded and run from the web-frontend.
|
static ConfigOption<Boolean> |
MetricOptions.SYSTEM_RESOURCE_METRICS
Whether Flink should report system resource metrics such as machine's CPU, memory or network
usage.
|
static ConfigOption<Long> |
MetricOptions.SYSTEM_RESOURCE_METRICS_PROBING_INTERVAL
Interval between probing of system resource metrics specified in milliseconds.
|
static ConfigOption<String> |
DeploymentOptions.TARGET |
static ConfigOption<Long> |
TaskManagerOptions.TASK_CANCELLATION_INTERVAL
Time interval in milliseconds between two successive task cancellation attempts.
|
static ConfigOption<Long> |
TaskManagerOptions.TASK_CANCELLATION_TIMEOUT
Timeout in milliseconds after which a task cancellation times out and leads to a fatal
TaskManager error.
|
static ConfigOption<Long> |
TaskManagerOptions.TASK_CANCELLATION_TIMEOUT_TIMERS
This configures how long we wait for the timers in milliseconds to finish all pending timer
threads when the stream task is cancelled.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.TASK_HEAP_MEMORY
Task Heap Memory size for TaskExecutors.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.TASK_MANAGER_HEAP_MEMORY
Deprecated.
use
TaskManagerOptions.TOTAL_FLINK_MEMORY for standalone setups and TaskManagerOptions.TOTAL_PROCESS_MEMORY for containerized setups. |
static ConfigOption<Integer> |
TaskManagerOptions.TASK_MANAGER_HEAP_MEMORY_MB
Deprecated.
use
TaskManagerOptions.TOTAL_FLINK_MEMORY for standalone setups and TaskManagerOptions.TOTAL_PROCESS_MEMORY for containerized setups. |
static ConfigOption<java.time.Duration> |
ResourceManagerOptions.TASK_MANAGER_REGISTRATION_TIMEOUT
Timeout for TaskManagers to register at the active resource managers.
|
static ConfigOption<Boolean> |
ResourceManagerOptions.TASK_MANAGER_RELEASE_WHEN_RESULT_CONSUMED
Deprecated.
The default value should be reasonable enough in all cases, this option is to
fallback to older behaviour which will be removed or refactored in future.
|
static ConfigOption<String> |
TaskManagerOptions.TASK_MANAGER_RESOURCE_ID
The TaskManager's ResourceID.
|
static ConfigOption<String> |
TaskManagerOptionsInternal.TASK_MANAGER_RESOURCE_ID_METADATA |
static ConfigOption<Long> |
ResourceManagerOptions.TASK_MANAGER_TIMEOUT
The timeout for an idle task manager to be released, in milliseconds.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.TASK_OFF_HEAP_MEMORY
Task Off-Heap Memory size for TaskExecutors.
|
static ConfigOption<String> |
AkkaOptions.TCP_TIMEOUT
The Akka tcp connection timeout.
|
static ConfigOption<Long> |
WebOptions.TIMEOUT
Timeout for asynchronous operations by the web monitor in milliseconds.
|
static ConfigOption<String> |
WebOptions.TMP_DIR
The config parameter defining the flink web directory to be used by the webmonitor.
|
static ConfigOption<String> |
CoreOptions.TMP_DIRS
The config parameter defining the directories for temporary files, separated by ",", "|", or
the system's
File.pathSeparator . |
static ConfigOption<MemorySize> |
JobManagerOptions.TOTAL_FLINK_MEMORY
Total Flink Memory size for the JobManager.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.TOTAL_FLINK_MEMORY
Total Flink Memory size for the TaskExecutors.
|
static ConfigOption<MemorySize> |
JobManagerOptions.TOTAL_PROCESS_MEMORY
Total Process Memory size for the JobManager.
|
static ConfigOption<MemorySize> |
TaskManagerOptions.TOTAL_PROCESS_MEMORY
Total Process Memory size for the TaskExecutors.
|
static ConfigOption<String> |
NettyShuffleEnvironmentOptions.TRANSPORT_TYPE |
static ConfigOption<String> |
WebOptions.UPLOAD_DIR
The config parameter defining the directory for uploading the job jars.
|
static ConfigOption<Boolean> |
ExecutionOptions.USE_BATCH_STATE_BACKEND |
static ConfigOption<Boolean> |
AlgorithmOptions.USE_LARGE_RECORDS_HANDLER |
static ConfigOption<String> |
AkkaOptions.WATCH_HEARTBEAT_INTERVAL
Deprecated.
Don't use this option anymore. It has no effect on Flink.
|
static ConfigOption<String> |
AkkaOptions.WATCH_HEARTBEAT_PAUSE
Deprecated.
Don't use this option anymore. It has no effect on Flink.
|
static ConfigOption<Integer> |
AkkaOptions.WATCH_THRESHOLD
Deprecated.
Don't use this option anymore. It has no effect on Flink.
|
static ConfigOption<String> |
HighAvailabilityOptions.ZOOKEEPER_CLIENT_ACL |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_CONNECTION_TIMEOUT |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_MAX_RETRY_ATTEMPTS |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_RETRY_WAIT |
static ConfigOption<String> |
HighAvailabilityOptions.ZOOKEEPER_RUNNING_JOB_REGISTRY_PATH |
static ConfigOption<Boolean> |
SecurityOptions.ZOOKEEPER_SASL_DISABLE |
static ConfigOption<String> |
SecurityOptions.ZOOKEEPER_SASL_LOGIN_CONTEXT_NAME |
static ConfigOption<String> |
SecurityOptions.ZOOKEEPER_SASL_SERVICE_NAME |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_SESSION_TIMEOUT |
Modifier and Type | Method and Description |
---|---|
ConfigOption<T> |
ConfigOptions.TypedConfigOptionBuilder.defaultValue(T value)
Creates a ConfigOption with the given default value.
|
<T> ConfigOption<T> |
ConfigOptions.OptionBuilder.defaultValue(T value)
Deprecated.
define the type explicitly first with one of the intType(), stringType(),
etc.
|
ConfigOption<List<E>> |
ConfigOptions.ListConfigOptionBuilder.defaultValues(E... values)
Creates a ConfigOption with the given default value.
|
static ConfigOption<Integer> |
CoreOptions.fileSystemConnectionLimit(String scheme)
The total number of input plus output connections that a file system for the given scheme may
open.
|
static ConfigOption<Integer> |
CoreOptions.fileSystemConnectionLimitIn(String scheme)
The total number of input connections that a file system for the given scheme may open.
|
static ConfigOption<Integer> |
CoreOptions.fileSystemConnectionLimitOut(String scheme)
The total number of output connections that a file system for the given scheme may open.
|
static ConfigOption<Long> |
CoreOptions.fileSystemConnectionLimitStreamInactivityTimeout(String scheme)
If any connection limit is configured, this option can be optionally set to define after
which time (in milliseconds) inactive streams are reclaimed.
|
static ConfigOption<Long> |
CoreOptions.fileSystemConnectionLimitTimeout(String scheme)
If any connection limit is configured, this option can be optionally set to define after
which time (in milliseconds) stream opening fails with a timeout exception, if no stream
connection becomes available.
|
ConfigOption<String> |
ConfigOptions.OptionBuilder.noDefaultValue()
Deprecated.
define the type explicitly first with one of the intType(), stringType(),
etc.
|
ConfigOption<T> |
ConfigOptions.TypedConfigOptionBuilder.noDefaultValue()
Creates a ConfigOption without a default value.
|
ConfigOption<List<E>> |
ConfigOptions.ListConfigOptionBuilder.noDefaultValue()
Creates a ConfigOption without a default value.
|
ConfigOption<T> |
ConfigOption.withDeprecatedKeys(String... deprecatedKeys)
Creates a new config option, using this option's key and default value, and adding the given
deprecated keys.
|
ConfigOption<T> |
ConfigOption.withDescription(Description description)
Creates a new config option, using this option's key and default value, and adding the given
description.
|
ConfigOption<T> |
ConfigOption.withDescription(String description)
Creates a new config option, using this option's key and default value, and adding the given
description.
|
ConfigOption<T> |
ConfigOption.withFallbackKeys(String... fallbackKeys)
Creates a new config option, using this option's key and default value, and adding the given
fallback keys.
|
Modifier and Type | Method and Description |
---|---|
boolean |
DelegatingConfiguration.contains(ConfigOption<?> configOption) |
boolean |
Configuration.contains(ConfigOption<?> configOption)
Checks whether there is an entry for the given config option.
|
static <IN,OUT,E extends Throwable> |
ConfigUtils.decodeListFromConfig(ReadableConfig configuration,
ConfigOption<List<IN>> key,
FunctionWithException<IN,OUT,E> mapper)
Gets a
List of values of type IN from a ReadableConfig and transforms
it to a List of type OUT based on the provided mapper function. |
static <IN,OUT> void |
ConfigUtils.encodeArrayToConfig(WritableConfig configuration,
ConfigOption<List<OUT>> key,
IN[] values,
java.util.function.Function<IN,OUT> mapper)
|
static <IN,OUT> void |
ConfigUtils.encodeCollectionToConfig(WritableConfig configuration,
ConfigOption<List<OUT>> key,
Collection<IN> values,
java.util.function.Function<IN,OUT> mapper)
Puts a
Collection of values of type IN in a WritableConfig as a
ConfigOption of type List of type OUT . |
<T> T |
DelegatingConfiguration.get(ConfigOption<T> option) |
<T> T |
ReadableConfig.get(ConfigOption<T> option)
Reads a value using the metadata included in
ConfigOption . |
<T> T |
Configuration.get(ConfigOption<T> option) |
boolean |
DelegatingConfiguration.getBoolean(ConfigOption<Boolean> configOption) |
boolean |
Configuration.getBoolean(ConfigOption<Boolean> configOption)
Returns the value associated with the given config option as a boolean.
|
boolean |
DelegatingConfiguration.getBoolean(ConfigOption<Boolean> configOption,
boolean overrideDefault) |
boolean |
Configuration.getBoolean(ConfigOption<Boolean> configOption,
boolean overrideDefault)
Returns the value associated with the given config option as a boolean.
|
double |
DelegatingConfiguration.getDouble(ConfigOption<Double> configOption) |
double |
Configuration.getDouble(ConfigOption<Double> configOption)
Returns the value associated with the given config option as a
double . |
double |
DelegatingConfiguration.getDouble(ConfigOption<Double> configOption,
double overrideDefault) |
double |
Configuration.getDouble(ConfigOption<Double> configOption,
double overrideDefault)
Returns the value associated with the given config option as a
double . |
<T extends Enum<T>> |
DelegatingConfiguration.getEnum(Class<T> enumClass,
ConfigOption<String> configOption) |
<T extends Enum<T>> |
Configuration.getEnum(Class<T> enumClass,
ConfigOption<String> configOption)
Returns the value associated with the given config option as an enum.
|
float |
DelegatingConfiguration.getFloat(ConfigOption<Float> configOption) |
float |
Configuration.getFloat(ConfigOption<Float> configOption)
Returns the value associated with the given config option as a float.
|
float |
DelegatingConfiguration.getFloat(ConfigOption<Float> configOption,
float overrideDefault) |
float |
Configuration.getFloat(ConfigOption<Float> configOption,
float overrideDefault)
Returns the value associated with the given config option as a float.
|
int |
DelegatingConfiguration.getInteger(ConfigOption<Integer> configOption) |
int |
Configuration.getInteger(ConfigOption<Integer> configOption)
Returns the value associated with the given config option as an integer.
|
int |
DelegatingConfiguration.getInteger(ConfigOption<Integer> configOption,
int overrideDefault) |
int |
Configuration.getInteger(ConfigOption<Integer> configOption,
int overrideDefault)
Returns the value associated with the given config option as an integer.
|
long |
DelegatingConfiguration.getLong(ConfigOption<Long> configOption) |
long |
Configuration.getLong(ConfigOption<Long> configOption)
Returns the value associated with the given config option as a long integer.
|
long |
DelegatingConfiguration.getLong(ConfigOption<Long> configOption,
long overrideDefault) |
long |
Configuration.getLong(ConfigOption<Long> configOption,
long overrideDefault)
Returns the value associated with the given config option as a long integer.
|
<T> Optional<T> |
DelegatingConfiguration.getOptional(ConfigOption<T> option) |
<T> Optional<T> |
ReadableConfig.getOptional(ConfigOption<T> option)
Reads a value using the metadata included in
ConfigOption . |
<T> Optional<T> |
Configuration.getOptional(ConfigOption<T> option) |
String |
DelegatingConfiguration.getString(ConfigOption<String> configOption) |
String |
Configuration.getString(ConfigOption<String> configOption)
Returns the value associated with the given config option as a string.
|
String |
DelegatingConfiguration.getString(ConfigOption<String> configOption,
String overrideDefault) |
String |
Configuration.getString(ConfigOption<String> configOption,
String overrideDefault)
Returns the value associated with the given config option as a string.
|
String |
DelegatingConfiguration.getValue(ConfigOption<?> configOption) |
String |
Configuration.getValue(ConfigOption<?> configOption)
Returns the value associated with the given config option as a string.
|
<T> boolean |
DelegatingConfiguration.removeConfig(ConfigOption<T> configOption) |
<T> boolean |
UnmodifiableConfiguration.removeConfig(ConfigOption<T> configOption) |
<T> boolean |
Configuration.removeConfig(ConfigOption<T> configOption)
Removes given config option from the configuration.
|
<T> WritableConfig |
WritableConfig.set(ConfigOption<T> option,
T value)
Stores a given value using the metadata included in the
ConfigOption . |
<T> Configuration |
DelegatingConfiguration.set(ConfigOption<T> option,
T value) |
<T> Configuration |
Configuration.set(ConfigOption<T> option,
T value) |
void |
DelegatingConfiguration.setBoolean(ConfigOption<Boolean> key,
boolean value) |
void |
Configuration.setBoolean(ConfigOption<Boolean> key,
boolean value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setDouble(ConfigOption<Double> key,
double value) |
void |
Configuration.setDouble(ConfigOption<Double> key,
double value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setFloat(ConfigOption<Float> key,
float value) |
void |
Configuration.setFloat(ConfigOption<Float> key,
float value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setInteger(ConfigOption<Integer> key,
int value) |
void |
Configuration.setInteger(ConfigOption<Integer> key,
int value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setLong(ConfigOption<Long> key,
long value) |
void |
Configuration.setLong(ConfigOption<Long> key,
long value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setString(ConfigOption<String> key,
String value) |
void |
Configuration.setString(ConfigOption<String> key,
String value)
Adds the given value to the configuration object.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Integer> |
SourceReaderOptions.ELEMENT_QUEUE_CAPACITY |
static ConfigOption<Long> |
SourceReaderOptions.SOURCE_READER_CLOSE_TIMEOUT |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<MemorySize> |
StreamFormat.FETCH_IO_SIZE
The config option to define how many bytes to be read by the I/O thread in one fetch
operation.
|
static ConfigOption<Integer> |
FileRecordFormat.RECORDS_PER_FETCH
Config option for the number of records to hand over in each fetch.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
HBaseOptions.LOOKUP_ASYNC |
static ConfigOption<Long> |
HBaseOptions.LOOKUP_CACHE_MAX_ROWS |
static ConfigOption<java.time.Duration> |
HBaseOptions.LOOKUP_CACHE_TTL |
static ConfigOption<Integer> |
HBaseOptions.LOOKUP_MAX_RETRIES |
static ConfigOption<String> |
HBaseOptions.NULL_STRING_LITERAL |
static ConfigOption<java.time.Duration> |
HBaseOptions.SINK_BUFFER_FLUSH_INTERVAL |
static ConfigOption<Integer> |
HBaseOptions.SINK_BUFFER_FLUSH_MAX_ROWS |
static ConfigOption<MemorySize> |
HBaseOptions.SINK_BUFFER_FLUSH_MAX_SIZE |
static ConfigOption<String> |
HBaseOptions.TABLE_NAME |
static ConfigOption<String> |
HBaseOptions.ZOOKEEPER_QUORUM |
static ConfigOption<String> |
HBaseOptions.ZOOKEEPER_ZNODE_PARENT |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
HBase1DynamicTableFactory.optionalOptions() |
Set<ConfigOption<?>> |
HBase1DynamicTableFactory.requiredOptions() |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
HBase2DynamicTableFactory.optionalOptions() |
Set<ConfigOption<?>> |
HBase2DynamicTableFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
JdbcCatalogFactoryOptions.BASE_URL |
static ConfigOption<String> |
JdbcCatalogFactoryOptions.DEFAULT_DATABASE |
static ConfigOption<String> |
JdbcCatalogFactoryOptions.PASSWORD |
static ConfigOption<String> |
JdbcCatalogFactoryOptions.USERNAME |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
JdbcCatalogFactory.optionalOptions() |
Set<ConfigOption<?>> |
JdbcCatalogFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<java.time.Duration> |
JdbcDynamicTableFactory.MAX_RETRY_TIMEOUT |
static ConfigOption<String> |
JdbcDynamicTableFactory.PASSWORD |
static ConfigOption<String> |
JdbcDynamicTableFactory.TABLE_NAME |
static ConfigOption<String> |
JdbcDynamicTableFactory.URL |
static ConfigOption<String> |
JdbcDynamicTableFactory.USERNAME |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
JdbcDynamicTableFactory.optionalOptions() |
Set<ConfigOption<?>> |
JdbcDynamicTableFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
KafkaSourceOptions.CLIENT_ID_PREFIX |
static ConfigOption<Boolean> |
KafkaSourceOptions.COMMIT_OFFSETS_ON_CHECKPOINT |
static ConfigOption<Long> |
KafkaSourceOptions.PARTITION_DISCOVERY_INTERVAL_MS |
static ConfigOption<Boolean> |
KafkaSourceOptions.REGISTER_KAFKA_CONSUMER_METRICS |
Modifier and Type | Method and Description |
---|---|
static <T> T |
KafkaSourceOptions.getOption(Properties props,
ConfigOption<?> configOption,
java.util.function.Function<String,T> parser) |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
HiveOptions.TABLE_EXEC_HIVE_FALLBACK_MAPRED_READER |
static ConfigOption<Boolean> |
HiveOptions.TABLE_EXEC_HIVE_FALLBACK_MAPRED_WRITER |
static ConfigOption<Boolean> |
HiveOptions.TABLE_EXEC_HIVE_INFER_SOURCE_PARALLELISM |
static ConfigOption<Integer> |
HiveOptions.TABLE_EXEC_HIVE_INFER_SOURCE_PARALLELISM_MAX |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
HiveDynamicTableFactory.optionalOptions() |
Set<ConfigOption<?>> |
HiveDynamicTableFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.BLOCK_CACHE_CAPACITY |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.BLOCK_CACHE_PINNED_USAGE |
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.BLOCK_CACHE_SIZE |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.BLOCK_CACHE_USAGE |
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.BLOCK_SIZE |
static ConfigOption<Integer> |
RocksDBOptions.CHECKPOINT_TRANSFER_THREAD_NUM
The number of threads used to transfer (download and upload) files in RocksDBStateBackend.
|
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.COLUMN_FAMILY_AS_VARIABLE |
static ConfigOption<org.rocksdb.CompactionStyle> |
RocksDBConfigurableOptions.COMPACTION_STYLE |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.ESTIMATE_LIVE_DATA_SIZE |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.ESTIMATE_NUM_KEYS |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.ESTIMATE_PENDING_COMPACTION_BYTES |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.ESTIMATE_TABLE_READERS_MEM |
static ConfigOption<MemorySize> |
RocksDBOptions.FIX_PER_SLOT_MEMORY_SIZE |
static ConfigOption<Double> |
RocksDBOptions.HIGH_PRIORITY_POOL_RATIO |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.IS_WRITE_STOPPED |
static ConfigOption<String> |
RocksDBOptions.LOCAL_DIRECTORIES
The local directory (on the TaskManager) where RocksDB puts its files.
|
static ConfigOption<org.rocksdb.InfoLogLevel> |
RocksDBConfigurableOptions.LOG_LEVEL |
static ConfigOption<Integer> |
RocksDBConfigurableOptions.MAX_BACKGROUND_THREADS |
static ConfigOption<Integer> |
RocksDBConfigurableOptions.MAX_OPEN_FILES |
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.MAX_SIZE_LEVEL_BASE |
static ConfigOption<Integer> |
RocksDBConfigurableOptions.MAX_WRITE_BUFFER_NUMBER |
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.METADATA_BLOCK_SIZE |
static ConfigOption<Integer> |
RocksDBConfigurableOptions.MIN_WRITE_BUFFER_NUMBER_TO_MERGE |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_ACTUAL_DELAYED_WRITE_RATE |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_BACKGROUND_ERRORS |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_CUR_SIZE_ACTIVE_MEM_TABLE |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_CUR_SIZE_ALL_MEM_TABLE |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_MEM_TABLE_FLUSH_PENDING |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_NUM_DELETES_ACTIVE_MEM_TABLE |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_NUM_DELETES_IMM_MEM_TABLE |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_NUM_ENTRIES_ACTIVE_MEM_TABLE |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_NUM_ENTRIES_IMM_MEM_TABLES |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_NUM_IMMUTABLE_MEM_TABLES |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_NUM_LIVE_VERSIONS |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_NUM_RUNNING_COMPACTIONS |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_NUM_RUNNING_FLUSHES |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_NUM_SNAPSHOTS |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_SIZE_ALL_MEM_TABLES |
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.MONITOR_TOTAL_SST_FILES_SIZE |
static ConfigOption<String> |
RocksDBOptions.OPTIONS_FACTORY
The options factory class for RocksDB to create DBOptions and ColumnFamilyOptions.
|
static ConfigOption<String> |
RocksDBOptions.PREDEFINED_OPTIONS
The predefined settings for RocksDB DBOptions and ColumnFamilyOptions by Flink community.
|
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.TARGET_FILE_SIZE_BASE |
static ConfigOption<EmbeddedRocksDBStateBackend.PriorityQueueStateType> |
RocksDBOptions.TIMER_SERVICE_FACTORY
Choice of timer service implementation.
|
static ConfigOption<Boolean> |
RocksDBNativeMetricOptions.TRACK_COMPACTION_PENDING |
static ConfigOption<Boolean> |
RocksDBConfigurableOptions.USE_DYNAMIC_LEVEL_SIZE |
static ConfigOption<Boolean> |
RocksDBOptions.USE_MANAGED_MEMORY |
static ConfigOption<Boolean> |
RocksDBOptions.USE_PARTITIONED_INDEX_FILTERS |
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.WRITE_BATCH_SIZE |
static ConfigOption<Double> |
RocksDBOptions.WRITE_BUFFER_RATIO |
static ConfigOption<MemorySize> |
RocksDBConfigurableOptions.WRITE_BUFFER_SIZE |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
AvroFileFormatFactory.AVRO_OUTPUT_CODEC |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
AvroFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
AvroFileFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
AvroFileSystemFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
AvroFormatFactory.requiredOptions() |
Set<ConfigOption<?>> |
AvroFileFormatFactory.requiredOptions() |
Set<ConfigOption<?>> |
AvroFileSystemFormatFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
RegistryAvroOptions.BASIC_AUTH_CREDENTIALS_SOURCE |
static ConfigOption<String> |
RegistryAvroOptions.BASIC_AUTH_USER_INFO |
static ConfigOption<String> |
RegistryAvroOptions.BEARER_AUTH_CREDENTIALS_SOURCE |
static ConfigOption<String> |
RegistryAvroOptions.BEARER_AUTH_TOKEN |
static ConfigOption<String> |
RegistryAvroOptions.SCHEMA_REGISTRY_SUBJECT |
static ConfigOption<String> |
RegistryAvroOptions.SCHEMA_REGISTRY_URL |
static ConfigOption<String> |
RegistryAvroOptions.SSL_KEYSTORE_LOCATION |
static ConfigOption<String> |
RegistryAvroOptions.SSL_KEYSTORE_PASSWORD |
static ConfigOption<String> |
RegistryAvroOptions.SSL_TRUSTSTORE_LOCATION |
static ConfigOption<String> |
RegistryAvroOptions.SSL_TRUSTSTORE_PASSWORD |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
RegistryAvroFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
RegistryAvroFormatFactory.requiredOptions() |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
DebeziumAvroFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
DebeziumAvroFormatFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
CsvOptions.ALLOW_COMMENTS |
static ConfigOption<String> |
CsvOptions.ARRAY_ELEMENT_DELIMITER |
static ConfigOption<Boolean> |
CsvOptions.DISABLE_QUOTE_CHARACTER |
static ConfigOption<String> |
CsvOptions.ESCAPE_CHARACTER |
static ConfigOption<String> |
CsvOptions.FIELD_DELIMITER |
static ConfigOption<Boolean> |
CsvOptions.IGNORE_PARSE_ERRORS |
static ConfigOption<String> |
CsvOptions.NULL_LITERAL |
static ConfigOption<String> |
CsvOptions.QUOTE_CHARACTER |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
CsvFileSystemFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
CsvFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
CsvFileSystemFormatFactory.requiredOptions() |
Set<ConfigOption<?>> |
CsvFormatFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
JsonOptions.ENCODE_DECIMAL_AS_PLAIN_NUMBER |
static ConfigOption<Boolean> |
JsonOptions.FAIL_ON_MISSING_FIELD |
static ConfigOption<Boolean> |
JsonOptions.IGNORE_PARSE_ERRORS |
static ConfigOption<String> |
JsonOptions.MAP_NULL_KEY_LITERAL |
static ConfigOption<String> |
JsonOptions.MAP_NULL_KEY_MODE |
static ConfigOption<String> |
JsonOptions.TIMESTAMP_FORMAT |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
JsonFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
JsonFormatFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
CanalJsonOptions.DATABASE_INCLUDE |
static ConfigOption<Boolean> |
CanalJsonOptions.IGNORE_PARSE_ERRORS |
static ConfigOption<String> |
CanalJsonOptions.JSON_MAP_NULL_KEY_LITERAL |
static ConfigOption<String> |
CanalJsonOptions.JSON_MAP_NULL_KEY_MODE |
static ConfigOption<String> |
CanalJsonOptions.TABLE_INCLUDE |
static ConfigOption<String> |
CanalJsonOptions.TIMESTAMP_FORMAT |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
CanalJsonFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
CanalJsonFormatFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
DebeziumJsonOptions.IGNORE_PARSE_ERRORS |
static ConfigOption<String> |
DebeziumJsonOptions.JSON_MAP_NULL_KEY_LITERAL |
static ConfigOption<String> |
DebeziumJsonOptions.JSON_MAP_NULL_KEY_MODE |
static ConfigOption<Boolean> |
DebeziumJsonOptions.SCHEMA_INCLUDE |
static ConfigOption<String> |
DebeziumJsonOptions.TIMESTAMP_FORMAT |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
DebeziumJsonFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
DebeziumJsonFormatFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
MaxwellJsonOptions.IGNORE_PARSE_ERRORS |
static ConfigOption<String> |
MaxwellJsonOptions.JSON_MAP_NULL_KEY_LITERAL |
static ConfigOption<String> |
MaxwellJsonOptions.JSON_MAP_NULL_KEY_MODE |
static ConfigOption<String> |
MaxwellJsonOptions.TIMESTAMP_FORMAT |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
MaxwellJsonFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
MaxwellJsonFormatFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
ParquetFileFormatFactory.UTC_TIMEZONE |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
ParquetFileFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
ParquetFileFormatFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
AbstractS3FileSystemFactory.ENTROPY_INJECT_KEY_OPTION
The substring to be replaced by random entropy in checkpoint paths.
|
static ConfigOption<Integer> |
AbstractS3FileSystemFactory.ENTROPY_INJECT_LENGTH_OPTION
The number of entropy characters, in case entropy injection is configured.
|
static ConfigOption<Integer> |
AbstractS3FileSystemFactory.MAX_CONCURRENT_UPLOADS |
static ConfigOption<Long> |
AbstractS3FileSystemFactory.PART_UPLOAD_MIN_SIZE |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
KubernetesConfigOptions.CLUSTER_ID |
static ConfigOption<String> |
KubernetesConfigOptions.CONTAINER_IMAGE |
static ConfigOption<KubernetesConfigOptions.ImagePullPolicy> |
KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY |
static ConfigOption<List<String>> |
KubernetesConfigOptions.CONTAINER_IMAGE_PULL_SECRETS |
static ConfigOption<String> |
KubernetesConfigOptions.CONTEXT |
static ConfigOption<String> |
KubernetesConfigOptionsInternal.ENTRY_POINT_CLASS |
static ConfigOption<String> |
KubernetesConfigOptions.EXTERNAL_RESOURCE_KUBERNETES_CONFIG_KEY
If configured, Flink will add "resources.limits.>config-key<" and
"resources.requests.>config-key<" to the main container of TaskExecutor and set the
value to
ExternalResourceOptions.EXTERNAL_RESOURCE_AMOUNT . |
static ConfigOption<String> |
KubernetesConfigOptions.FLINK_CONF_DIR |
static ConfigOption<String> |
KubernetesConfigOptions.FLINK_LOG_DIR |
static ConfigOption<String> |
KubernetesConfigOptions.HADOOP_CONF_CONFIG_MAP |
static ConfigOption<Map<String,String>> |
KubernetesConfigOptions.JOB_MANAGER_ANNOTATIONS |
static ConfigOption<Double> |
KubernetesConfigOptions.JOB_MANAGER_CPU |
static ConfigOption<Map<String,String>> |
KubernetesConfigOptions.JOB_MANAGER_LABELS |
static ConfigOption<Map<String,String>> |
KubernetesConfigOptions.JOB_MANAGER_NODE_SELECTOR |
static ConfigOption<List<Map<String,String>>> |
KubernetesConfigOptions.JOB_MANAGER_OWNER_REFERENCE |
static ConfigOption<String> |
KubernetesConfigOptions.JOB_MANAGER_POD_TEMPLATE |
static ConfigOption<String> |
KubernetesConfigOptions.JOB_MANAGER_SERVICE_ACCOUNT |
static ConfigOption<List<Map<String,String>>> |
KubernetesConfigOptions.JOB_MANAGER_TOLERATIONS |
static ConfigOption<String> |
KubernetesConfigOptions.KUBE_CONFIG_FILE |
static ConfigOption<Integer> |
KubernetesConfigOptions.KUBERNETES_CLIENT_IO_EXECUTOR_POOL_SIZE |
static ConfigOption<String> |
KubernetesConfigOptions.KUBERNETES_ENTRY_PATH
The following config options need to be set according to the image.
|
static ConfigOption<List<Map<String,String>>> |
KubernetesConfigOptions.KUBERNETES_ENV_SECRET_KEY_REF |
static ConfigOption<java.time.Duration> |
KubernetesHighAvailabilityOptions.KUBERNETES_LEASE_DURATION |
static ConfigOption<String> |
KubernetesConfigOptions.KUBERNETES_POD_TEMPLATE
This option is here only for documentation generation, it is the fallback key of
JOB_MANAGER_POD_TEMPLATE and TASK_MANAGER_POD_TEMPLATE.
|
static ConfigOption<java.time.Duration> |
KubernetesHighAvailabilityOptions.KUBERNETES_RENEW_DEADLINE |
static ConfigOption<java.time.Duration> |
KubernetesHighAvailabilityOptions.KUBERNETES_RETRY_PERIOD |
static ConfigOption<Map<String,String>> |
KubernetesConfigOptions.KUBERNETES_SECRETS |
static ConfigOption<String> |
KubernetesConfigOptions.KUBERNETES_SERVICE_ACCOUNT |
static ConfigOption<Integer> |
KubernetesConfigOptions.KUBERNETES_TRANSACTIONAL_OPERATION_MAX_RETRIES |
static ConfigOption<String> |
KubernetesConfigOptions.NAMESPACE |
static ConfigOption<Map<String,String>> |
KubernetesConfigOptions.REST_SERVICE_ANNOTATIONS |
static ConfigOption<KubernetesConfigOptions.ServiceExposedType> |
KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE |
static ConfigOption<Map<String,String>> |
KubernetesConfigOptions.TASK_MANAGER_ANNOTATIONS |
static ConfigOption<Double> |
KubernetesConfigOptions.TASK_MANAGER_CPU |
static ConfigOption<Map<String,String>> |
KubernetesConfigOptions.TASK_MANAGER_LABELS |
static ConfigOption<Map<String,String>> |
KubernetesConfigOptions.TASK_MANAGER_NODE_SELECTOR |
static ConfigOption<String> |
KubernetesConfigOptions.TASK_MANAGER_POD_TEMPLATE |
static ConfigOption<String> |
KubernetesConfigOptions.TASK_MANAGER_SERVICE_ACCOUNT |
static ConfigOption<List<Map<String,String>>> |
KubernetesConfigOptions.TASK_MANAGER_TOLERATIONS |
Modifier and Type | Method and Description |
---|---|
static void |
KubernetesUtils.checkAndUpdatePortConfigOption(Configuration flinkConfig,
ConfigOption<String> port,
int fallbackPort)
Check whether the port config option is a fixed port.
|
static Integer |
KubernetesUtils.parsePort(Configuration flinkConfig,
ConfigOption<String> port)
Parse a valid port for the config option.
|
static <T> String |
KubernetesUtils.resolveUserDefinedValue(Configuration flinkConfig,
ConfigOption<T> configOption,
String valueOfConfigOptionOrDefault,
String valueOfPodTemplate,
String fieldDescription)
Resolve the user defined value with the precedence.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Integer> |
MesosOptions.ARTIFACT_SERVER_PORT
Deprecated.
The config parameter defining the Mesos artifact server port to use.
|
static ConfigOption<Boolean> |
MesosOptions.ARTIFACT_SERVER_SSL_ENABLED
Deprecated.
Config parameter to override SSL support for the Artifact Server.
|
static ConfigOption<Long> |
MesosOptions.DECLINED_OFFER_REFUSE_DURATION
Deprecated.
Config parameter to configure the amount of time refuse a particular offer for.
|
static ConfigOption<Integer> |
MesosOptions.FAILOVER_TIMEOUT_SECONDS
Deprecated.
The failover timeout for the Mesos scheduler, after which running tasks are automatically
shut down.
|
static ConfigOption<String> |
MesosOptions.MASTER_URL
Deprecated.
The Mesos master URL.
|
static ConfigOption<String> |
MesosOptions.PORT_ASSIGNMENTS
Deprecated.
Config parameter to configure which configuration keys will dynamically get a port assigned
through Mesos.
|
static ConfigOption<String> |
MesosOptions.RESOURCEMANAGER_FRAMEWORK_NAME
Deprecated.
|
static ConfigOption<String> |
MesosOptions.RESOURCEMANAGER_FRAMEWORK_PRINCIPAL
Deprecated.
|
static ConfigOption<String> |
MesosOptions.RESOURCEMANAGER_FRAMEWORK_ROLE
Deprecated.
|
static ConfigOption<String> |
MesosOptions.RESOURCEMANAGER_FRAMEWORK_SECRET
Deprecated.
|
static ConfigOption<String> |
MesosOptions.RESOURCEMANAGER_FRAMEWORK_USER
Deprecated.
|
static ConfigOption<Long> |
MesosOptions.UNUSED_OFFER_EXPIRATION
Deprecated.
Config parameter to configure the amount of time to wait for unused expired Mesos offers
before they are declined.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_CONSTRAINTS_HARD_HOSTATTR
Deprecated.
|
static ConfigOption<Boolean> |
MesosTaskManagerParameters.MESOS_RM_CONTAINER_DOCKER_FORCE_PULL_IMAGE
Deprecated.
|
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_RM_CONTAINER_DOCKER_PARAMETERS
Deprecated.
|
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_RM_CONTAINER_IMAGE_NAME
Deprecated.
|
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_RM_CONTAINER_TYPE
Deprecated.
|
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_RM_CONTAINER_VOLUMES
Deprecated.
|
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_RM_NETWORK_RESOURCE_NAME
Deprecated.
|
static ConfigOption<Double> |
MesosTaskManagerParameters.MESOS_RM_TASKS_CPUS
Deprecated.
|
static ConfigOption<Integer> |
MesosTaskManagerParameters.MESOS_RM_TASKS_DISK_MB
Deprecated.
|
static ConfigOption<Integer> |
MesosTaskManagerParameters.MESOS_RM_TASKS_GPUS
Deprecated.
|
static ConfigOption<Integer> |
MesosTaskManagerParameters.MESOS_RM_TASKS_NETWORK_MB_PER_SEC
Deprecated.
|
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_TM_BOOTSTRAP_CMD
Deprecated.
|
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_TM_CMD
Deprecated.
|
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_TM_HOSTNAME
Deprecated.
|
static ConfigOption<Map<String,String>> |
MesosTaskManagerParameters.MESOS_TM_LABELS
Deprecated.
|
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_TM_URIS
Deprecated.
|
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_TM_USER
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Integer> |
InfluxdbReporterOptions.CONNECT_TIMEOUT |
static ConfigOption<org.influxdb.InfluxDB.ConsistencyLevel> |
InfluxdbReporterOptions.CONSISTENCY |
static ConfigOption<String> |
InfluxdbReporterOptions.DB |
static ConfigOption<String> |
InfluxdbReporterOptions.HOST |
static ConfigOption<String> |
InfluxdbReporterOptions.PASSWORD |
static ConfigOption<Integer> |
InfluxdbReporterOptions.PORT |
static ConfigOption<String> |
InfluxdbReporterOptions.RETENTION_POLICY |
static ConfigOption<org.apache.flink.metrics.influxdb.InfluxdbReporterOptions.Scheme> |
InfluxdbReporterOptions.SCHEME |
static ConfigOption<String> |
InfluxdbReporterOptions.USERNAME |
static ConfigOption<Integer> |
InfluxdbReporterOptions.WRITE_TIMEOUT |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
PrometheusPushGatewayReporterOptions.DELETE_ON_SHUTDOWN |
static ConfigOption<Boolean> |
PrometheusPushGatewayReporterOptions.FILTER_LABEL_VALUE_CHARACTER |
static ConfigOption<String> |
PrometheusPushGatewayReporterOptions.GROUPING_KEY |
static ConfigOption<String> |
PrometheusPushGatewayReporterOptions.HOST |
static ConfigOption<String> |
PrometheusPushGatewayReporterOptions.JOB_NAME |
static ConfigOption<Integer> |
PrometheusPushGatewayReporterOptions.PORT |
static ConfigOption<Boolean> |
PrometheusPushGatewayReporterOptions.RANDOM_JOB_NAME_SUFFIX |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
OrcFileFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
OrcFileFormatFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Integer> |
PythonOptions.MAP_STATE_ITERATE_RESPONSE_BATCH_SIZE
The maximum number of entries sent to Python UDF worker per request when iterating a Python
MapState.
|
static ConfigOption<Integer> |
PythonOptions.MAP_STATE_READ_CACHE_SIZE
The maximum number of cached items which read from Java side in a Python MapState.
|
static ConfigOption<Integer> |
PythonOptions.MAP_STATE_WRITE_CACHE_SIZE
The maximum number of write requests cached in a Python MapState.
|
static ConfigOption<Integer> |
PythonOptions.MAX_ARROW_BATCH_SIZE
The maximum number of elements to include in an arrow batch.
|
static ConfigOption<Integer> |
PythonOptions.MAX_BUNDLE_SIZE
The maximum number of elements to include in a bundle.
|
static ConfigOption<Long> |
PythonOptions.MAX_BUNDLE_TIME_MILLS
The maximum time to wait before finalising a bundle (in milliseconds).
|
static ConfigOption<String> |
PythonOptions.PYTHON_ARCHIVES |
static ConfigOption<String> |
PythonOptions.PYTHON_CLIENT_EXECUTABLE |
static ConfigOption<String> |
PythonOptions.PYTHON_EXECUTABLE |
static ConfigOption<String> |
PythonOptions.PYTHON_FILES |
static ConfigOption<Boolean> |
PythonOptions.PYTHON_METRIC_ENABLED
The configuration to enable or disable metric for Python execution.
|
static ConfigOption<String> |
PythonOptions.PYTHON_REQUIREMENTS |
static ConfigOption<Integer> |
PythonOptions.STATE_CACHE_SIZE
The maximum number of states cached in a Python UDF worker.
|
static ConfigOption<Boolean> |
PythonOptions.USE_MANAGED_MEMORY
Whether the memory used by the Python framework is managed memory.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Map<String,String>> |
PythonDependencyUtils.PYTHON_ARCHIVES |
static ConfigOption<Map<String,String>> |
PythonDependencyUtils.PYTHON_FILES |
static ConfigOption<Map<String,String>> |
PythonDependencyUtils.PYTHON_REQUIREMENTS_FILE |
Modifier and Type | Method and Description |
---|---|
static Configuration |
TaskExecutorProcessUtils.getConfigurationMapLegacyTaskManagerHeapSizeToConfigOption(Configuration configuration,
ConfigOption<MemorySize> configOption) |
static double |
TaskExecutorProcessUtils.getCpuCoresWithFallbackConfigOption(Configuration config,
ConfigOption<Double> fallbackOption) |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
ClusterEntrypoint.INTERNAL_CLUSTER_EXECUTION_MODE |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
FileJobGraphRetriever.JOB_GRAPH_FILE_PATH |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
SavepointConfigOptions.SAVEPOINT_IGNORE_UNCLAIMED_STATE
A flag indicating if we allow Flink to skip savepoint state that cannot be restored, e.g.
|
static ConfigOption<String> |
SavepointConfigOptions.SAVEPOINT_PATH
The path to a savepoint that will be used to bootstrap the pipeline's state.
|
Modifier and Type | Method and Description |
---|---|
static JobManagerProcessSpec |
JobManagerProcessUtils.processSpecFromConfigWithNewOptionToInterpretLegacyHeap(Configuration config,
ConfigOption<MemorySize> newOptionToInterpretLegacyHeap) |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
ShuffleServiceOptions.SHUFFLE_SERVICE_FACTORY_CLASS
The full class name of the shuffle service factory implementation to be used by the cluster.
|
Modifier and Type | Method and Description |
---|---|
Configuration |
MemoryBackwardsCompatibilityUtils.getConfWithLegacyHeapSizeMappedToNewConfigOption(Configuration configuration,
ConfigOption<MemorySize> configOption) |
static MemorySize |
ProcessMemoryUtils.getMemorySizeFromConfig(Configuration config,
ConfigOption<MemorySize> option) |
static RangeFraction |
ProcessMemoryUtils.getRangeFraction(MemorySize minSize,
MemorySize maxSize,
ConfigOption<Float> fractionOption,
Configuration config) |
Constructor and Description |
---|
ProcessMemoryOptions(List<ConfigOption<MemorySize>> requiredFineGrainedOptions,
ConfigOption<MemorySize> totalFlinkMemoryOption,
ConfigOption<MemorySize> totalProcessMemoryOption,
JvmMetaspaceAndOverheadOptions jvmOptions) |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<java.time.Duration> |
ExecutionCheckpointingOptions.ALIGNMENT_TIMEOUT |
static ConfigOption<java.time.Duration> |
ExecutionCheckpointingOptions.CHECKPOINTING_INTERVAL |
static ConfigOption<CheckpointingMode> |
ExecutionCheckpointingOptions.CHECKPOINTING_MODE |
static ConfigOption<java.time.Duration> |
ExecutionCheckpointingOptions.CHECKPOINTING_TIMEOUT |
static ConfigOption<Boolean> |
ExecutionCheckpointingOptions.ENABLE_UNALIGNED |
static ConfigOption<CheckpointConfig.ExternalizedCheckpointCleanup> |
ExecutionCheckpointingOptions.EXTERNALIZED_CHECKPOINT |
static ConfigOption<Boolean> |
ExecutionCheckpointingOptions.FORCE_UNALIGNED |
static ConfigOption<Integer> |
ExecutionCheckpointingOptions.MAX_CONCURRENT_CHECKPOINTS |
static ConfigOption<java.time.Duration> |
ExecutionCheckpointingOptions.MIN_PAUSE_BETWEEN_CHECKPOINTS |
static ConfigOption<Boolean> |
ExecutionCheckpointingOptions.PREFER_CHECKPOINT_FOR_RECOVERY |
static ConfigOption<TimeCharacteristic> |
StreamPipelineOptions.TIME_CHARACTERISTIC |
static ConfigOption<Integer> |
ExecutionCheckpointingOptions.TOLERABLE_FAILURE_NUMBER |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
Elasticsearch7DynamicSinkFactory.optionalOptions() |
Set<ConfigOption<?>> |
Elasticsearch6DynamicSinkFactory.optionalOptions() |
Set<ConfigOption<?>> |
Elasticsearch7DynamicSinkFactory.requiredOptions() |
Set<ConfigOption<?>> |
Elasticsearch6DynamicSinkFactory.requiredOptions() |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
KafkaDynamicTableFactory.optionalOptions() |
Set<ConfigOption<?>> |
UpsertKafkaDynamicTableFactory.optionalOptions() |
Set<ConfigOption<?>> |
KafkaDynamicTableFactory.requiredOptions() |
Set<ConfigOption<?>> |
UpsertKafkaDynamicTableFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
KinesisOptions.SINK_PARTITIONER |
static ConfigOption<String> |
KinesisOptions.SINK_PARTITIONER_FIELD_DELIMITER |
static ConfigOption<String> |
KinesisOptions.STREAM |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
KinesisDynamicTableFactory.optionalOptions() |
Set<ConfigOption<?>> |
KinesisDynamicTableFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
CommonCatalogOptions.CATALOG_TYPE
ConfigOption which is used during catalog discovery to match it against Factory.factoryIdentifier() . |
static ConfigOption<String> |
GenericInMemoryCatalogFactoryOptions.DEFAULT_DATABASE |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
GenericInMemoryCatalogFactory.optionalOptions() |
Set<ConfigOption<?>> |
GenericInMemoryCatalogFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
HiveCatalogFactoryOptions.DEFAULT_DATABASE |
static ConfigOption<String> |
HiveCatalogFactoryOptions.HADOOP_CONF_DIR |
static ConfigOption<String> |
HiveCatalogFactoryOptions.HIVE_CONF_DIR |
static ConfigOption<String> |
HiveCatalogFactoryOptions.HIVE_VERSION |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
HiveCatalogFactory.optionalOptions() |
Set<ConfigOption<?>> |
HiveCatalogFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Integer> |
SqlClientOptions.EXECUTION_MAX_TABLE_RESULT_ROWS |
static ConfigOption<ResultMode> |
SqlClientOptions.EXECUTION_RESULT_MODE |
static ConfigOption<Boolean> |
SqlClientOptions.VERBOSE |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Integer> |
SocketDynamicTableFactory.BYTE_DELIMITER |
static ConfigOption<String> |
ChangelogCsvFormatFactory.COLUMN_DELIMITER |
static ConfigOption<String> |
SocketDynamicTableFactory.HOSTNAME |
static ConfigOption<Integer> |
SocketDynamicTableFactory.PORT |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
SocketDynamicTableFactory.optionalOptions() |
Set<ConfigOption<?>> |
ChangelogCsvFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
SocketDynamicTableFactory.requiredOptions() |
Set<ConfigOption<?>> |
ChangelogCsvFormatFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
FactoryUtil.CONNECTOR |
static ConfigOption<String> |
DataGenOptions.FIELD_END
Placeholder
ConfigOption . |
static ConfigOption<String> |
DataGenOptions.FIELD_KIND
Placeholder
ConfigOption . |
static ConfigOption<Integer> |
DataGenOptions.FIELD_LENGTH
Placeholder
ConfigOption . |
static ConfigOption<String> |
DataGenOptions.FIELD_MAX
Placeholder
ConfigOption . |
static ConfigOption<String> |
DataGenOptions.FIELD_MIN
Placeholder
ConfigOption . |
static ConfigOption<String> |
DataGenOptions.FIELD_START
Placeholder
ConfigOption . |
static ConfigOption<String> |
FactoryUtil.FORMAT |
static ConfigOption<Long> |
DataGenOptions.NUMBER_OF_ROWS |
static ConfigOption<String> |
PrintTableSinkFactory.PRINT_IDENTIFIER |
static ConfigOption<Integer> |
FactoryUtil.PROPERTY_VERSION
Describes the property version.
|
static ConfigOption<Long> |
DataGenOptions.ROWS_PER_SECOND |
static ConfigOption<Integer> |
FactoryUtil.SINK_PARALLELISM |
static ConfigOption<Boolean> |
PrintTableSinkFactory.STANDARD_ERROR |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
DataGenTableSourceFactory.optionalOptions() |
Set<ConfigOption<?>> |
PrintTableSinkFactory.optionalOptions() |
Set<ConfigOption<?>> |
BlackHoleTableSinkFactory.optionalOptions() |
default Set<ConfigOption<?>> |
CatalogFactory.optionalOptions() |
Set<ConfigOption<?>> |
Factory.optionalOptions()
Returns a set of
ConfigOption that an implementation of this factory consumes in
addition to Factory.requiredOptions() . |
Set<ConfigOption<?>> |
DataGenTableSourceFactory.requiredOptions() |
Set<ConfigOption<?>> |
PrintTableSinkFactory.requiredOptions() |
Set<ConfigOption<?>> |
BlackHoleTableSinkFactory.requiredOptions() |
default Set<ConfigOption<?>> |
CatalogFactory.requiredOptions() |
Set<ConfigOption<?>> |
Factory.requiredOptions()
Returns a set of
ConfigOption that an implementation of this factory requires in
addition to Factory.optionalOptions() . |
Modifier and Type | Method and Description |
---|---|
<I,F extends DecodingFormatFactory<I>> |
FactoryUtil.TableFactoryHelper.discoverDecodingFormat(Class<F> formatFactoryClass,
ConfigOption<String> formatOption)
Discovers a
DecodingFormat of the given type using the given option as factory
identifier. |
<I,F extends EncodingFormatFactory<I>> |
FactoryUtil.TableFactoryHelper.discoverEncodingFormat(Class<F> formatFactoryClass,
ConfigOption<String> formatOption)
Discovers a
EncodingFormat of the given type using the given option as factory
identifier. |
<I,F extends DecodingFormatFactory<I>> |
FactoryUtil.TableFactoryHelper.discoverOptionalDecodingFormat(Class<F> formatFactoryClass,
ConfigOption<String> formatOption)
Discovers a
DecodingFormat of the given type using the given option (if present)
as factory identifier. |
<I,F extends EncodingFormatFactory<I>> |
FactoryUtil.TableFactoryHelper.discoverOptionalEncodingFormat(Class<F> formatFactoryClass,
ConfigOption<String> formatOption)
Discovers a
EncodingFormat of the given type using the given option (if present)
as factory identifier. |
Modifier and Type | Method and Description |
---|---|
static void |
FactoryUtil.validateFactoryOptions(Set<ConfigOption<?>> requiredOptions,
Set<ConfigOption<?>> optionalOptions,
ReadableConfig options)
Validates the required options and optional options.
|
static void |
FactoryUtil.validateFactoryOptions(Set<ConfigOption<?>> requiredOptions,
Set<ConfigOption<?>> optionalOptions,
ReadableConfig options)
Validates the required options and optional options.
|
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
DataGeneratorContainer.getOptions() |
Modifier and Type | Method and Description |
---|---|
static DataGeneratorContainer |
DataGeneratorContainer.of(DataGenerator generator,
ConfigOption<?>... options) |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
FileSystemTableFactory.optionalOptions() |
Set<ConfigOption<?>> |
FileSystemTableFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
RawFormatFactory.CHARSET |
static ConfigOption<String> |
RawFormatFactory.ENDIANNESS |
Modifier and Type | Method and Description |
---|---|
Set<ConfigOption<?>> |
RawFormatFactory.optionalOptions() |
Set<ConfigOption<?>> |
RawFormatFactory.requiredOptions() |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
StreamExecDeduplicate.TABLE_EXEC_INSERT_AND_UPDATE_AFTER_SENSITIVE |
static ConfigOption<Boolean> |
StreamExecSort.TABLE_EXEC_NON_TEMPORAL_SORT_ENABLED |
static ConfigOption<Long> |
StreamExecRank.TABLE_EXEC_TOPN_CACHE_SIZE |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Long> |
InternalConfigOptions.TABLE_QUERY_START_EPOCH_TIME |
static ConfigOption<Long> |
InternalConfigOptions.TABLE_QUERY_START_LOCAL_TIME |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Integer> |
YarnConfigOptions.APP_MASTER_VCORES
The vcores used by YARN application master.
|
static ConfigOption<Long> |
YarnConfigOptions.APPLICATION_ATTEMPT_FAILURE_VALIDITY_INTERVAL
The config parameter defining the attemptFailuresValidityInterval of Yarn application.
|
static ConfigOption<String> |
YarnConfigOptions.APPLICATION_ATTEMPTS
Set the number of retries for failed YARN ApplicationMasters/JobManagers in high availability
mode.
|
static ConfigOption<String> |
YarnConfigOptions.APPLICATION_ID |
static ConfigOption<String> |
YarnConfigOptionsInternal.APPLICATION_LOG_CONFIG_FILE |
static ConfigOption<String> |
YarnConfigOptions.APPLICATION_MASTER_PORT
The config parameter defining the Akka actor system port for the ApplicationMaster and
JobManager.
|
static ConfigOption<String> |
YarnConfigOptions.APPLICATION_NAME |
static ConfigOption<Integer> |
YarnConfigOptions.APPLICATION_PRIORITY
A non-negative integer indicating the priority for submitting a Flink YARN application.
|
static ConfigOption<String> |
YarnConfigOptions.APPLICATION_QUEUE |
static ConfigOption<String> |
YarnConfigOptions.APPLICATION_TAGS
A comma-separated list of strings to use as YARN application tags.
|
static ConfigOption<String> |
YarnConfigOptions.APPLICATION_TYPE |
static ConfigOption<YarnConfigOptions.UserJarInclusion> |
YarnConfigOptions.CLASSPATH_INCLUDE_USER_JAR
Defines whether user-jars are included in the system class path for per-job-clusters as well
as their positioning in the path.
|
static ConfigOption<Integer> |
YarnConfigOptions.CONTAINER_REQUEST_HEARTBEAT_INTERVAL_MILLISECONDS
The heartbeat interval between the Application Master and the YARN Resource Manager if Flink
is requesting containers.
|
static ConfigOption<String> |
YarnConfigOptions.EXTERNAL_RESOURCE_YARN_CONFIG_KEY
If configured, Flink will add this key to the resource profile of container request to Yarn.
|
static ConfigOption<Integer> |
YarnConfigOptions.FILE_REPLICATION
Yarn session client uploads flink jar and user libs to file system (hdfs/s3) as local
resource for yarn application context.
|
static ConfigOption<String> |
YarnConfigOptions.FLINK_DIST_JAR |
static ConfigOption<String> |
YarnConfigOptions.HADOOP_CONFIG_KEY |
static ConfigOption<Integer> |
YarnConfigOptions.HEARTBEAT_DELAY_SECONDS
The heartbeat interval between the Application Master and the YARN Resource Manager.
|
static ConfigOption<String> |
YarnConfigOptions.LOCALIZED_KEYTAB_PATH |
static ConfigOption<Boolean> |
YarnConfigOptionsInternal.MATCH_CONTAINER_VCORES
**DO NOT USE** Whether
YarnResourceManagerDriver should match
the vcores of allocated containers with those requested. |
static ConfigOption<String> |
YarnConfigOptions.NODE_LABEL |
static ConfigOption<String> |
YarnConfigOptions.PROPERTIES_FILE_LOCATION
When a Flink job is submitted to YARN, the JobManager's host and the number of available
processing slots is written into a properties file, so that the Flink client is able to pick
those details up.
|
static ConfigOption<List<String>> |
YarnConfigOptions.PROVIDED_LIB_DIRS |
static ConfigOption<List<String>> |
YarnConfigOptions.SHIP_ARCHIVES |
static ConfigOption<List<String>> |
YarnConfigOptions.SHIP_FILES |
static ConfigOption<Boolean> |
YarnConfigOptions.SHIP_LOCAL_KEYTAB |
static ConfigOption<String> |
YarnConfigOptions.STAGING_DIRECTORY |
static ConfigOption<Integer> |
YarnConfigOptions.VCORES
The vcores exposed by YARN.
|
static ConfigOption<List<String>> |
YarnConfigOptions.YARN_ACCESS |
static ConfigOption<String> |
YarnConfigOptions.YARN_CONFIG_KEY |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.