@Experimental public interface TwoInputNonBroadcastStreamProcessFunction<IN1,IN2,OUT> extends ProcessFunction
Modifier and Type | Method and Description |
---|---|
default void |
endFirstInput(NonPartitionedContext<OUT> ctx)
This is a life-cycle method indicates that this function will no longer receive any data from
the first input.
|
default void |
endSecondInput(NonPartitionedContext<OUT> ctx)
This is a life-cycle method indicates that this function will no longer receive any data from
the second input.
|
void |
processRecordFromFirstInput(IN1 record,
Collector<OUT> output,
RuntimeContext ctx)
Process record from the first input and emit data through
Collector . |
void |
processRecordFromSecondInput(IN2 record,
Collector<OUT> output,
RuntimeContext ctx)
Process record from the second input and emit data through
Collector . |
close, open
void processRecordFromFirstInput(IN1 record, Collector<OUT> output, RuntimeContext ctx) throws Exception
Collector
.record
- to process.output
- to emit processed records.ctx
- runtime context in which this function is executed.Exception
void processRecordFromSecondInput(IN2 record, Collector<OUT> output, RuntimeContext ctx) throws Exception
Collector
.record
- to process.output
- to emit processed records.ctx
- runtime context in which this function is executed.Exception
default void endFirstInput(NonPartitionedContext<OUT> ctx)
ctx
- the context in which this function is executed.default void endSecondInput(NonPartitionedContext<OUT> ctx)
ctx
- the context in which this function is executed.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.