private static class ProcedureWALFormatReader.WalProcedureMap extends Object
Modifier and Type | Field and Description |
---|---|
private ProcedureWALFormatReader.Entry |
childUnlinkedHead |
private long |
maxProcId |
private long |
minProcId |
private ProcedureWALFormatReader.Entry[] |
procedureMap |
private ProcedureWALFormatReader.Entry |
replayOrderHead |
private ProcedureWALFormatReader.Entry |
replayOrderTail |
private ProcedureWALFormatReader.Entry |
rootHead |
Constructor and Description |
---|
ProcedureWALFormatReader.WalProcedureMap(int size) |
private ProcedureWALFormatReader.Entry[] procedureMap
private ProcedureWALFormatReader.Entry replayOrderHead
private ProcedureWALFormatReader.Entry replayOrderTail
private ProcedureWALFormatReader.Entry rootHead
private ProcedureWALFormatReader.Entry childUnlinkedHead
private long minProcId
private long maxProcId
public ProcedureWALFormatReader.WalProcedureMap(int size)
public void add(org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.Procedure procProto)
public boolean remove(long procId)
private void trackProcIds(long procId)
public long getMinProcId()
public long getMaxProcId()
public boolean contains(long procId)
public boolean isEmpty()
public void clear()
public void mergeTail(ProcedureWALFormatReader.WalProcedureMap other)
public ProcedureWALFormatReader.EntryIterator fetchReady()
public ProcedureWALFormatReader.EntryIterator fetchAll()
private void buildGraph()
private ProcedureWALFormatReader.Entry getRootProcedure(ProcedureWALFormatReader.Entry entry)
private boolean checkReadyToRun(ProcedureWALFormatReader.Entry rootEntry)
private void unlinkFromReplayList(ProcedureWALFormatReader.Entry entry)
private void addToReplayList(ProcedureWALFormatReader.Entry entry)
private void unlinkFromLinkList(ProcedureWALFormatReader.Entry entry)
private ProcedureWALFormatReader.Entry addToLinkList(ProcedureWALFormatReader.Entry entry, ProcedureWALFormatReader.Entry linkHead)
private ProcedureWALFormatReader.Entry findLinkListTail(ProcedureWALFormatReader.Entry linkHead)
private ProcedureWALFormatReader.Entry addToMap(long procId, boolean hasParent)
private ProcedureWALFormatReader.Entry removeFromMap(long procId)
private ProcedureWALFormatReader.Entry getProcedure(long procId)
private ProcedureWALFormatReader.Entry getProcedure(int slotIndex, long procId)
private int getMapSlot(long procId)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.