Class and Description |
---|
FlinkILoop |
Class and Description |
---|
AggregateDataSet
The result of
DataSet.aggregate . |
ClosureCleaner$ |
CoGroupDataSet
A specific
DataSet that results from a coGroup operation. |
CrossDataSet
A specific
DataSet that results from a cross operation. |
CrossDataSet$ |
DataSet
The DataSet, the basic abstraction of Flink.
|
ExecutionEnvironment
The ExecutionEnviroment is the context in which a program is executed.
|
ExecutionEnvironment$ |
FlinkShell.Config
Configuration object
|
FlinkShell.Config$ |
FlinkShell.ExecutionMode$ |
FlinkShell.YarnConfig
YARN configuration object
|
FlinkShell.YarnConfig$ |
FlinkShell$ |
GroupedDataSet
A
DataSet to which a grouping key was added. |
HalfUnfinishedKeyPairOperation |
ILoopCompat |
JoinDataSet
A specific
DataSet that results from a join operation. |
JoinFunctionAssigner |
UnfinishedCoGroupOperation
An unfinished coGroup operation that results from
DataSet.coGroup The keys for the left and
right side must be specified using first where and then equalTo . |
UnfinishedJoinOperation
An unfinished inner join operation that results from calling
DataSet.join() . |
UnfinishedJoinOperationBase |
UnfinishedKeyPairOperation
This is for dealing with operations that require keys and use a fluent interface (join, and
coGroup for now).
|
UnfinishedOuterJoinOperation
An unfinished outer join operation that results from calling, e.g.
|
Class and Description |
---|
CoGroupDataSet
A specific
DataSet that results from a coGroup operation. |
CrossDataSet
A specific
DataSet that results from a cross operation. |
DataSet
The DataSet, the basic abstraction of Flink.
|
GroupedDataSet
A
DataSet to which a grouping key was added. |
HalfUnfinishedKeyPairOperation |
JoinFunctionAssigner |
UnfinishedKeyPairOperation
This is for dealing with operations that require keys and use a fluent interface (join, and
coGroup for now).
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
ExecutionEnvironment
The ExecutionEnviroment is the context in which a program is executed.
|
Class and Description |
---|
ExecutionEnvironment
The ExecutionEnviroment is the context in which a program is executed.
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
ExecutionEnvironment
The ExecutionEnviroment is the context in which a program is executed.
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
ExecutionEnvironment
The ExecutionEnviroment is the context in which a program is executed.
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
ExecutionEnvironment
The ExecutionEnviroment is the context in which a program is executed.
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
ExecutionEnvironment
The ExecutionEnviroment is the context in which a program is executed.
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
Class and Description |
---|
DataSet
The DataSet, the basic abstraction of Flink.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.