```
public class Epoch<OUT>
extends Object
```
All inputs are segment into distinct epochs, marked by the arrival of non-record inputs. Records are assigned to a unique epoch based on their arrival.

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close(Runnable advanceWatermark)`	Close this epoch.
`void`	`collect(org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<OUT> resultFuture)`	Add resultFuture to the output queue.
`void`	`decrementCount()`
`boolean`	`equals(Object obj)`
`void`	`free()`
`int`	`getOngoingRecordCount()`
`org.apache.flink.streaming.api.watermark.Watermark`	`getWatermark()`
`int`	`hashCode()`
`void`	`incrementCount()`
`void`	`setOutput(Consumer<org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<OUT>> outputConsumer)`
`String`	`toString()`

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

public Epoch(org.apache.flink.streaming.api.watermark.Watermark watermark)

public void collect(org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<OUT> resultFuture)

Add resultFuture to the output queue.

public void setOutput(Consumer<org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<OUT>> outputConsumer)

public org.apache.flink.streaming.api.watermark.Watermark getWatermark()

public void close(Runnable advanceWatermark)

Close this epoch.

@VisibleForTesting
public int getOngoingRecordCount()

Class Epoch<OUT>