@Deprecated @InterfaceAudience.Private final class ProcedureWALFormat extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ProcedureWALFormat.InvalidWALDataException
Deprecated.
|
(package private) static interface |
ProcedureWALFormat.Loader
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
(package private) static long |
HEADER_MAGIC
Deprecated.
|
(package private) static byte |
HEADER_VERSION
Deprecated.
|
(package private) static byte |
LOG_TYPE_COMPACTED
Deprecated.
|
(package private) static byte |
LOG_TYPE_MAX_VALID
Deprecated.
|
(package private) static byte |
LOG_TYPE_STREAM
Deprecated.
|
(package private) static long |
TRAILER_MAGIC
Deprecated.
|
(package private) static byte |
TRAILER_VERSION
Deprecated.
|
Modifier | Constructor and Description |
---|---|
private |
ProcedureWALFormat()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static void |
load(Iterator<ProcedureWALFile> logs,
ProcedureStoreTracker tracker,
ProcedureWALFormat.Loader loader)
Deprecated.
Load all the procedures in these ProcedureWALFiles, and rebuild the given
tracker if
needed, i.e, the tracker is a partial one. |
static org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALEntry |
readEntry(InputStream stream)
Deprecated.
|
static org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALHeader |
readHeader(InputStream stream)
Deprecated.
|
static org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALTrailer |
readTrailer(org.apache.hadoop.fs.FSDataInputStream stream,
long startPos,
long size)
Deprecated.
|
static void |
writeDelete(ByteSlot slot,
long procId)
Deprecated.
|
static void |
writeDelete(ByteSlot slot,
Procedure<?> proc,
long[] subprocs)
Deprecated.
|
static void |
writeEntry(ByteSlot slot,
org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type type,
Procedure<?> proc,
Procedure<?>[] subprocs)
Deprecated.
|
static void |
writeHeader(OutputStream stream,
org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALHeader header)
Deprecated.
|
static void |
writeInsert(ByteSlot slot,
Procedure<?> proc)
Deprecated.
|
static void |
writeInsert(ByteSlot slot,
Procedure<?> proc,
Procedure<?>[] subprocs)
Deprecated.
|
static long |
writeTrailer(org.apache.hadoop.fs.FSDataOutputStream stream,
ProcedureStoreTracker tracker)
Deprecated.
|
static void |
writeUpdate(ByteSlot slot,
Procedure<?> proc)
Deprecated.
|
static final byte LOG_TYPE_STREAM
static final byte LOG_TYPE_COMPACTED
static final byte LOG_TYPE_MAX_VALID
static final byte HEADER_VERSION
static final byte TRAILER_VERSION
static final long HEADER_MAGIC
static final long TRAILER_MAGIC
private ProcedureWALFormat()
public static void load(Iterator<ProcedureWALFile> logs, ProcedureStoreTracker tracker, ProcedureWALFormat.Loader loader) throws IOException
tracker
if
needed, i.e, the tracker
is a partial one.
The method in the give loader
will be called at the end after we load all the
procedures and construct the hierarchy.
And we will call the ProcedureStoreTracker.resetModified()
method for the given
tracker
before returning, as it will be used to track the next proc wal file's modified
procedures.IOException
public static void writeHeader(OutputStream stream, org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALHeader header) throws IOException
IOException
public static long writeTrailer(org.apache.hadoop.fs.FSDataOutputStream stream, ProcedureStoreTracker tracker) throws IOException
IOException
public static org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALHeader readHeader(InputStream stream) throws IOException
IOException
public static org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALTrailer readTrailer(org.apache.hadoop.fs.FSDataInputStream stream, long startPos, long size) throws IOException
IOException
public static org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALEntry readEntry(InputStream stream) throws IOException
IOException
public static void writeEntry(ByteSlot slot, org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type type, Procedure<?> proc, Procedure<?>[] subprocs) throws IOException
IOException
public static void writeInsert(ByteSlot slot, Procedure<?> proc) throws IOException
IOException
public static void writeInsert(ByteSlot slot, Procedure<?> proc, Procedure<?>[] subprocs) throws IOException
IOException
public static void writeUpdate(ByteSlot slot, Procedure<?> proc) throws IOException
IOException
public static void writeDelete(ByteSlot slot, long procId) throws IOException
IOException
public static void writeDelete(ByteSlot slot, Procedure<?> proc, long[] subprocs) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.