| 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 | 
|---|
AbstractTransactionLog.Entry(org.apache.hadoop.io.LongWritable key,
                            TransactionEdit edit)  | 
Copyright © 2017 The Apache Software Foundation. All rights reserved.