Modifier and Type | Class and Description |
---|---|
class |
RichFlatJoinFunction<IN1,IN2,OUT>
Rich variant of the
FlatJoinFunction . |
Modifier and Type | Class and Description |
---|---|
class |
InnerJoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>> |
class |
JoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>> |
class |
OuterJoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>> |
Modifier and Type | Class and Description |
---|---|
static class |
JoinOperator.DefaultFlatJoinFunction<T1,T2> |
static class |
JoinOperator.DefaultJoin.WrappingFlatJoinFunction<IN1,IN2,OUT> |
static class |
JoinOperator.ProjectFlatJoinFunction<T1,T2,R extends Tuple> |
Modifier and Type | Method and Description |
---|---|
protected FlatJoinFunction<I1,I2,OUT> |
JoinOperator.EquiJoin.getFunction() |
Modifier and Type | Method and Description |
---|---|
<R> JoinOperator.EquiJoin<I1,I2,R> |
JoinOperator.DefaultJoin.with(FlatJoinFunction<I1,I2,R> function)
Finalizes a Join transformation by applying a
RichFlatJoinFunction to each pair of joined elements.Each JoinFunction call returns exactly one element. |
Modifier and Type | Method and Description |
---|---|
<R> JoinOperator<I1,I2,R> |
JoinFunctionAssigner.with(FlatJoinFunction<I1,I2,R> joinFunction) |
Modifier and Type | Class and Description |
---|---|
class |
TupleLeftUnwrappingJoiner<I1,I2,OUT,K> |
class |
TupleRightUnwrappingJoiner<I1,I2,OUT,K> |
class |
TupleUnwrappingJoiner<I1,I2,OUT,K> |
Constructor and Description |
---|
TupleLeftUnwrappingJoiner(FlatJoinFunction<I1,I2,OUT> wrapped) |
TupleRightUnwrappingJoiner(FlatJoinFunction<I1,I2,OUT> wrapped) |
TupleUnwrappingJoiner(FlatJoinFunction<I1,I2,OUT> wrapped) |
Modifier and Type | Method and Description |
---|---|
static <IN1,IN2,OUT> |
TypeExtractor.getFlatJoinReturnTypes(FlatJoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type) |
static <IN1,IN2,OUT> |
TypeExtractor.getFlatJoinReturnTypes(FlatJoinFunction<IN1,IN2,OUT> joinInterface,
TypeInformation<IN1> in1Type,
TypeInformation<IN2> in2Type,
String functionName,
boolean allowMissing) |
Modifier and Type | Method and Description |
---|---|
<O> DataSet<O> |
JoinDataSet.apply(FlatJoinFunction<L,R,O> joiner,
TypeInformation<O> evidence$5,
scala.reflect.ClassTag<O> evidence$6)
Creates a new
DataSet by passing each pair of joined values to the given function. |
<O> DataSet<O> |
JoinFunctionAssigner.apply(FlatJoinFunction<L,R,O> fun,
TypeInformation<O> evidence$24,
scala.reflect.ClassTag<O> evidence$25) |
Modifier and Type | Class and Description |
---|---|
class |
FlatJoinRunner<IN1,IN2,OUT> |
Modifier and Type | Class and Description |
---|---|
static class |
ConnectedComponents.ComponentIdFilter |
Modifier and Type | Field and Description |
---|---|
protected TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> |
JoinDriver.taskContext |
protected TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> |
AbstractOuterJoinDriver.taskContext |
Modifier and Type | Method and Description |
---|---|
Class<FlatJoinFunction<IT1,IT2,OT>> |
JoinWithSolutionSetSecondDriver.getStubType() |
Class<FlatJoinFunction<IT1,IT2,OT>> |
JoinWithSolutionSetFirstDriver.getStubType() |
Class<FlatJoinFunction<IT1,IT2,OT>> |
JoinDriver.getStubType() |
Class<FlatJoinFunction<IT1,IT2,OT>> |
AbstractOuterJoinDriver.getStubType() |
Modifier and Type | Method and Description |
---|---|
void |
JoinWithSolutionSetSecondDriver.setup(TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> context) |
void |
JoinWithSolutionSetFirstDriver.setup(TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> context) |
void |
JoinDriver.setup(TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> context) |
void |
AbstractOuterJoinDriver.setup(TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> context) |
Modifier and Type | Method and Description |
---|---|
boolean |
ReusingBuildSecondHashJoinIterator.callWithNextKey(FlatJoinFunction<V1,V2,O> matchFunction,
Collector<O> collector) |
boolean |
ReusingBuildFirstHashJoinIterator.callWithNextKey(FlatJoinFunction<V1,V2,O> matchFunction,
Collector<O> collector) |
boolean |
NonReusingBuildSecondHashJoinIterator.callWithNextKey(FlatJoinFunction<V1,V2,O> matchFunction,
Collector<O> collector) |
boolean |
NonReusingBuildFirstHashJoinIterator.callWithNextKey(FlatJoinFunction<V1,V2,O> matchFunction,
Collector<O> collector) |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractMergeOuterJoinIterator.callWithNextKey(FlatJoinFunction<T1,T2,O> joinFunction,
Collector<O> collector)
Calls the
JoinFunction#join() method for all two key-value pairs that share the same key and come
from different inputs. |
abstract boolean |
AbstractMergeIterator.callWithNextKey(FlatJoinFunction<T1,T2,O> joinFunction,
Collector<O> collector)
Calls the
JoinFunction#join() method for all two key-value pairs that share the same key and come
from different inputs. |
boolean |
AbstractMergeInnerJoinIterator.callWithNextKey(FlatJoinFunction<T1,T2,O> joinFunction,
Collector<O> collector)
Calls the
JoinFunction#join() method for all two key-value pairs that share the same key and come
from different inputs. |
protected void |
AbstractMergeIterator.crossMatchingGroup(Iterator<T1> values1,
Iterator<T2> values2,
FlatJoinFunction<T1,T2,O> joinFunction,
Collector<O> collector) |
Modifier and Type | Method and Description |
---|---|
boolean |
JoinTaskIterator.callWithNextKey(FlatJoinFunction<V1,V2,O> matchFunction,
Collector<O> collector)
Moves the internal pointer to the next key that both inputs share.
|
Modifier and Type | Method and Description |
---|---|
<T> DataStream<T> |
JoinedStreams.WithWindow.apply(FlatJoinFunction<T1,T2,T> function)
Completes the join operation with the user function that is executed
for each combination of elements with the same key in a window.
|
<T> DataStream<T> |
JoinedStreams.WithWindow.apply(FlatJoinFunction<T1,T2,T> function,
TypeInformation<T> resultType)
Completes the join operation with the user function that is executed
for each combination of elements with the same key in a window.
|
Modifier and Type | Method and Description |
---|---|
<T> DataStream<T> |
JoinedStreams.Where.EqualTo.WithWindow.apply(FlatJoinFunction<T1,T2,T> function,
TypeInformation<T> evidence$5)
Completes the join operation with the user function that is executed
for windowed groups.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.