@Experimental public interface TwoOutputStreamProcessFunction<IN,OUT1,OUT2> extends ProcessFunction
Modifier and Type | Method and Description |
---|---|
default void |
endInput(TwoOutputNonPartitionedContext<OUT1,OUT2> ctx)
This is a life-cycle method indicates that this function will no longer receive any input
data.
|
void |
processRecord(IN record,
Collector<OUT1> output1,
Collector<OUT2> output2,
RuntimeContext ctx)
Process and emit record to the first/second output through
Collector s. |
close, open
void processRecord(IN record, Collector<OUT1> output1, Collector<OUT2> output2, RuntimeContext ctx) throws Exception
Collector
s.record
- to process.output1
- to emit processed records to the first output.output2
- to emit processed records to the second output.ctx
- runtime context in which this function is executed.Exception
default void endInput(TwoOutputNonPartitionedContext<OUT1,OUT2> ctx)
ctx
- the context in which this function is executed.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.