Package com.here.platform.data.client.flink.impl

Class ContinuousSourceUtils.TimestampSplit

java.lang.Object

com.here.platform.data.client.flink.impl.ContinuousSourceUtils.TimestampSplit

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.SourceSplit

Enclosing class:

ContinuousSourceUtils

public static final class ContinuousSourceUtils.TimestampSplit
extends Object
implements org.apache.flink.api.connector.source.SourceSplit, Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
TimestampSplit(long timestamp)

Method Summary

Modifier and Type	Method	Description
String	splitId()
long	timestamp()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TimestampSplit

public TimestampSplit(long timestamp)

Method Details

timestamp

public long timestamp()

splitId

public String splitId()

Specified by:

splitId in interface org.apache.flink.api.connector.source.SourceSplit