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.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.JobInfo TheJobInforepresents the meta information of current 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.TaskInfo TheTaskInforepresents the meta information of current task. -
Classes in org.apache.flink.api.common used by org.apache.flink.api.common.functions Class Description InvalidProgramException An exception thrown to indicate that the composed program is invalid.JobInfo TheJobInforepresents the meta information of current job.TaskInfo TheTaskInforepresents the meta information of current task. -
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.JobInfo TheJobInforepresents the meta information of current job.TaskInfo TheTaskInforepresents the meta information of current task. -
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.SerializableSerializer The wrapper to make serializer serializable. -
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.state.v2 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 JobInfo TheJobInforepresents the meta information of current job.TaskInfo TheTaskInforepresents the meta information of current task. -
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 SerializableSerializer The wrapper to make serializer serializable. -
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. -
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 JobInfo TheJobInforepresents the meta information of current job. -
Classes in org.apache.flink.api.common used by org.apache.flink.streaming.api.operators 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.util Class Description ExecutionConfig.GlobalJobParameters Abstract class for a custom user configuration object registered at the execution config.JobID Unique (at least statistically unique) identifier for a Flink Job.