Modifier and Type | Method and Description |
---|---|
IterationRuntimeContext |
RichFunction.getIterationRuntimeContext()
Gets a specialized version of the
RuntimeContext , which has additional information
about the iteration in which the function is executed. |
IterationRuntimeContext |
AbstractRichFunction.getIterationRuntimeContext() |
Modifier and Type | Method and Description |
---|---|
void |
SumFunction.init(IterationRuntimeContext iterationRuntimeContext) |
void |
GatherFunction.init(IterationRuntimeContext iterationRuntimeContext) |
void |
ApplyFunction.init(IterationRuntimeContext iterationRuntimeContext) |
Modifier and Type | Method and Description |
---|---|
IterationRuntimeContext |
ScalaWindowFunctionWrapper.getIterationRuntimeContext() |
IterationRuntimeContext |
ScalaAllWindowFunctionWrapper.getIterationRuntimeContext() |
Modifier and Type | Method and Description |
---|---|
IterationRuntimeContext |
FlinkKafkaProducer010.getIterationRuntimeContext()
This method is used for approach (a) (see above)
|
Modifier and Type | Method and Description |
---|---|
IterationRuntimeContext |
InternalSingleValueWindowFunction.getIterationRuntimeContext() |
IterationRuntimeContext |
InternalSingleValueAllWindowFunction.getIterationRuntimeContext() |
IterationRuntimeContext |
InternalIterableWindowFunction.getIterationRuntimeContext() |
IterationRuntimeContext |
InternalIterableAllWindowFunction.getIterationRuntimeContext() |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.