TimestampCollector (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.datastream.impl.common.TimestampCollector<OUT>

All Implemented Interfaces:

Collector<OUT>

Direct Known Subclasses:

KeyCheckedOutputCollector, OutputCollector, TwoOutputProcessOperator.SideOutputCollector
```
public abstract class TimestampCollector<OUT>
extends Object
implements Collector<OUT>
```
The base Collector which take care of records timestamp.

Field Summary

Fields
Modifier and Type Field Description

protected StreamRecord<OUT> reuse

Constructor Summary

Constructors
Constructor Description

TimestampCollector()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`eraseTimestamp()`
`void`	`setTimestamp(long timestamp)`
`void`	`setTimestampFromStreamRecord(StreamRecord<?> timestampBase)`

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

Methods inherited from interface org.apache.flink.datastream.api.common.Collector
collect, collectAndOverwriteTimestamp

Field Detail

reuse

protected final StreamRecord<OUT> reuse

Constructor Detail
- TimestampCollector
```
public TimestampCollector()
```

Method Detail

setTimestampFromStreamRecord

public void setTimestampFromStreamRecord(StreamRecord<?> timestampBase)

setTimestamp

public void setTimestamp(long timestamp)

eraseTimestamp
```
public void eraseTimestamp()
```