Uses of Package
org.apache.flink.api.common

Packages that use org.apache.flink.api.common

Package	Description
org.apache.flink.api.common
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.operators
org.apache.flink.api.common.operators.base
org.apache.flink.api.common.serialization
org.apache.flink.api.common.state
org.apache.flink.api.common.typeinfo
org.apache.flink.api.common.typeutils
org.apache.flink.api.java
org.apache.flink.api.java.io
org.apache.flink.api.java.operators
org.apache.flink.api.java.operators.translation
org.apache.flink.api.java.typeutils
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.api.java.typeutils.runtime.kryo
org.apache.flink.api.java.utils
org.apache.flink.api.scala.operators
org.apache.flink.client
org.apache.flink.client.deployment
org.apache.flink.client.deployment.application
org.apache.flink.client.deployment.application.executors
org.apache.flink.client.program
org.apache.flink.client.program.rest
org.apache.flink.configuration
org.apache.flink.connector.file.sink.compactor.operator
org.apache.flink.connector.jdbc.internal
org.apache.flink.connector.jdbc.xa	Provides exactly-once JDBC sink implementation using Java XA transactions API (JTA).
org.apache.flink.connector.pulsar.common.config
org.apache.flink.connector.pulsar.common.schema
org.apache.flink.connector.pulsar.sink.config
org.apache.flink.connector.pulsar.source.config
org.apache.flink.connector.pulsar.source.reader.deserializer
org.apache.flink.connector.testframe.utils
org.apache.flink.contrib.streaming.state
org.apache.flink.core.execution
org.apache.flink.formats.avro.typeutils
org.apache.flink.formats.avro.utils
org.apache.flink.graph.drivers.transform
org.apache.flink.graph.examples
org.apache.flink.graph.types.valuearray
org.apache.flink.kubernetes.highavailability
org.apache.flink.optimizer
org.apache.flink.optimizer.dag
org.apache.flink.optimizer.dataproperties
org.apache.flink.optimizer.plan
org.apache.flink.optimizer.plandump
org.apache.flink.optimizer.plantranslate
org.apache.flink.optimizer.traversals	This package contains the various traversals over the program plan and the optimizer DAG (directed acyclic graph) that are made in the course of the optimization.
org.apache.flink.optimizer.util
org.apache.flink.python.env
org.apache.flink.python.env.embedded
org.apache.flink.python.env.process
org.apache.flink.queryablestate.client
org.apache.flink.queryablestate.client.proxy
org.apache.flink.queryablestate.messages
org.apache.flink.runtime.accumulators
org.apache.flink.runtime.blob
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.client
org.apache.flink.runtime.clusterframework	This package contains the cluster resource management functionality.
org.apache.flink.runtime.deployment
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.dispatcher.cleanup
org.apache.flink.runtime.dispatcher.runner
org.apache.flink.runtime.execution
org.apache.flink.runtime.execution.librarycache
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.filecache
org.apache.flink.runtime.highavailability
org.apache.flink.runtime.highavailability.nonha.embedded
org.apache.flink.runtime.highavailability.nonha.standalone
org.apache.flink.runtime.highavailability.zookeeper
org.apache.flink.runtime.history
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.jobgraph.jsonplan
org.apache.flink.runtime.jobgraph.tasks
org.apache.flink.runtime.jobmanager
org.apache.flink.runtime.jobmanager.slots
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.factories
org.apache.flink.runtime.jobmaster.slotpool
org.apache.flink.runtime.messages	This package contains the messages that are sent between Flink's distributed components to coordinate the distributed operations.
org.apache.flink.runtime.messages.checkpoint	This package contains the messages that are sent between JobMaster and TaskExecutor to coordinate the checkpoint snapshots of the distributed dataflow.
org.apache.flink.runtime.messages.webmonitor	This package contains the actor messages that are sent between the JobManager and components that are interested in the status of the JobManager.
org.apache.flink.runtime.metrics.groups
org.apache.flink.runtime.metrics.scope
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.chaining
org.apache.flink.runtime.operators.sort
org.apache.flink.runtime.operators.util
org.apache.flink.runtime.query
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.registration
org.apache.flink.runtime.resourcemanager.slotmanager
org.apache.flink.runtime.rest.handler.job
org.apache.flink.runtime.rest.handler.legacy
org.apache.flink.runtime.rest.messages
org.apache.flink.runtime.rest.messages.job
org.apache.flink.runtime.rest.messages.job.metrics
org.apache.flink.runtime.rest.messages.json
org.apache.flink.runtime.rest.messages.taskmanager
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adaptive
org.apache.flink.runtime.scheduler.metrics
org.apache.flink.runtime.scheduler.stopwithsavepoint
org.apache.flink.runtime.shuffle
org.apache.flink.runtime.slots
org.apache.flink.runtime.state
org.apache.flink.runtime.state.filesystem
org.apache.flink.runtime.state.hashmap
org.apache.flink.runtime.state.heap	This package contains the classes for key/value state backends that store the state on the JVM heap as objects.
org.apache.flink.runtime.state.memory
org.apache.flink.runtime.state.storage
org.apache.flink.runtime.taskexecutor
org.apache.flink.runtime.taskexecutor.exceptions
org.apache.flink.runtime.taskexecutor.rpc
org.apache.flink.runtime.taskexecutor.slot
org.apache.flink.runtime.taskmanager
org.apache.flink.runtime.util
org.apache.flink.runtime.webmonitor
org.apache.flink.runtime.webmonitor.handlers
org.apache.flink.runtime.webmonitor.stats
org.apache.flink.runtime.webmonitor.threadinfo
org.apache.flink.state.api.input.operator
org.apache.flink.state.api.runtime
org.apache.flink.state.changelog
org.apache.flink.streaming.api.connector.sink2
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.environment
org.apache.flink.streaming.api.functions.aggregation
org.apache.flink.streaming.api.functions.sink
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.sort
org.apache.flink.streaming.api.operators.sorted.state
org.apache.flink.streaming.api.typeinfo.python
org.apache.flink.streaming.api.windowing.assigners
org.apache.flink.streaming.examples.wordcount.util
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.io.recovery
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.streaming.tests
org.apache.flink.streaming.util.functions
org.apache.flink.streaming.util.keys
org.apache.flink.streaming.util.serialization
org.apache.flink.streaming.util.typeutils
org.apache.flink.table.catalog
org.apache.flink.table.dataview
org.apache.flink.table.delegation
org.apache.flink.table.executor.python
org.apache.flink.table.planner.delegation
org.apache.flink.table.planner.utils
org.apache.flink.table.runtime.operators.window.assigners
org.apache.flink.table.runtime.typeutils
org.apache.flink.table.types.logical
org.apache.flink.table.typeutils
org.apache.flink.table.utils.python
org.apache.flink.test.util
org.apache.flink.tests.util.flink
org.apache.flink.tests.util.flink.container

Classes in org.apache.flink.api.common used by org.apache.flink.api.common

Class and Description
Archiveable
ArchivedExecutionConfig Serializable class which is created when archiving the job.
BatchShuffleMode Defines how data is exchanged between tasks in batch ExecutionOptions.RUNTIME_MODE if the shuffling behavior has not been set explicitly for an individual exchange.
CodeAnalysisMode Deprecated. The code analysis code has been removed and this enum has no effect. NOTE It can not be removed from the codebase for now, because it had been serialized as part of the ExecutionConfig which in turn had been serialized as part of the PojoSerializer. This class can be removed when we drop support for pre 1.8 serializer snapshots that contained java serialized serializers (TypeSerializerConfigSnapshot).
ExecutionConfig A config to define the behavior of the program execution.
ExecutionConfig.ClosureCleanerLevel Configuration settings for the closure cleaner.
ExecutionConfig.GlobalJobParameters Abstract class for a custom user configuration object registered at the execution config.
ExecutionConfig.SerializableSerializer
ExecutionMode The execution mode specifies how a batch program is executed in terms of data exchange: pipelining or batched.
InputDependencyConstraint Deprecated. InputDependencyConstraint is not used anymore and will be deleted in one of the future versions. It was previously used in the scheduler implementations that were removed as part of FLINK-20589.
InvalidProgramException An exception thrown to indicate that the composed program is invalid.
JobExecutionResult The result of a job execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.
JobSubmissionResult The result of submitting a job to a JobManager.
RuntimeExecutionMode Runtime execution mode of DataStream programs.

Classes in org.apache.flink.api.common used by org.apache.flink.api.common.functions

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
InvalidProgramException An exception thrown to indicate that the composed program is invalid.
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.api.common.functions.util

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
TaskInfo Encapsulates task-specific information: name, index of subtask, parallelism and attempt number.

Classes in org.apache.flink.api.common used by org.apache.flink.api.common.operators

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
InvalidProgramException An exception thrown to indicate that the composed program is invalid.
JobExecutionResult The result of a job execution.
Plan This class represents Flink programs, in the form of dataflow plans.

Classes in org.apache.flink.api.common used by org.apache.flink.api.common.operators.base

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
InvalidProgramException An exception thrown to indicate that the composed program is invalid.

Classes in org.apache.flink.api.common used by org.apache.flink.api.common.serialization

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.api.common.state

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.api.common.typeinfo

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.api.common.typeutils

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.api.java

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
ExecutionConfig.ClosureCleanerLevel Configuration settings for the closure cleaner.
JobExecutionResult The result of a job execution.
Plan This class represents Flink programs, in the form of dataflow plans.

Classes in org.apache.flink.api.common used by org.apache.flink.api.java.io

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.api.java.operators

Class and Description
Plan This class represents Flink programs, in the form of dataflow plans.

Classes in org.apache.flink.api.common used by org.apache.flink.api.java.operators.translation

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.api.java.typeutils

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.api.java.typeutils.runtime

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
ExecutionConfig.SerializableSerializer

Classes in org.apache.flink.api.common used by org.apache.flink.api.java.typeutils.runtime.kryo

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.api.java.utils

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
ExecutionConfig.GlobalJobParameters Abstract class for a custom user configuration object registered at the execution config.
Plan This class represents Flink programs, in the form of dataflow plans.

Classes in org.apache.flink.api.common used by org.apache.flink.api.scala.operators

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.client

Class and Description
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.client.deployment

Class and Description
JobExecutionResult The result of a job execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.client.deployment.application

Class and Description
JobExecutionResult The result of a job execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.client.deployment.application.executors

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.client.program

Class and Description
JobExecutionResult The result of a job execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.client.program.rest

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.configuration

Class and Description
BatchShuffleMode Defines how data is exchanged between tasks in batch ExecutionOptions.RUNTIME_MODE if the shuffling behavior has not been set explicitly for an individual exchange.
ExecutionConfig.ClosureCleanerLevel Configuration settings for the closure cleaner.
ExecutionConfig.GlobalJobParameters Abstract class for a custom user configuration object registered at the execution config.
RuntimeExecutionMode Runtime execution mode of DataStream programs.

Classes in org.apache.flink.api.common used by org.apache.flink.connector.file.sink.compactor.operator

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.connector.jdbc.internal

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.connector.jdbc.xa

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.connector.pulsar.common.config

Class and Description
ExecutionConfig.GlobalJobParameters Abstract class for a custom user configuration object registered at the execution config.

Classes in org.apache.flink.api.common used by org.apache.flink.connector.pulsar.common.schema

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.connector.pulsar.sink.config

Class and Description
ExecutionConfig.GlobalJobParameters Abstract class for a custom user configuration object registered at the execution config.

Classes in org.apache.flink.api.common used by org.apache.flink.connector.pulsar.source.config

Class and Description
ExecutionConfig.GlobalJobParameters Abstract class for a custom user configuration object registered at the execution config.

Classes in org.apache.flink.api.common used by org.apache.flink.connector.pulsar.source.reader.deserializer

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.connector.testframe.utils

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.contrib.streaming.state

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.core.execution

Class and Description
JobExecutionResult The result of a job execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.
JobSubmissionResult The result of submitting a job to a JobManager.

Classes in org.apache.flink.api.common used by org.apache.flink.formats.avro.typeutils

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.formats.avro.utils

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.graph.drivers.transform

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.graph.examples

Class and Description
ProgramDescription Implementing this interface allows a Program to have a description of the plan which can be shown to the user.

Classes in org.apache.flink.api.common used by org.apache.flink.graph.types.valuearray

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.kubernetes.highavailability

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.optimizer

Class and Description
Plan This class represents Flink programs, in the form of dataflow plans.

Classes in org.apache.flink.api.common used by org.apache.flink.optimizer.dag

Class and Description
ExecutionMode The execution mode specifies how a batch program is executed in terms of data exchange: pipelining or batched.

Classes in org.apache.flink.api.common used by org.apache.flink.optimizer.dataproperties

Class and Description
ExecutionMode The execution mode specifies how a batch program is executed in terms of data exchange: pipelining or batched.

Classes in org.apache.flink.api.common used by org.apache.flink.optimizer.plan

Class and Description
Plan This class represents Flink programs, in the form of dataflow plans.

Classes in org.apache.flink.api.common used by org.apache.flink.optimizer.plandump

Class and Description
Plan This class represents Flink programs, in the form of dataflow plans.

Classes in org.apache.flink.api.common used by org.apache.flink.optimizer.plantranslate

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.optimizer.traversals

Class and Description
ExecutionMode The execution mode specifies how a batch program is executed in terms of data exchange: pipelining or batched.
Plan This class represents Flink programs, in the form of dataflow plans.

Classes in org.apache.flink.api.common used by org.apache.flink.optimizer.util

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.python.env

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.python.env.embedded

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.python.env.process

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.queryablestate.client

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.queryablestate.client.proxy

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.queryablestate.messages

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.accumulators

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.blob

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.checkpoint

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.client

Class and Description
JobExecutionResult The result of a job execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.clusterframework

Class and Description
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.deployment

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.dispatcher

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.dispatcher.cleanup

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.dispatcher.runner

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.execution

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
TaskInfo Encapsulates task-specific information: name, index of subtask, parallelism and attempt number.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.execution.librarycache

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.executiongraph

Class and Description
Archiveable
ArchivedExecutionConfig Serializable class which is created when archiving the job.
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.filecache

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.highavailability

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.highavailability.nonha.embedded

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.highavailability.nonha.standalone

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.highavailability.zookeeper

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.history

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.io.network

Class and Description
ExecutionMode The execution mode specifies how a batch program is executed in terms of data exchange: pipelining or batched.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.io.network.partition

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.jobgraph

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
InvalidProgramException An exception thrown to indicate that the composed program is invalid.
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.jobgraph.jsonplan

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.jobgraph.tasks

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.jobmanager

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.jobmanager.slots

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.jobmaster

Class and Description
JobExecutionResult The result of a job execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.jobmaster.factories

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.jobmaster.slotpool

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.messages

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.messages.checkpoint

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.messages.webmonitor

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.metrics.groups

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.metrics.scope

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.minicluster

Class and Description
JobExecutionResult The result of a job execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.
JobSubmissionResult The result of submitting a job to a JobManager.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.operators

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.operators.chaining

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.operators.sort

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.operators.util

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
TaskInfo Encapsulates task-specific information: name, index of subtask, parallelism and attempt number.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.query

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.resourcemanager

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.resourcemanager.registration

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.resourcemanager.slotmanager

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.rest.handler.job

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.rest.handler.legacy

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.rest.messages

Class and Description
ArchivedExecutionConfig Serializable class which is created when archiving the job.
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.rest.messages.job

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.rest.messages.job.metrics

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.rest.messages.json

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.rest.messages.taskmanager

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.scheduler

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.scheduler.adaptive

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.scheduler.metrics

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.scheduler.stopwithsavepoint

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.shuffle

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.slots

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.state

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.state.filesystem

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.state.hashmap

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.state.heap

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.state.memory

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.state.storage

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.taskexecutor

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.taskexecutor.exceptions

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.taskexecutor.rpc

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.taskexecutor.slot

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.taskmanager

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
TaskInfo Encapsulates task-specific information: name, index of subtask, parallelism and attempt number.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.util

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.webmonitor

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.
JobStatus Possible states of a job once it has been accepted by the dispatcher.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.webmonitor.handlers

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.webmonitor.stats

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.runtime.webmonitor.threadinfo

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.state.api.input.operator

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.state.api.runtime

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.
TaskInfo Encapsulates task-specific information: name, index of subtask, parallelism and attempt number.

Classes in org.apache.flink.api.common used by org.apache.flink.state.changelog

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.connector.sink2

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.datastream

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.environment

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobExecutionResult The result of a job execution.
RuntimeExecutionMode Runtime execution mode of DataStream programs.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.functions.aggregation

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.functions.sink

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.functions.source

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.graph

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.operators

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.operators.sort

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.operators.sorted.state

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.typeinfo.python

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.windowing.assigners

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.examples.wordcount.util

Class and Description
ExecutionConfig.GlobalJobParameters Abstract class for a custom user configuration object registered at the execution config.
RuntimeExecutionMode Runtime execution mode of DataStream programs.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.runtime.io

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
TaskInfo Encapsulates task-specific information: name, index of subtask, parallelism and attempt number.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.runtime.io.recovery

Class and Description
TaskInfo Encapsulates task-specific information: name, index of subtask, parallelism and attempt number.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.runtime.operators.windowing

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.runtime.tasks

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.tests

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.util.functions

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.util.keys

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.util.serialization

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.streaming.util.typeutils

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.table.catalog

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.table.dataview

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.table.delegation

Class and Description
JobExecutionResult The result of a job execution.

Classes in org.apache.flink.api.common used by org.apache.flink.table.executor.python

Class and Description
JobExecutionResult The result of a job execution.

Classes in org.apache.flink.api.common used by org.apache.flink.table.planner.delegation

Class and Description
JobExecutionResult The result of a job execution.

Classes in org.apache.flink.api.common used by org.apache.flink.table.planner.utils

Class and Description
ExecutionConfig A config to define the behavior of the program execution.
JobExecutionResult The result of a job execution.

Classes in org.apache.flink.api.common used by org.apache.flink.table.runtime.operators.window.assigners

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.table.runtime.typeutils

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.table.types.logical

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.table.typeutils

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.table.utils.python

Class and Description
ExecutionConfig A config to define the behavior of the program execution.

Classes in org.apache.flink.api.common used by org.apache.flink.test.util

Class and Description
JobExecutionResult The result of a job execution.

Classes in org.apache.flink.api.common used by org.apache.flink.tests.util.flink

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.

Classes in org.apache.flink.api.common used by org.apache.flink.tests.util.flink.container

Class and Description
JobID Unique (at least statistically unique) identifier for a Flink Job.