public class EditLog extends Object
Constructor and Description |
---|
EditLog(String path,
boolean inactive,
long transactionId) |
Modifier and Type | Method and Description |
---|---|
void |
addBlock(int fileId,
int blockIndex,
long blockLength) |
void |
addCheckpoint(int fileId,
long length,
String checkpointPath) |
void |
close()
Close the log.
|
void |
completeFile(int fileId) |
void |
createFile(boolean recursive,
String path,
boolean directory,
int columns,
ByteBuffer metadata,
long blockSizeByte,
long creationTimeMs) |
void |
delete(int fileId,
boolean recursive) |
void |
flush()
Flush the log onto the storage.
|
Pair<Long,Long> |
getTransactionIds()
Get the current TransactionId and FlushedTransactionId
|
static long |
load(MasterInfo info,
String path)
Load edit log.
|
void |
rename(int fileId,
String dstPath) |
void |
unpinFile(int fileId) |
void |
updateRawTableMetadata(int tableId,
ByteBuffer metadata) |
public EditLog(String path, boolean inactive, long transactionId) throws IOException
IOException
public static long load(MasterInfo info, String path) throws IOException
info
- The Master Info.IOException
public void addCheckpoint(int fileId, long length, String checkpointPath)
public void addBlock(int fileId, int blockIndex, long blockLength)
public void createFile(boolean recursive, String path, boolean directory, int columns, ByteBuffer metadata, long blockSizeByte, long creationTimeMs)
public void delete(int fileId, boolean recursive)
public void rename(int fileId, String dstPath)
public void unpinFile(int fileId)
public void updateRawTableMetadata(int tableId, ByteBuffer metadata)
public void completeFile(int fileId)
public Pair<Long,Long> getTransactionIds()
public void flush()
public void close()
Copyright © 2013. All rights reserved.