ds.granules.streaming.core.datatype

Class AbstractStreamEvent

java.lang.Object

ds.granules.dataset.StreamEvent

ds.granules.streaming.core.datatype.AbstractStreamEvent

Direct Known Subclasses:

StreamingString

public abstract class AbstractStreamEvent
extends StreamEvent

Abstracts out the boilerplate code from different data type implementations for Granules streaming API.

Author:

: Thilina Buddhika

Constructor Summary

Constructors

Constructor and Description
AbstractStreamEvent()

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	marshall() Convert a StreamTuple object into a byte[] for communication.
void	marshallAsBatch(DataOutputStream dataOutputStream)
protected abstract void	readValues(DataInputStream dataInputStream) Read values specific to the data type from the input stream.
void	unmarshall(byte[] bytes) Populate a StreamTuple object from a byte array.
void	unmarshallAsBatch(DataInputStream dataInputStream)
protected abstract void	writeValues(DataOutputStream dataOutputStream) Write data type specific values to the output stream.

Methods inherited from class ds.granules.dataset.StreamEvent

getPartitionKey, getStreamId, setStreamId

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractStreamEvent

public AbstractStreamEvent()

Method Detail

unmarshall

public void unmarshall(byte[] bytes)
                throws IOException

Description copied from class: StreamEvent

Populate a StreamTuple object from a byte array.

Specified by:

unmarshall in class StreamEvent

Parameters:

bytes - byte array offered by the communication layer.

Throws:

IOException

marshall

public byte[] marshall()
                throws IOException

Description copied from class: StreamEvent

Convert a StreamTuple object into a byte[] for communication.

Specified by:

marshall in class StreamEvent

Returns:

byte array generated after serialization.

Throws:

IOException

readValues

protected abstract void readValues(DataInputStream dataInputStream)
                            throws IOException

Read values specific to the data type from the input stream.

Parameters:

dataInputStream - DataInputStream containing the byte array.

Throws:

IOException - Error when reading from input stream.

writeValues

protected abstract void writeValues(DataOutputStream dataOutputStream)
                             throws IOException

Write data type specific values to the output stream.

Parameters:

dataOutputStream - Output stream containing used to write the serialized representation of an object.

Throws:

IOException - Error when writing to output stream.

marshallAsBatch

public void marshallAsBatch(DataOutputStream dataOutputStream)
                     throws IOException

Specified by:

marshallAsBatch in class StreamEvent

Throws:

IOException

unmarshallAsBatch

public void unmarshallAsBatch(DataInputStream dataInputStream)
                       throws IOException

Specified by:

unmarshallAsBatch in class StreamEvent

Throws:

IOException