@Experimental public interface OneInputStreamProcessFunction<IN,OUT> extends ProcessFunction
Modifier and Type | Method and Description |
---|---|
default void |
endInput(NonPartitionedContext<OUT> ctx)
This is a life-cycle method indicates that this function will no longer receive any data from
the input.
|
default void |
onProcessingTimer(long timestamp,
Collector<OUT> output,
PartitionedContext ctx)
Callback for processing timer.
|
void |
processRecord(IN record,
Collector<OUT> output,
PartitionedContext ctx)
Process record and emit data through
Collector . |
close, open, usesStates
void processRecord(IN record, Collector<OUT> output, PartitionedContext ctx) throws Exception
Collector
.record
- to process.output
- to emit processed records.ctx
- runtime context in which this function is executed.Exception
default void endInput(NonPartitionedContext<OUT> ctx)
ctx
- the context in which this function is executed.default void onProcessingTimer(long timestamp, Collector<OUT> output, PartitionedContext ctx)
timestamp
- when this callback is triggered.output
- to emit record.ctx
- runtime context in which this function is executed.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.