Package org.apache.flink.configuration

Class PipelineOptions

java.lang.Object

org.apache.flink.configuration.PipelineOptions

@PublicEvolving
public class PipelineOptions
extends Object

The configuration options for job execution.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	PipelineOptions.VertexDescriptionMode	The mode how we organize description of a vertex.

Field Summary

Fields

Modifier and Type	Field	Description
static final ConfigOption<Boolean>	ALLOW_UNALIGNED_SOURCE_SPLITS	Will be removed in future Flink releases.
static final ConfigOption<Boolean>	AUTO_GENERATE_UIDS
static final ConfigOption<Duration>	AUTO_WATERMARK_INTERVAL
static final ConfigOption<List<String>>	CACHED_FILES
static final ConfigOption<List<String>>	CLASSPATHS	A list of URLs that are added to the classpath of each user code classloader of the program.
static final ConfigOption<org.apache.flink.api.common.ExecutionConfig.ClosureCleanerLevel>	CLOSURE_CLEANER_LEVEL
static final ConfigOption<Boolean>	FORCE_AVRO
static final ConfigOption<Boolean>	FORCE_KRYO
static final ConfigOption<Boolean>	FORCE_KRYO_AVRO
static final ConfigOption<Boolean>	GENERIC_TYPES
static final ConfigOption<Map<String,String>>	GLOBAL_JOB_PARAMETERS
static final ConfigOption<List<String>>	JARS	A list of jar files that contain the user-defined function (UDF) classes and all classes used from within the UDFs.
static final ConfigOption<Integer>	MAX_PARALLELISM
static final ConfigOption<String>	NAME	The job name used for printing and logging.
static final ConfigOption<Boolean>	OBJECT_REUSE
static final ConfigOption<Boolean>	OPERATOR_CHAINING
static final ConfigOption<Boolean>	OPERATOR_CHAINING_CHAIN_OPERATORS_WITH_DIFFERENT_MAX_PARALLELISM
static final ConfigOption<Map<String,String>>	PARALLELISM_OVERRIDES
static final ConfigOption<List<String>>	SERIALIZATION_CONFIG
static final ConfigOption<PipelineOptions.VertexDescriptionMode>	VERTEX_DESCRIPTION_MODE
static final ConfigOption<Boolean>	VERTEX_NAME_INCLUDE_INDEX_PREFIX
static final ConfigOption<Integer>	WATERMARK_ALIGNMENT_BUFFER_SIZE

Constructor Summary

Constructors

Constructor	Description
PipelineOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

NAME

public static final ConfigOption<String> NAME

The job name used for printing and logging.

JARS

public static final ConfigOption<List<String>> JARS

A list of jar files that contain the user-defined function (UDF) classes and all classes used from within the UDFs.

CLASSPATHS

public static final ConfigOption<List<String>> CLASSPATHS

A list of URLs that are added to the classpath of each user code classloader of the program. Paths must specify a protocol (e.g. file://) and be accessible on all nodes

AUTO_GENERATE_UIDS

public static final ConfigOption<Boolean> AUTO_GENERATE_UIDS

AUTO_WATERMARK_INTERVAL

public static final ConfigOption<Duration> AUTO_WATERMARK_INTERVAL

CLOSURE_CLEANER_LEVEL

public static final ConfigOption<org.apache.flink.api.common.ExecutionConfig.ClosureCleanerLevel> CLOSURE_CLEANER_LEVEL

FORCE_AVRO

public static final ConfigOption<Boolean> FORCE_AVRO

FORCE_KRYO

public static final ConfigOption<Boolean> FORCE_KRYO

FORCE_KRYO_AVRO

public static final ConfigOption<Boolean> FORCE_KRYO_AVRO

GENERIC_TYPES

public static final ConfigOption<Boolean> GENERIC_TYPES

GLOBAL_JOB_PARAMETERS

public static final ConfigOption<Map<String,String>> GLOBAL_JOB_PARAMETERS

PARALLELISM_OVERRIDES

public static final ConfigOption<Map<String,String>> PARALLELISM_OVERRIDES

MAX_PARALLELISM

public static final ConfigOption<Integer> MAX_PARALLELISM

OBJECT_REUSE

public static final ConfigOption<Boolean> OBJECT_REUSE

SERIALIZATION_CONFIG

public static final ConfigOption<List<String>> SERIALIZATION_CONFIG

OPERATOR_CHAINING

public static final ConfigOption<Boolean> OPERATOR_CHAINING

OPERATOR_CHAINING_CHAIN_OPERATORS_WITH_DIFFERENT_MAX_PARALLELISM

public static final ConfigOption<Boolean> OPERATOR_CHAINING_CHAIN_OPERATORS_WITH_DIFFERENT_MAX_PARALLELISM

CACHED_FILES

public static final ConfigOption<List<String>> CACHED_FILES

VERTEX_DESCRIPTION_MODE

public static final ConfigOption<PipelineOptions.VertexDescriptionMode> VERTEX_DESCRIPTION_MODE

VERTEX_NAME_INCLUDE_INDEX_PREFIX

public static final ConfigOption<Boolean> VERTEX_NAME_INCLUDE_INDEX_PREFIX

ALLOW_UNALIGNED_SOURCE_SPLITS

public static final ConfigOption<Boolean> ALLOW_UNALIGNED_SOURCE_SPLITS

Will be removed in future Flink releases.

WATERMARK_ALIGNMENT_BUFFER_SIZE

@Experimental
public static final ConfigOption<Integer> WATERMARK_ALIGNMENT_BUFFER_SIZE

Constructor Details

PipelineOptions

public PipelineOptions()