public class StreamingString extends AbstractStreamEvent
Constructor and Description |
---|
StreamingString() |
Modifier and Type | Method and Description |
---|---|
Object |
getPartitionKey()
Return the partitioning key used for partitioning a stream.
|
String |
getValue() |
protected void |
readValues(DataInputStream dis)
Read values specific to the data type from the input stream.
|
void |
setValue(String value) |
protected void |
writeValues(DataOutputStream dataOutputStream)
Write data type specific values to the output stream.
|
marshall, marshallAsBatch, unmarshall, unmarshallAsBatch
getStreamId, setStreamId
public String getValue()
public void setValue(String value)
protected void readValues(DataInputStream dis) throws IOException
AbstractStreamEvent
readValues
in class AbstractStreamEvent
dis
- DataInputStream containing the byte array.IOException
- Error when reading from input stream.protected void writeValues(DataOutputStream dataOutputStream) throws IOException
AbstractStreamEvent
writeValues
in class AbstractStreamEvent
dataOutputStream
- Output stream containing used to write the serialized
representation of an object.IOException
- Error when writing to output stream.public Object getPartitionKey()
StreamEvent
getPartitionKey
in class StreamEvent
Copyright © 2015. All rights reserved.