com.hazelcast.cp.internal.datastructures.spi.atomic

Class RaftAtomicValueSnapshot<T>

java.lang.Object

com.hazelcast.cp.internal.datastructures.spi.atomic.RaftAtomicValueSnapshot<T>

All Implemented Interfaces:

DataSerializable, IdentifiedDataSerializable

Direct Known Subclasses:

AtomicLongSnapshot, AtomicRefSnapshot

public abstract class RaftAtomicValueSnapshot<T>
extends Object
implements IdentifiedDataSerializable

Snapshot of a RaftAtomicValueService state for a Raft group

Field Summary

Fields

Modifier and Type	Field and Description
protected Set<String>	destroyed
protected Map<String,T>	values

Constructor Summary

Constructors

Constructor and Description
RaftAtomicValueSnapshot()
RaftAtomicValueSnapshot(Map<String,T> values, Set<String> destroyed)

Method Summary

Modifier and Type	Method and Description
Set<String>	getDestroyed()
Iterable<Map.Entry<String,T>>	getValues()
void	readData(ObjectDataInput in) Reads fields from the input stream
protected abstract T	readValue(ObjectDataInput in)
void	writeData(ObjectDataOutput out) Writes object fields to output stream
protected abstract void	writeValue(ObjectDataOutput out, T value)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

getClassId, getFactoryId

Field Detail

values

protected Map<String,T> values

destroyed

protected Set<String> destroyed

Constructor Detail

RaftAtomicValueSnapshot

public RaftAtomicValueSnapshot()

RaftAtomicValueSnapshot

public RaftAtomicValueSnapshot(Map<String,T> values,
                               Set<String> destroyed)

Method Detail

getValues

public Iterable<Map.Entry<String,T>> getValues()

getDestroyed

public Set<String> getDestroyed()

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Parameters:

out - output

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.

writeValue

protected abstract void writeValue(ObjectDataOutput out,
                                   T value)
                            throws IOException

Throws:

IOException

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Parameters:

in - input

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the input stream has been closed.

readValue

protected abstract T readValue(ObjectDataInput in)
                        throws IOException

Throws:

IOException