Class and Description |
---|
Archiveable |
ArchivedExecutionConfig
Serializable class which is created when archiving the job.
|
CodeAnalysisMode
Specifies to which extent user-defined functions are analyzed in order
to give the Flink optimizer an insight of UDF internals and inform
the user about common implementation mistakes.
|
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.
|
ExecutionConfig.SerializableSerializer |
ExecutionMode
The execution mode specifies how a batch program is executed in terms
of data exchange: pipelining or batched.
|
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.
|
JobSubmissionResult
The result of submitting a job to a JobManager.
|
Plan
This class represents Flink programs, in the form of dataflow plans.
|
PlanExecutor
A PlanExecutor executes a Flink program's dataflow plan.
|
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.
|
JobExecutionResult
The result of a job execution.
|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Plan
This class represents Flink programs, in the form of dataflow plans.
|
PlanExecutor
A PlanExecutor executes a Flink program's dataflow plan.
|
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.
|
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 |
---|
ExecutionConfig
A config to define the behavior of the program execution.
|
Class and Description |
---|
JobExecutionResult
The result of a job execution.
|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Plan
This class represents Flink programs, in the form of dataflow plans.
|
PlanExecutor
A PlanExecutor executes a Flink program's dataflow plan.
|
Program
A Program represents and end-to-end Flink program.
|
Class and Description |
---|
JobExecutionResult
The result of a job execution.
|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
JobSubmissionResult
The result of submitting a job to a JobManager.
|
Plan
This class represents Flink programs, in the form of dataflow plans.
|
Class and Description |
---|
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 |
---|
ProgramDescription
Implementing this interface allows a Program to have a description
of the plan which can be shown to the user.
|
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 |
---|
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 |
---|
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 |
---|
JobExecutionResult
The result of a job 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 |
---|
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.
|
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.
|
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.
|
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 |
---|
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 |
---|
JobExecutionResult
The result of a job execution.
|
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
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 |
---|
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 |
---|
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.
|
Class and Description |
---|
JobExecutionResult
The result of a job 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 |
---|
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 |
---|
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 |
---|
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 |
---|
JobSubmissionResult
The result of submitting a job to a JobManager.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.