@InterfaceAudience.Private @InterfaceStability.Evolving public final class ProcedureWALFormat extends Object
| Modifier and Type | Class and Description |
|---|---|
static class |
ProcedureWALFormat.InvalidWALDataException |
| Modifier and Type | Method and Description |
|---|---|
static void |
load(Iterator<ProcedureWALFile> logs,
ProcedureStoreTracker tracker,
org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat.Loader loader) |
static org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry |
readEntry(InputStream stream) |
static org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALHeader |
readHeader(InputStream stream) |
static org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALTrailer |
readTrailer(org.apache.hadoop.fs.FSDataInputStream stream,
long startPos,
long size) |
static void |
writeDelete(ByteSlot slot,
long procId) |
static void |
writeDelete(ByteSlot slot,
Procedure proc,
long[] subprocs) |
static void |
writeEntry(ByteSlot slot,
org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type type,
Procedure proc,
Procedure[] subprocs) |
static void |
writeHeader(OutputStream stream,
org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALHeader header) |
static void |
writeInsert(ByteSlot slot,
Procedure proc) |
static void |
writeInsert(ByteSlot slot,
Procedure proc,
Procedure[] subprocs) |
static long |
writeTrailer(org.apache.hadoop.fs.FSDataOutputStream stream,
ProcedureStoreTracker tracker) |
static void |
writeUpdate(ByteSlot slot,
Procedure proc) |
public static void load(Iterator<ProcedureWALFile> logs, ProcedureStoreTracker tracker, org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat.Loader loader) throws IOException
IOExceptionpublic static void writeHeader(OutputStream stream, org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALHeader header) throws IOException
IOExceptionpublic static long writeTrailer(org.apache.hadoop.fs.FSDataOutputStream stream,
ProcedureStoreTracker tracker)
throws IOException
IOExceptionpublic static org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALHeader readHeader(InputStream stream) throws IOException
IOExceptionpublic static org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALTrailer readTrailer(org.apache.hadoop.fs.FSDataInputStream stream,
long startPos,
long size)
throws IOException
IOExceptionpublic static org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry readEntry(InputStream stream) throws IOException
IOExceptionpublic static void writeEntry(ByteSlot slot, org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type type, Procedure proc, Procedure[] subprocs) throws IOException
IOExceptionpublic static void writeInsert(ByteSlot slot, Procedure proc) throws IOException
IOExceptionpublic static void writeInsert(ByteSlot slot, Procedure proc, Procedure[] subprocs) throws IOException
IOExceptionpublic static void writeUpdate(ByteSlot slot, Procedure proc) throws IOException
IOExceptionpublic static void writeDelete(ByteSlot slot, long procId) throws IOException
IOExceptionpublic static void writeDelete(ByteSlot slot, Procedure proc, long[] subprocs) throws IOException
IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.