Package | Description |
---|---|
co.cask.tephra.persist | |
org.apache.tephra.persist |
This package contains interfaces and implementations for persisting transaction state.
|
Modifier and Type | Method and Description |
---|---|
static TransactionEdit |
TransactionEdit.createAborted(long writePointer,
TransactionType type,
long[] checkpointPointers)
Deprecated.
Creates a new instance in the
TransactionEdit.State.ABORTED state. |
static TransactionEdit |
TransactionEdit.createCheckpoint(long writePointer,
long parentWritePointer)
Deprecated.
Creates a new instance in the
TransactionEdit.State.CHECKPOINT state. |
static TransactionEdit |
TransactionEdit.createCommitted(long writePointer,
Set<ChangeId> changes,
long nextWritePointer,
boolean canCommit)
Deprecated.
Creates a new instance in the
TransactionEdit.State.COMMITTED state. |
static TransactionEdit |
TransactionEdit.createCommitting(long writePointer,
Set<ChangeId> changes)
Deprecated.
Creates a new instance in the
TransactionEdit.State.COMMITTING state. |
static TransactionEdit |
TransactionEdit.createInvalid(long writePointer)
Deprecated.
Creates a new instance in the
TransactionEdit.State.INVALID state. |
static TransactionEdit |
TransactionEdit.createMoveWatermark(long writePointer)
Deprecated.
Creates a new instance in the
TransactionEdit.State.MOVE_WATERMARK state. |
static TransactionEdit |
TransactionEdit.createStarted(long writePointer,
long visibilityUpperBound,
long expirationDate,
TransactionType type)
Deprecated.
Creates a new instance in the
TransactionEdit.State.INPROGRESS state. |
static TransactionEdit |
TransactionEdit.createTruncateInvalidTx(Set<Long> truncateInvalidTx)
Deprecated.
Creates a new instance in the
TransactionEdit.State.TRUNCATE_INVALID_TX state. |
static TransactionEdit |
TransactionEdit.createTruncateInvalidTxBefore(long truncateInvalidTxTime)
Deprecated.
Creates a new instance in the
TransactionEdit.State.TRUNCATE_INVALID_TX state. |
Modifier and Type | Method and Description |
---|---|
static void |
TransactionEditCodecs.decode(TransactionEdit dest,
DataInput in)
Deprecated.
Deserializes the encoded data from the given input stream, setting the values as fields
on the given
TransactionEdit instances. |
static void |
TransactionEditCodecs.encode(TransactionEdit src,
DataOutput out)
Deprecated.
Serializes the given
TransactionEdit instance with the latest available codec. |
Modifier and Type | Method and Description |
---|---|
static TransactionEdit |
TransactionEdit.convertCaskTxEdit(TransactionEdit txEdit)
Deprecated.
|
Copyright © 2018 The Apache Software Foundation. All rights reserved.