Package | Description |
---|---|
org.apache.flink.api.scala | |
org.apache.flink.api.scala.extensions.impl.acceptPartialFunctions |
Modifier and Type | Method and Description |
---|---|
<K> HalfUnfinishedKeyPairOperation<L,R,O> |
UnfinishedKeyPairOperation.where(scala.Function1<L,K> fun,
TypeInformation<K> evidence$1)
Specify the key selector function for the left side of the key based operation.
|
HalfUnfinishedKeyPairOperation<L,R,O> |
UnfinishedKeyPairOperation.where(scala.collection.Seq<Object> leftKeys)
Specify the key fields for the left side of the key based operation.
|
HalfUnfinishedKeyPairOperation<L,R,O> |
UnfinishedKeyPairOperation.where(String firstLeftField,
scala.collection.Seq<String> otherLeftFields)
Specify the key fields for the left side of the key based operation.
|
Modifier and Type | Method and Description |
---|---|
<K> HalfUnfinishedKeyPairOperation<L,R,O> |
OnUnfinishedKeyPairOperation.whereClause(scala.Function1<L,K> fun,
TypeInformation<K> evidence$1)
Initiates a join or co-group operation, defining the first half of
the where clause with the items of the left data set that will be
checked for equality with the ones provided by the second half.
|
Constructor and Description |
---|
OnHalfUnfinishedKeyPairOperation(HalfUnfinishedKeyPairOperation<L,R,O> ds) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.