Uses of Class
org.apache.flink.table.watermark.WatermarkEmitStrategy
-
Packages that use WatermarkEmitStrategy Package Description org.apache.flink.table.factories org.apache.flink.table.runtime.generated org.apache.flink.table.watermark -
-
Uses of WatermarkEmitStrategy in org.apache.flink.table.factories
Fields in org.apache.flink.table.factories with type parameters of type WatermarkEmitStrategy Modifier and Type Field Description static ConfigOption<WatermarkEmitStrategy>
FactoryUtil. WATERMARK_EMIT_STRATEGY
-
Uses of WatermarkEmitStrategy in org.apache.flink.table.runtime.generated
Constructors in org.apache.flink.table.runtime.generated with parameters of type WatermarkEmitStrategy Constructor Description DefaultWatermarkGenerator(WatermarkGenerator watermarkGenerator, WatermarkEmitStrategy watermarkEmitStrategy)
-
Uses of WatermarkEmitStrategy in org.apache.flink.table.watermark
Methods in org.apache.flink.table.watermark that return WatermarkEmitStrategy Modifier and Type Method Description WatermarkEmitStrategy
WatermarkParams. getEmitStrategy()
static WatermarkEmitStrategy
WatermarkEmitStrategy. valueOf(String name)
Returns the enum constant of this type with the specified name.static WatermarkEmitStrategy[]
WatermarkEmitStrategy. values()
Returns an array containing the constants of this enum type, in the order they are declared.Methods in org.apache.flink.table.watermark with parameters of type WatermarkEmitStrategy Modifier and Type Method Description WatermarkParams.WatermarkParamsBuilder
WatermarkParams.WatermarkParamsBuilder. emitStrategy(WatermarkEmitStrategy emitStrategy)
void
WatermarkParams. setEmitStrategy(WatermarkEmitStrategy emitStrategy)
Constructors in org.apache.flink.table.watermark with parameters of type WatermarkEmitStrategy Constructor Description WatermarkParams(WatermarkEmitStrategy emitStrategy, String alignGroupName, Duration alignMaxDrift, Duration alignUpdateInterval, long sourceIdleTimeout)
-