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

Class StreamEmbeddedPartitionMessage

java.lang.Object

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

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

All Implemented Interfaces:

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

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

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
StreamEmbeddedPartitionMessage(String layer, StreamMessage raw, boolean isCompressed)

Method Summary

Modifier and Type	Method	Description
abstract static R	apply(T1 v1, T2 v2, T3 v3)
byte[]	data()
scala.Option<Object>	dataSize()
Optional<CheckpointMark>	getCheckpoints()	Optional value for the stream record kafka offset
boolean	isCompressed()
String	layer()
StreamMessage	raw()
static String	toString()

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

additionalMetadata, checkpoint, checksum, compressedDataSize, crc, 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

StreamEmbeddedPartitionMessage

public StreamEmbeddedPartitionMessage(String layer,
 StreamMessage raw,
 boolean isCompressed)

Method Details

apply

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

toString

public static String toString()

layer

public String layer()

Specified by:

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

raw

public StreamMessage raw()

isCompressed

public boolean isCompressed()

data

public byte[] data()

Specified by:

data in interface com.here.platform.data.client.scaladsl.EmbeddedData

dataSize

public scala.Option<Object> dataSize()

Specified by:

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

Overrides:

dataSize in class StreamPartitionMessage

getCheckpoints

public Optional<CheckpointMark> getCheckpoints()

Description copied from interface: Partition

Optional value for the stream record kafka offset

Specified by:

getCheckpoints in interface Partition