Modifier and Type | Class and Description |
---|---|
class |
ProcessFunction.OnTimerContext
Information available in an invocation of
ProcessFunction.onTimer(long, OnTimerContext, Collector) . |
Modifier and Type | Method and Description |
---|---|
abstract void |
ProcessFunction.processElement(I value,
ProcessFunction.Context ctx,
Collector<O> out)
Process one element from the input stream.
|
Modifier and Type | Method and Description |
---|---|
void |
SideOutputExample.Tokenizer.processElement(String value,
ProcessFunction.Context ctx,
Collector<Tuple2<String,Integer>> out) |
Modifier and Type | Method and Description |
---|---|
void |
CRowProcessRunner.processElement(CRow in,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
CRowCorrelateProcessRunner.processElement(CRow in,
ProcessFunction.Context ctx,
Collector<CRow> out) |
Modifier and Type | Method and Description |
---|---|
void |
RowTimeBoundedRangeOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
ProcTimeBoundedRowsOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
ProcTimeBoundedRangeOver.processElement(CRow input,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
RowTimeBoundedRowsOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
GroupAggProcessFunction.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
ProcTimeUnboundedOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
RowTimeUnboundedOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out)
Puts an element from the input stream into state if it is not late.
|
protected void |
ProcessFunctionWithCleanupState.registerProcessingCleanupTimer(ProcessFunction.Context ctx,
long currentTime) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.