WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder |
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder.combineFunctionAND() |
Propagate the logical AND combination result of boolean watermarks downstream.
|
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder |
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder.combineFunctionOR() |
Propagate the logical OR combination result of boolean watermarks downstream.
|
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder |
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder.combineWaitForAllChannels(boolean combineWaitForAllChannels) |
Whether the combine process should be executed after the process function receives
watermarks from both upstream channels.
|
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder |
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder.defaultHandlingStrategy(WatermarkHandlingStrategy strategy) |
|
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder |
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder.defaultHandlingStrategyForward() |
|
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder |
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder.defaultHandlingStrategyIgnore() |
|
WatermarkDeclarations.WatermarkDeclarationBuilder.BoolWatermarkDeclarationBuilder |
WatermarkDeclarations.WatermarkDeclarationBuilder.typeBool() |
|