Package org.apache.flink.api.scala

Interface Summary

Interface	Description
JoinFunctionAssigner<L,R>

Class Summary

Class	Description
AggregateDataSet<T>	The result of DataSet.aggregate.
ClosureCleaner
ClosureCleaner$
CoGroupDataSet<L,R>	A specific DataSet that results from a coGroup operation.
CrossDataSet<L,R>	A specific DataSet that results from a cross operation.
CrossDataSet$
DataSet<T>	The DataSet, the basic abstraction of Flink.
ExecutionEnvironment	The ExecutionEnviroment is the context in which a program is executed.
ExecutionEnvironment$
FieldAccessFinder
FlinkILoop
FlinkShell
FlinkShell.ExecutionMode$
FlinkShell$
GroupedDataSet<T>	A DataSet to which a grouping key was added.
HalfUnfinishedKeyPairOperation<L,R,O>
ILoopCompat
InnerClosureFinder
JoinDataSet<L,R>	A specific DataSet that results from a join operation.
PartitionSortedDataSet<T>	The result of DataSet.sortPartition.
ReturnStatementFinder
UnfinishedCoGroupOperation<L,R>	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<L,R>	An unfinished inner join operation that results from calling DataSet.join().
UnfinishedJoinOperationBase<L,R,O extends JoinFunctionAssigner<L,R>>
UnfinishedKeyPairOperation<L,R,O>	This is for dealing with operations that require keys and use a fluent interface (join, and coGroup for now).
UnfinishedOuterJoinOperation<L,R>	An unfinished outer join operation that results from calling, e.g.