@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.
|
void |
processRecord(IN record,
Collector<OUT> output,
RuntimeContext ctx)
Process record and emit data through
Collector . |
close, open
void processRecord(IN 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 endInput(NonPartitionedContext<OUT> ctx)
ctx
- the context in which this function is executed.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.