Class WatermarkGeneratorCodeGeneratorFunctionContextWrapper
- java.lang.Object
-
- org.apache.flink.table.functions.FunctionContext
-
- org.apache.flink.table.runtime.generated.WatermarkGeneratorCodeGeneratorFunctionContextWrapper
-
public class WatermarkGeneratorCodeGeneratorFunctionContextWrapper extends FunctionContext
A function wrapper forFunctionContext
if the source supportsSupportsWatermarkPushDown
.See more in
WatermarkGeneratorFunctionContext
.
-
-
Constructor Summary
Constructors Constructor Description WatermarkGeneratorCodeGeneratorFunctionContextWrapper(WatermarkGeneratorSupplier.Context context)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description MetricGroup
getMetricGroup()
Returns the metric group for this parallel subtask.-
Methods inherited from class org.apache.flink.table.functions.FunctionContext
getCachedFile, getExternalResourceInfos, getJobParameter, getUserCodeClassLoader
-
-
-
-
Constructor Detail
-
WatermarkGeneratorCodeGeneratorFunctionContextWrapper
public WatermarkGeneratorCodeGeneratorFunctionContextWrapper(WatermarkGeneratorSupplier.Context context)
-
-
Method Detail
-
getMetricGroup
public MetricGroup getMetricGroup()
Description copied from class:FunctionContext
Returns the metric group for this parallel subtask.- Overrides:
getMetricGroup
in classFunctionContext
- Returns:
- metric group for this parallel subtask.
-
-