Package | Description |
---|---|
org.apache.hadoop.hbase.procedure2.store | |
org.apache.hadoop.hbase.procedure2.store.wal |
Modifier and Type | Method and Description |
---|---|
void |
ProcedureStoreTracker.resetTo(ProcedureStoreTracker tracker)
Resets internal state to same as given
tracker . |
void |
ProcedureStoreTracker.resetTo(ProcedureStoreTracker tracker,
boolean resetDelete)
Resets internal state to same as given
tracker , and change the deleted flag according
to the modified flag if resetDelete is true. |
void |
ProcedureStoreTracker.setDeletedIfDeletedByThem(ProcedureStoreTracker tracker)
For the global tracker, we will use this method to build the holdingCleanupTracker, as the
modified flags will be cleared after rolling so we only need to test the deleted flags.
|
void |
ProcedureStoreTracker.setDeletedIfModifiedInBoth(ProcedureStoreTracker tracker)
|
private void |
ProcedureStoreTracker.setDeleteIf(ProcedureStoreTracker tracker,
BiFunction<BitSetNode,Long,Boolean> func) |
Modifier and Type | Field and Description |
---|---|
private ProcedureStoreTracker |
WALProcedureStore.holdingCleanupTracker |
private ProcedureStoreTracker |
ProcedureWALFormatReader.localTracker
If tracker for a log file is partial (see
partial ), we re-build
the list of procedures modified in that WAL because we need it for log cleaning purposes. |
private ProcedureStoreTracker |
WALProcedureStore.storeTracker |
private ProcedureStoreTracker |
ProcedureWALFormatReader.tracker
Global tracker that will be used by the WALProcedureStore after load.
|
private ProcedureStoreTracker |
ProcedureWALFile.tracker |
Modifier and Type | Method and Description |
---|---|
ProcedureStoreTracker |
WALProcedureStore.getStoreTracker() |
ProcedureStoreTracker |
ProcedureWALFile.getTracker() |
Modifier and Type | Method and Description |
---|---|
private void |
ProcedureWALFormatReader.insertIfPartial(ProcedureStoreTracker tracker,
org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure proc) |
static void |
ProcedureWALFormat.load(Iterator<ProcedureWALFile> logs,
ProcedureStoreTracker tracker,
ProcedureWALFormat.Loader loader)
Load all the procedures in these ProcedureWALFiles, and rebuild the given
tracker if
needed, i.e, the tracker is a partial one. |
private void |
ProcedureWALFormatReader.setDeletedIfPartial(ProcedureStoreTracker tracker,
long procId) |
void |
ProcedureWALFile.updateLocalTracker(ProcedureStoreTracker tracker) |
static long |
ProcedureWALFormat.writeTrailer(org.apache.hadoop.fs.FSDataOutputStream stream,
ProcedureStoreTracker tracker) |
Constructor and Description |
---|
ProcedureWALFormatReader(ProcedureStoreTracker tracker,
ProcedureWALFormat.Loader loader) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.