public class ByteStreamStateHandle extends Object implements StreamStateHandle
Modifier and Type | Field and Description |
---|---|
protected byte[] |
data
The state data.
|
protected String |
handleName
A unique name of by which this state handle is identified and compared.
|
Constructor and Description |
---|
ByteStreamStateHandle(String handleName,
byte[] data)
Creates a new ByteStreamStateHandle containing the given data.
|
Modifier and Type | Method and Description |
---|---|
void |
discardState()
Discards the state referred to by this handle, to free up resources in
the persistent storage.
|
boolean |
equals(Object o) |
byte[] |
getData() |
String |
getHandleName() |
long |
getStateSize()
Returns the size of the state in bytes.
|
int |
hashCode() |
FSDataInputStream |
openInputStream()
Returns an
FSDataInputStream that can be used to read back the data that
was previously written to the stream. |
protected final byte[] data
protected final String handleName
ByteStreamStateHandle
with the exact same name must also have the exact same content in data.public ByteStreamStateHandle(String handleName, byte[] data)
public FSDataInputStream openInputStream() throws IOException
StreamStateHandle
FSDataInputStream
that can be used to read back the data that
was previously written to the stream.openInputStream
in interface StreamStateHandle
IOException
public byte[] getData()
public String getHandleName()
public void discardState()
StateObject
discardState
in interface StateObject
public long getStateSize()
StateObject
If the the size is not known, return 0
.
getStateSize
in interface StateObject
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.