Class and Description |
---|
Archiveable |
ArchivedExecutionConfig
Serializable class which is created when archiving the job.
|
CodeAnalysisMode
Deprecated.
The code analysis code has been removed and this enum has no effect.
|
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
This constraint indicates when a task should be scheduled considering its inputs status.
|
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 job manager.
|
JobSubmissionResult
The result of submitting a job to a JobManager.
|
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.
|
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.
|
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.
|
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.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
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.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
Plan
This class represents Flink programs, in the form of dataflow plans.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
ExecutionConfig.SerializableSerializer |
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig.GlobalJobParameters
Abstract class for a custom user configuration object registered at the execution config.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
JobExecutionResult
The result of a job 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 job manager.
|
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 job manager.
|
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 job manager.
|
Class and Description |
---|
ExecutionConfig.ClosureCleanerLevel
Configuration settings for the closure cleaner.
|
ExecutionConfig.GlobalJobParameters
Abstract class for a custom user configuration object registered at the execution config.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
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.
|
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 job manager.
|
JobSubmissionResult
The result of submitting a job to a JobManager.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ProgramDescription
Implementing this interface allows a Program to have a description
of the plan which can be shown to the user.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
Plan
This class represents Flink programs, in the form of dataflow plans.
|
Class and Description |
---|
ExecutionMode
The execution mode specifies how a batch program is executed in terms
of data exchange: pipelining or batched.
|
Class and Description |
---|
ExecutionMode
The execution mode specifies how a batch program is executed in terms
of data exchange: pipelining or batched.
|
Class and Description |
---|
Plan
This class represents Flink programs, in the form of dataflow plans.
|
Class and Description |
---|
Plan
This class represents Flink programs, in the form of dataflow plans.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
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.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program 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.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink 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 job manager.
|
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 job manager.
|
Class and Description |
---|
JobStatus
Possible states of a job once it has been accepted by the job manager.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink 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 job manager.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
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.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
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.
|
InputDependencyConstraint
This constraint indicates when a task should be scheduled considering its inputs status.
|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
JobStatus
Possible states of a job once it has been accepted by the job manager.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
ExecutionMode
The execution mode specifies how a batch program is executed in terms
of data exchange: pipelining or batched.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
InputDependencyConstraint
This constraint indicates when a task should be scheduled considering its inputs status.
|
InvalidProgramException
An exception thrown to indicate that the composed program is invalid.
|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
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 job manager.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink 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 job manager.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
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 job manager.
|
JobSubmissionResult
The result of submitting a job to a JobManager.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
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.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
ArchivedExecutionConfig
Serializable class which is created when archiving the job.
|
JobID
Unique (at least statistically unique) identifier for a Flink 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 job manager.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink 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 job manager.
|
Class and Description |
---|
InputDependencyConstraint
This constraint indicates when a task should be scheduled considering its inputs status.
|
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.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
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.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink 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 job manager.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program 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.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
JobExecutionResult
The result of a job execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program 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.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
JobExecutionResult
The result of a job execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
JobExecutionResult
The result of a job execution.
|
Class and Description |
---|
JobExecutionResult
The result of a job execution.
|
Class and Description |
---|
JobExecutionResult
The result of a job execution.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
JobExecutionResult
The result of a job execution.
|
Class and Description |
---|
JobExecutionResult
The result of a job execution.
|
Class and Description |
---|
JobExecutionResult
The result of a job execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
JobExecutionResult
The result of a job execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
JobExecutionResult
The result of a job execution.
|
Class and Description |
---|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.