@Experimental public interface TwoInputBroadcastStreamProcessFunction<IN1,IN2,OUT> extends ProcessFunction
Modifier and Type | Method and Description |
---|---|
default void |
endBroadcastInput(NonPartitionedContext<OUT> ctx)
This is a life-cycle method indicates that this function will no longer receive any data from
the broadcast input.
|
default void |
endNonBroadcastInput(NonPartitionedContext<OUT> ctx)
This is a life-cycle method indicates that this function will no longer receive any data from
the non-broadcast input.
|
void |
processRecordFromBroadcastInput(IN2 record,
NonPartitionedContext<OUT> ctx)
Process record from broadcast input.
|
void |
processRecordFromNonBroadcastInput(IN1 record,
Collector<OUT> output,
RuntimeContext ctx)
Process record from non-broadcast input and emit data through
Collector . |
close, open
void processRecordFromNonBroadcastInput(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 processRecordFromBroadcastInput(IN2 record, NonPartitionedContext<OUT> ctx) throws Exception
record
- to process.ctx
- the context in which this function is executed.Exception
default void endNonBroadcastInput(NonPartitionedContext<OUT> ctx)
ctx
- the context in which this function is executed.default void endBroadcastInput(NonPartitionedContext<OUT> ctx)
ctx
- the context in which this function is executed.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.