Package | Description |
---|---|
org.apache.tephra.persist |
This package contains interfaces and implementations for persisting transaction state.
|
Modifier and Type | Method and Description |
---|---|
static TransactionEdit |
TransactionEdit.convertCaskTxEdit(TransactionEdit txEdit)
Deprecated.
|
static TransactionEdit |
TransactionEdit.createAborted(long writePointer,
TransactionType type,
long[] checkpointPointers)
Creates a new instance in the
TransactionEdit.State.ABORTED state. |
static TransactionEdit |
TransactionEdit.createCheckpoint(long writePointer,
long parentWritePointer)
Creates a new instance in the
TransactionEdit.State.CHECKPOINT state. |
static TransactionEdit |
TransactionEdit.createCommitted(long writePointer,
Set<ChangeId> changes,
long nextWritePointer,
boolean canCommit)
Creates a new instance in the
TransactionEdit.State.COMMITTED state. |
static TransactionEdit |
TransactionEdit.createCommitting(long writePointer,
Set<ChangeId> changes)
Creates a new instance in the
TransactionEdit.State.COMMITTING state. |
static TransactionEdit |
TransactionEdit.createInvalid(long writePointer)
Creates a new instance in the
TransactionEdit.State.INVALID state. |
static TransactionEdit |
TransactionEdit.createMoveWatermark(long writePointer)
Creates a new instance in the
TransactionEdit.State.MOVE_WATERMARK state. |
static TransactionEdit |
TransactionEdit.createStarted(long writePointer,
long visibilityUpperBound,
long expirationDate,
TransactionType type)
Creates a new instance in the
TransactionEdit.State.INPROGRESS state. |
static TransactionEdit |
TransactionEdit.createTruncateInvalidTx(Set<Long> truncateInvalidTx)
Creates a new instance in the
TransactionEdit.State.TRUNCATE_INVALID_TX state. |
static TransactionEdit |
TransactionEdit.createTruncateInvalidTxBefore(long truncateInvalidTxTime)
Creates a new instance in the
TransactionEdit.State.TRUNCATE_INVALID_TX state. |
TransactionEdit |
AbstractTransactionLog.Entry.getEdit() |
TransactionEdit |
TransactionLogReader.next()
Returns the next
TransactionEdit from the log file, based on the current position, or null
if the end of the file has been reached. |
TransactionEdit |
HDFSTransactionLogReaderV3.next() |
TransactionEdit |
HDFSTransactionLogReaderV2.next() |
TransactionEdit |
HDFSTransactionLogReaderV1.next() |
TransactionEdit |
TransactionLogReader.next(TransactionEdit reuse)
Populates
reuse with the next TransactionEdit , based on the reader's current position in the
log file. |
TransactionEdit |
HDFSTransactionLogReaderV3.next(TransactionEdit reuse) |
TransactionEdit |
HDFSTransactionLogReaderV2.next(TransactionEdit reuse) |
TransactionEdit |
HDFSTransactionLogReaderV1.next(TransactionEdit reuse) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionLog.append(TransactionEdit edit) |
void |
AbstractTransactionLog.append(TransactionEdit edit) |
static void |
TransactionEditCodecs.decode(TransactionEdit dest,
DataInput in)
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)
Serializes the given
TransactionEdit instance with the latest available codec. |
TransactionEdit |
TransactionLogReader.next(TransactionEdit reuse)
Populates
reuse with the next TransactionEdit , based on the reader's current position in the
log file. |
TransactionEdit |
HDFSTransactionLogReaderV3.next(TransactionEdit reuse) |
TransactionEdit |
HDFSTransactionLogReaderV2.next(TransactionEdit reuse) |
TransactionEdit |
HDFSTransactionLogReaderV1.next(TransactionEdit reuse) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionLog.append(List<TransactionEdit> edits) |
void |
AbstractTransactionLog.append(List<TransactionEdit> edits) |
Constructor and Description |
---|
Entry(org.apache.hadoop.io.LongWritable key,
TransactionEdit edit) |
Copyright © 2018 The Apache Software Foundation. All rights reserved.