Package | Description |
---|---|
org.apache.flink.api.scala | |
org.apache.flink.api.scala.extensions.impl.acceptPartialFunctions |
Modifier and Type | Class and Description |
---|---|
class |
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 . |
class |
UnfinishedJoinOperation<L,R>
An unfinished inner join operation that results from calling
DataSet.join() . |
class |
UnfinishedJoinOperationBase<L,R,O extends JoinFunctionAssigner<L,R>> |
class |
UnfinishedOuterJoinOperation<L,R>
An unfinished outer join operation that results from calling, e.g.
|
Constructor and Description |
---|
HalfUnfinishedKeyPairOperation(UnfinishedKeyPairOperation<L,R,O> unfinished,
Keys<L> leftKey) |
Constructor and Description |
---|
OnUnfinishedKeyPairOperation(UnfinishedKeyPairOperation<L,R,O> ds) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.