Uses of Package
org.apache.flink.api.common
-
Classes in org.apache.flink.api.common used by org.apache.flink.api.common Class Description Archiveable ArchivedExecutionConfig Serializable class which is created when archiving the job.BatchShuffleMode Defines how data is exchanged between tasks in batchExecutionOptions.RUNTIME_MODEif the shuffling behavior has not been set explicitly for an individual exchange.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 Deprecated.TheExecutionModeis deprecated because it's only used in DataSet APIs.InputDependencyConstraint Deprecated.InputDependencyConstraintis not used anymore and will be deleted in one of the future versions.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 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 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 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 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 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 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 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 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.connector.sink2 Class Description JobID Unique (at least statistically unique) identifier for a Flink Job. -
Classes in org.apache.flink.api.common used by org.apache.flink.api.java Class Description ExecutionConfig.ClosureCleanerLevel Configuration settings for the closure cleaner. -
Classes in org.apache.flink.api.common used by org.apache.flink.api.java.typeutils Class 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 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 Description ExecutionConfig A config to define the behavior of the program execution. -
Classes in org.apache.flink.api.common used by org.apache.flink.configuration Class Description BatchShuffleMode Defines how data is exchanged between tasks in batchExecutionOptions.RUNTIME_MODEif 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.core.execution Class 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.core.failure Class Description JobID Unique (at least statistically unique) identifier for a Flink Job.