Package com.here.platform.data.client.service.stream

Class StreamReferencedPartitionMessage

java.lang.Object

com.here.platform.data.client.service.stream.StreamPartitionMessage

com.here.platform.data.client.service.stream.StreamReferencedPartitionMessage

All Implemented Interfaces:

Partition, com.here.platform.data.client.scaladsl.Partition, com.here.platform.data.client.scaladsl.ReferenceData, HasCheckpointing, Serializable, scala.Equals, scala.Product

public class StreamReferencedPartitionMessage
extends StreamPartitionMessage
implements com.here.platform.data.client.scaladsl.ReferenceData, scala.Product, Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
StreamReferencedPartitionMessage(String layer, StreamMessage raw)

Method Summary

Modifier and Type	Method	Description
abstract static R	apply(T1 v1, T2 v2)
String	dataHandle()
Optional<CheckpointMark>	getCheckpoints()	Optional value for the stream record kafka offset
String	layer()
StreamMessage	raw()
static String	toString()

Methods inherited from class com.here.platform.data.client.service.stream.StreamPartitionMessage

additionalMetadata, apply, checkpoint, checksum, compressedDataSize, crc, dataSize, getAdditionalMetadata, getChecksum, getCompressedDataSize, getCrc, getDataSize, getLayer, getPartition, getTimestamp, isDeleted, offset, partition, streamPartition, timestamp, withCheckpoint

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

StreamReferencedPartitionMessage

public StreamReferencedPartitionMessage(String layer,
 StreamMessage raw)

Method Details

apply

public abstract static R apply(T1 v1,
 T2 v2)

toString

public static String toString()

layer

public String layer()

Specified by:

layer in interface com.here.platform.data.client.scaladsl.Partition

Specified by:

layer in interface com.here.platform.data.client.scaladsl.ReferenceData

raw

public StreamMessage raw()

dataHandle

public String dataHandle()

Specified by:

dataHandle in interface com.here.platform.data.client.scaladsl.ReferenceData

getCheckpoints

public Optional<CheckpointMark> getCheckpoints()

Description copied from interface: Partition

Optional value for the stream record kafka offset

Specified by:

getCheckpoints in interface Partition