co.cask.cdap.data2.transaction.snapshot

Class AbstractSnapshotCodec

java.lang.Object

co.cask.cdap.data2.transaction.snapshot.AbstractSnapshotCodec

All Implemented Interfaces:

co.cask.tephra.snapshot.SnapshotCodec

Direct Known Subclasses:

SnapshotCodecV1, SnapshotCodecV2

public abstract class AbstractSnapshotCodec
extends Object
implements co.cask.tephra.snapshot.SnapshotCodec

Handles serialization/deserialization of a TransactionSnapshot and its elements to byte[].

Constructor Summary

Constructors

Constructor and Description
AbstractSnapshotCodec()

Method Summary

Methods

Modifier and Type	Method and Description
co.cask.tephra.persist.TransactionSnapshot	decode(InputStream in)
protected abstract NavigableMap<Long,co.cask.tephra.TransactionManager.InProgressTx>	decodeInProgress(co.cask.tephra.snapshot.BinaryDecoder decoder)
protected void	decodeObsoleteAttributes(co.cask.tephra.snapshot.BinaryDecoder decoder) Deprecated.
co.cask.tephra.persist.TransactionVisibilityState	decodeTransactionVisibilityState(InputStream in)
void	encode(OutputStream out, co.cask.tephra.persist.TransactionSnapshot snapshot)
protected abstract void	encodeInProgress(co.cask.tephra.snapshot.BinaryEncoder encoder, Map<Long,co.cask.tephra.TransactionManager.InProgressTx> inProgress)
protected void	encodeObsoleteAttributes(co.cask.tephra.snapshot.BinaryEncoder encoder) Deprecated.
abstract int	getVersion()

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractSnapshotCodec

public AbstractSnapshotCodec()

Method Detail

getVersion

public abstract int getVersion()

Specified by:

getVersion in interface co.cask.tephra.snapshot.SnapshotCodec

decodeInProgress

protected abstract NavigableMap<Long,co.cask.tephra.TransactionManager.InProgressTx> decodeInProgress(co.cask.tephra.snapshot.BinaryDecoder decoder)
                                                                                               throws IOException

Throws:

IOException

encodeInProgress

protected abstract void encodeInProgress(co.cask.tephra.snapshot.BinaryEncoder encoder,
                    Map<Long,co.cask.tephra.TransactionManager.InProgressTx> inProgress)
                                  throws IOException

Throws:

IOException

encode

public void encode(OutputStream out,
          co.cask.tephra.persist.TransactionSnapshot snapshot)

Specified by:

encode in interface co.cask.tephra.snapshot.SnapshotCodec

decode

public co.cask.tephra.persist.TransactionSnapshot decode(InputStream in)

Specified by:

decode in interface co.cask.tephra.snapshot.SnapshotCodec

decodeTransactionVisibilityState

public co.cask.tephra.persist.TransactionVisibilityState decodeTransactionVisibilityState(InputStream in)

Specified by:

decodeTransactionVisibilityState in interface co.cask.tephra.snapshot.SnapshotCodec

decodeObsoleteAttributes

@Deprecated
protected void decodeObsoleteAttributes(co.cask.tephra.snapshot.BinaryDecoder decoder)
                                 throws IOException

Deprecated.

Throws:

IOException

encodeObsoleteAttributes

@Deprecated
protected void encodeObsoleteAttributes(co.cask.tephra.snapshot.BinaryEncoder encoder)
                                 throws IOException

Deprecated.

Throws:

IOException