Class WatermarkGeneratorCodeGeneratorFunctionContextWrapper


  • public class WatermarkGeneratorCodeGeneratorFunctionContextWrapper
    extends org.apache.flink.table.functions.FunctionContext
    A function wrapper for FunctionContext if the source supports SupportsWatermarkPushDown.

    See more in WatermarkGeneratorFunctionContext.

    • Constructor Detail

      • WatermarkGeneratorCodeGeneratorFunctionContextWrapper

        public WatermarkGeneratorCodeGeneratorFunctionContextWrapper​(org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier.Context context)
    • Method Detail

      • getMetricGroup

        public org.apache.flink.metrics.MetricGroup getMetricGroup()
        Overrides:
        getMetricGroup in class org.apache.flink.table.functions.FunctionContext