| Modifier and Type | Method and Description |
|---|---|
<R> SingleOutputStreamOperator<R> |
ConnectedStreams.transform(String functionName,
org.apache.flink.api.common.typeinfo.TypeInformation<R> outTypeInfo,
TwoInputStreamOperator<IN1,IN2,R> operator) |
| Modifier and Type | Method and Description |
|---|---|
<IN1,IN2,OUT> |
StreamGraph.addCoOperator(Integer vertexID,
String slotSharingGroup,
String coLocationGroup,
TwoInputStreamOperator<IN1,IN2,OUT> taskOperatorObject,
org.apache.flink.api.common.typeinfo.TypeInformation<IN1> in1TypeInfo,
org.apache.flink.api.common.typeinfo.TypeInformation<IN2> in2TypeInfo,
org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outTypeInfo,
String operatorName) |
| Modifier and Type | Class and Description |
|---|---|
class |
CoBroadcastWithKeyedOperator<KS,IN1,IN2,OUT>
A
TwoInputStreamOperator for executing KeyedBroadcastProcessFunctions. |
class |
CoBroadcastWithNonKeyedOperator<IN1,IN2,OUT>
A
TwoInputStreamOperator for executing BroadcastProcessFunctions. |
class |
CoProcessOperator<IN1,IN2,OUT>
A
StreamOperator for executing
CoProcessFunctions. |
class |
CoStreamFlatMap<IN1,IN2,OUT>
StreamOperator for processing
CoFlatMapFunctions. |
class |
CoStreamMap<IN1,IN2,OUT>
StreamOperator for processing
CoMapFunctions. |
class |
IntervalJoinOperator<K,T1,T2,OUT>
An
operator to execute time-bounded stream inner joins. |
class |
KeyedCoProcessOperator<K,IN1,IN2,OUT>
A
StreamOperator for executing keyed
CoProcessFunctions. |
| 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,
org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType,
int parallelism)
Creates a new
TwoInputTransformation from the given inputs and operator. |
| Constructor and Description |
|---|
StreamTwoInputProcessor(Collection<org.apache.flink.runtime.io.network.partition.consumer.InputGate> inputGates1,
Collection<org.apache.flink.runtime.io.network.partition.consumer.InputGate> inputGates2,
org.apache.flink.api.common.typeutils.TypeSerializer<IN1> inputSerializer1,
org.apache.flink.api.common.typeutils.TypeSerializer<IN2> inputSerializer2,
TwoInputStreamTask<IN1,IN2,?> checkpointedTask,
CheckpointingMode checkpointMode,
Object lock,
org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
org.apache.flink.configuration.Configuration taskManagerConfig,
StreamStatusMaintainer streamStatusMaintainer,
TwoInputStreamOperator<IN1,IN2,?> streamOperator,
org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup metrics,
WatermarkGauge input1WatermarkGauge,
WatermarkGauge input2WatermarkGauge) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.