org.apache.tephra.snapshot

Class SnapshotCodecProvider

java.lang.Object

org.apache.tephra.snapshot.SnapshotCodecProvider

All Implemented Interfaces:

SnapshotCodec

public class SnapshotCodecProvider
extends Object
implements SnapshotCodec

Maintains the codecs for all known versions of the transaction snapshot encoding.

Constructor Summary

Constructors

Constructor and Description
SnapshotCodecProvider(org.apache.hadoop.conf.Configuration configuration)

Method Summary

Modifier and Type	Method and Description
TransactionSnapshot	decode(InputStream in) Decode a transaction snapshot from an input stream.
TransactionVisibilityState	decodeTransactionVisibilityState(InputStream in) Decode transaction visibility state from an input stream.
void	encode(OutputStream out, TransactionSnapshot snapshot) Encode a transaction snapshot into an output stream.
int	getVersion()

Methods inherited from class java.lang.Object

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

Constructor Detail

SnapshotCodecProvider

@Inject
public SnapshotCodecProvider(org.apache.hadoop.conf.Configuration configuration)

Method Detail

getVersion

public int getVersion()

Specified by:

getVersion in interface SnapshotCodec

Returns:

the version of the encoding implemented by the codec.

decode

public TransactionSnapshot decode(InputStream in)

Description copied from interface: SnapshotCodec

Decode a transaction snapshot from an input stream.

Specified by:

decode in interface SnapshotCodec

Parameters:

in - the input stream to read from

Returns:

the decoded snapshot

decodeTransactionVisibilityState

public TransactionVisibilityState decodeTransactionVisibilityState(InputStream in)

Description copied from interface: SnapshotCodec

Decode transaction visibility state from an input stream.

Specified by:

decodeTransactionVisibilityState in interface SnapshotCodec

Parameters:

in - the input stream to read from

Returns:

TransactionVisibilityState

encode

public void encode(OutputStream out,
                   TransactionSnapshot snapshot)

Description copied from interface: SnapshotCodec

Encode a transaction snapshot into an output stream.

Specified by:

encode in interface SnapshotCodec

Parameters:

out - the output stream to write to

snapshot - the snapshot to encode