public class CheckpointStorageLocationReference extends Object implements Serializable
The reference is represented via raw bytes, which are subject to interpretation by the state backends. We did not add any more typing and serialization abstraction in between, because these types need to serialize/deserialize fast in between network streams (byte buffers) and barriers. We may ultimately add some more typing if we simply keep the byte buffers for the checkpoint barriers and forward them, thus saving decoding and re-encoding these references repeatedly.
Constructor and Description |
---|
CheckpointStorageLocationReference(byte[] encodedReference)
Creates a new location reference.
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
static CheckpointStorageLocationReference |
getDefault() |
byte[] |
getReferenceBytes()
Gets the reference bytes.
|
int |
hashCode() |
boolean |
isDefaultReference()
Returns true, if this object is the default reference.
|
protected Object |
readResolve()
readResolve() preserves the singleton property of the default value.
|
String |
toString() |
public CheckpointStorageLocationReference(byte[] encodedReference)
encodedReference
- The location reference, represented as bytes (non null)public byte[] getReferenceBytes()
Important: For efficiency, this method does not make a defensive copy, so the caller must not modify the bytes in the array.
public boolean isDefaultReference()
protected final Object readResolve() throws ObjectStreamException
ObjectStreamException
public static CheckpointStorageLocationReference getDefault()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.