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.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<Boolean>	AUTO_GENERATE_UIDS
static ConfigOption<Boolean>	AUTO_TYPE_REGISTRATION
static ConfigOption<java.time.Duration>	AUTO_WATERMARK_INTERVAL
static ConfigOption<List<String>>	CACHED_FILES
static ConfigOption<List<String>>	CLASSPATHS A list of URLs that are added to the classpath of each user code classloader of the program.
static ConfigOption<ExecutionConfig.ClosureCleanerLevel>	CLOSURE_CLEANER_LEVEL
static ConfigOption<Boolean>	FORCE_AVRO
static ConfigOption<Boolean>	FORCE_KRYO
static ConfigOption<Boolean>	GENERIC_TYPES
static ConfigOption<Map<String,String>>	GLOBAL_JOB_PARAMETERS
static 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 ConfigOption<List<String>>	KRYO_DEFAULT_SERIALIZERS
static ConfigOption<List<String>>	KRYO_REGISTERED_CLASSES
static ConfigOption<Integer>	MAX_PARALLELISM
static ConfigOption<String>	NAME The job name used for printing and logging.
static ConfigOption<Boolean>	OBJECT_REUSE
static ConfigOption<Boolean>	OPERATOR_CHAINING
static ConfigOption<List<String>>	POJO_REGISTERED_CLASSES

Constructor Summary

Constructors

Constructor and Description
PipelineOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

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_TYPE_REGISTRATION

public static final ConfigOption<Boolean> AUTO_TYPE_REGISTRATION

AUTO_WATERMARK_INTERVAL

public static final ConfigOption<java.time.Duration> AUTO_WATERMARK_INTERVAL

CLOSURE_CLEANER_LEVEL

public static final ConfigOption<ExecutionConfig.ClosureCleanerLevel> CLOSURE_CLEANER_LEVEL

FORCE_AVRO

public static final ConfigOption<Boolean> FORCE_AVRO

FORCE_KRYO

public static final ConfigOption<Boolean> FORCE_KRYO

GENERIC_TYPES

public static final ConfigOption<Boolean> GENERIC_TYPES

GLOBAL_JOB_PARAMETERS

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

MAX_PARALLELISM

public static final ConfigOption<Integer> MAX_PARALLELISM

OBJECT_REUSE

public static final ConfigOption<Boolean> OBJECT_REUSE

KRYO_DEFAULT_SERIALIZERS

public static final ConfigOption<List<String>> KRYO_DEFAULT_SERIALIZERS

KRYO_REGISTERED_CLASSES

public static final ConfigOption<List<String>> KRYO_REGISTERED_CLASSES

POJO_REGISTERED_CLASSES

public static final ConfigOption<List<String>> POJO_REGISTERED_CLASSES

OPERATOR_CHAINING

public static final ConfigOption<Boolean> OPERATOR_CHAINING

CACHED_FILES

public static final ConfigOption<List<String>> CACHED_FILES

Constructor Detail

PipelineOptions

public PipelineOptions()