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.DefaultJoin.WrappingFlatJoinFunction<IN1,IN2,OUT>
Wrapper around
JoinFunction . |
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. |
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>
Joiner that unwraps values from the left set before applying the join operation.
|
class |
TupleRightUnwrappingJoiner<I1,I2,OUT,K>
Joiner that unwraps values from the right set before applying the join operation.
|
class |
TupleUnwrappingJoiner<I1,I2,OUT,K>
Joiner that unwraps both values before applying the join operation.
|
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 | Class and Description |
---|---|
static class |
ConnectedComponents.ComponentIdFilter
Emit the candidate (Vertex-ID, Component-ID) pair if and only if the candidate component ID
is less than the vertex's current component ID.
|
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>> |
JoinWithSolutionSetFirstDriver.getStubType() |
Class<FlatJoinFunction<IT1,IT2,OT>> |
JoinDriver.getStubType() |
Class<FlatJoinFunction<IT1,IT2,OT>> |
JoinWithSolutionSetSecondDriver.getStubType() |
Class<FlatJoinFunction<IT1,IT2,OT>> |
AbstractOuterJoinDriver.getStubType() |
Modifier and Type | Method and Description |
---|---|
void |
JoinWithSolutionSetFirstDriver.setup(TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> context) |
void |
JoinDriver.setup(TaskContext<FlatJoinFunction<IT1,IT2,OT>,OT> context) |
void |
JoinWithSolutionSetSecondDriver.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 |
NonReusingBuildSecondHashJoinIterator.callWithNextKey(FlatJoinFunction<V1,V2,O> matchFunction,
Collector<O> collector) |
boolean |
NonReusingBuildFirstHashJoinIterator.callWithNextKey(FlatJoinFunction<V1,V2,O> matchFunction,
Collector<O> collector) |
boolean |
ReusingBuildFirstHashJoinIterator.callWithNextKey(FlatJoinFunction<V1,V2,O> matchFunction,
Collector<O> collector) |
Modifier and Type | Method and Description |
---|---|
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. |
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. |
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.
|
<T> SingleOutputStreamOperator<T> |
JoinedStreams.WithWindow.with(FlatJoinFunction<T1,T2,T> function)
Deprecated.
This method will be removed once the
JoinedStreams.WithWindow.apply(FlatJoinFunction) method
is fixed in the next major version of Flink (2.0). |
<T> SingleOutputStreamOperator<T> |
JoinedStreams.WithWindow.with(FlatJoinFunction<T1,T2,T> function,
TypeInformation<T> resultType)
Deprecated.
This method will be replaced by
JoinedStreams.WithWindow.apply(FlatJoinFunction,
TypeInformation) in Flink 2.0. So use the JoinedStreams.WithWindow.apply(FlatJoinFunction,
TypeInformation) in the future. |
Modifier and Type | Class and Description |
---|---|
class |
IntervalJoinFunction
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.