public class WatermarkGeneratorCodeGeneratorFunctionContextWrapper extends FunctionContext
FunctionContext
if the source supports SupportsWatermarkPushDown
.
See more in WatermarkGeneratorFunctionContext
.
Constructor and Description |
---|
WatermarkGeneratorCodeGeneratorFunctionContextWrapper(WatermarkGeneratorSupplier.Context context) |
Modifier and Type | Method and Description |
---|---|
MetricGroup |
getMetricGroup()
Returns the metric group for this parallel subtask.
|
getCachedFile, getExternalResourceInfos, getJobParameter, getUserCodeClassLoader
public WatermarkGeneratorCodeGeneratorFunctionContextWrapper(WatermarkGeneratorSupplier.Context context)
public MetricGroup getMetricGroup()
FunctionContext
getMetricGroup
in class FunctionContext
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.