IndexedCombinedWatermarkStatus (Flink : Core 1.20.2-cp1 API)

java.lang.Object
- org.apache.flink.api.common.eventtime.IndexedCombinedWatermarkStatus

```
@Internal
public final class IndexedCombinedWatermarkStatus
extends Object
```
Represents combined value and status of a watermark for a set number of input partial watermarks.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static IndexedCombinedWatermarkStatus`	`forInputsCount(int inputsCount)`
`long`	`getCombinedWatermark()`
`boolean`	`isIdle()`
`boolean`	`updateStatus(int index, boolean idle)`	Updates the idleness for the given partial watermark.
`boolean`	`updateWatermark(int index, long timestamp)`	Updates the value for the given partial watermark.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - forInputsCount
```
public static IndexedCombinedWatermarkStatus forInputsCount(int inputsCount)
```
  - updateWatermark
```
public boolean updateWatermark(int index,
                               long timestamp)
```
    Updates the value for the given partial watermark. Can update both the global idleness as well as the combined watermark value.
    
    Returns:
    
    true, if the combined watermark value changed. The global idleness needs to be checked separately via isIdle()
  - getCombinedWatermark
```
public long getCombinedWatermark()
```
  - updateStatus
```
public boolean updateStatus(int index,
                            boolean idle)
```
    Updates the idleness for the given partial watermark. Can update both the global idleness as well as the combined watermark value.
    
    Returns:
    
    true, if the combined watermark value changed. The global idleness needs to be checked separately via isIdle()
  - isIdle
```
public boolean isIdle()
```