Modifier and Type | Method and Description |
---|---|
<R> SingleOutputStreamOperator<R> |
ConnectedStreams.transform(String functionName,
TypeInformation<R> outTypeInfo,
TwoInputStreamOperator<IN1,IN2,R> operator) |
Modifier and Type | Method and Description |
---|---|
<IN1,IN2,OUT> |
StreamGraph.addCoOperator(Integer vertexID,
String slotSharingGroup,
TwoInputStreamOperator<IN1,IN2,OUT> taskOperatorObject,
TypeInformation<IN1> in1TypeInfo,
TypeInformation<IN2> in2TypeInfo,
TypeInformation<OUT> outTypeInfo,
String operatorName) |
Modifier and Type | Class and Description |
---|---|
class |
CoProcessOperator<K,IN1,IN2,OUT> |
class |
CoStreamFlatMap<IN1,IN2,OUT> |
class |
CoStreamMap<IN1,IN2,OUT> |
Modifier and Type | Method and Description |
---|---|
<R> DataStream<R> |
ConnectedStreams.transform(String functionName,
TwoInputStreamOperator<IN1,IN2,R> operator,
TypeInformation<R> evidence$9) |
Modifier and Type | Method and Description |
---|---|
TwoInputStreamOperator<IN1,IN2,OUT> |
TwoInputTransformation.getOperator()
Returns the
TwoInputStreamOperator of this Transformation. |
Constructor and Description |
---|
TwoInputTransformation(StreamTransformation<IN1> input1,
StreamTransformation<IN2> input2,
String name,
TwoInputStreamOperator<IN1,IN2,OUT> operator,
TypeInformation<OUT> outputType,
int parallelism)
Creates a new
TwoInputTransformation from the given inputs and operator. |
Modifier and Type | Method and Description |
---|---|
boolean |
StreamTwoInputProcessor.processInput(TwoInputStreamOperator<IN1,IN2,?> streamOperator,
Object lock) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.