@InterfaceAudience.Private @InterfaceStability.Evolving public class ProcedureWALFormatReader extends Object
Modifier and Type | Class and Description |
---|---|
private static class |
ProcedureWALFormatReader.Entry |
private static class |
ProcedureWALFormatReader.EntryIterator |
private static class |
ProcedureWALFormatReader.WalProcedureMap |
Modifier and Type | Field and Description |
---|---|
private boolean |
hasFastStartSupport |
private ProcedureWALFormatReader.WalProcedureMap |
localProcedureMap |
private static org.apache.commons.logging.Log |
LOG |
private long |
maxProcId |
private ProcedureWALFormatReader.WalProcedureMap |
procedureMap |
private ProcedureStoreTracker |
tracker |
Constructor and Description |
---|
ProcedureWALFormatReader(ProcedureStoreTracker tracker) |
Modifier and Type | Method and Description |
---|---|
void |
finalize(ProcedureWALFormat.Loader loader) |
private boolean |
isDeleted(long procId) |
private boolean |
isRequired(long procId) |
private void |
loadProcedure(org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry entry,
org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.Procedure proc) |
void |
read(ProcedureWALFile log,
ProcedureWALFormat.Loader loader) |
private void |
readDeleteEntry(org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry entry) |
private void |
readInitEntry(org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry entry) |
private void |
readInsertEntry(org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry entry) |
private void |
readUpdateEntry(org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry entry) |
private static final org.apache.commons.logging.Log LOG
private final ProcedureWALFormatReader.WalProcedureMap localProcedureMap
private final ProcedureWALFormatReader.WalProcedureMap procedureMap
private long maxProcId
private final ProcedureStoreTracker tracker
private final boolean hasFastStartSupport
public ProcedureWALFormatReader(ProcedureStoreTracker tracker)
public void read(ProcedureWALFile log, ProcedureWALFormat.Loader loader) throws IOException
IOException
public void finalize(ProcedureWALFormat.Loader loader) throws IOException
IOException
private void loadProcedure(org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry entry, org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.Procedure proc)
private void readInitEntry(org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry entry) throws IOException
IOException
private void readInsertEntry(org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry entry) throws IOException
IOException
private void readUpdateEntry(org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry entry) throws IOException
IOException
private void readDeleteEntry(org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry entry) throws IOException
IOException
private boolean isDeleted(long procId)
private boolean isRequired(long procId)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.