ProcedureStoreTracker (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker

```
@InterfaceAudience.Private
@InterfaceStability.Evolving
public class ProcedureStoreTracker
extends Object
```
Keeps track of live procedures. It can be used by the ProcedureStore to identify which procedures are already deleted/completed to avoid the deserialization step on restart.

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class ProcedureStoreTracker.BitSetNode

static class ProcedureStoreTracker.DeleteState

Nested Classes
Modifier and Type	Class and Description
`static class`	`ProcedureStoreTracker.BitSetNode`
`static class`	`ProcedureStoreTracker.DeleteState`

Field Summary

Fields
Modifier and Type	Field and Description
`private boolean`	`keepDeletes`
`private TreeMap<Long,ProcedureStoreTracker.BitSetNode>`	`map`
`private long`	`maxUpdatedProcId`
`private long`	`minUpdatedProcId`
`private boolean`	`partial`

Constructor Summary

Constructors
Constructor and Description

ProcedureStoreTracker()

Constructors
Constructor and Description
`ProcedureStoreTracker()`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`delete(long procId)`
`void`	`dump()`
`long`	`getMinProcId()`
`private ProcedureStoreTracker.BitSetNode`	`getOrCreateNode(long procId)`
`long`	`getUpdatedMaxProcId()`
`long`	`getUpdatedMinProcId()`
`private ProcedureStoreTracker.BitSetNode`	`growNode(ProcedureStoreTracker.BitSetNode node, long procId)`
`void`	`insert(long procId)`
`void`	`insert(long procId, long[] subProcIds)`
`ProcedureStoreTracker.DeleteState`	`isDeleted(long procId)`
`boolean`	`isEmpty()`
`boolean`	`isTracking(long minId, long maxId)`
`boolean`	`isUpdated()`
`private ProcedureStoreTracker.BitSetNode`	`mergeNodes(ProcedureStoreTracker.BitSetNode leftNode, ProcedureStoreTracker.BitSetNode rightNode)`
`void`	`readFrom(InputStream stream)`
`void`	`reset()`
`void`	`resetUpdates()`
`void`	`setDeleted(long procId, boolean isDeleted)`
`void`	`setKeepDeletes(boolean keepDeletes)`
`void`	`setPartialFlag(boolean isPartial)`
`private void`	`trackProcIds(long procId)`
`void`	`undeleteAll()`
`void`	`update(long procId)`
`void`	`writeTo(OutputStream stream)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

map

private final TreeMap<Long,ProcedureStoreTracker.BitSetNode> map

keepDeletes
```
private boolean keepDeletes
```

partial
```
private boolean partial
```

minUpdatedProcId
```
private long minUpdatedProcId
```

maxUpdatedProcId
```
private long maxUpdatedProcId
```

Constructor Detail
- ProcedureStoreTracker
```
public ProcedureStoreTracker()
```

Method Detail

insert
```
public void insert(long procId)
```

insert

public void insert(long procId,
          long[] subProcIds)

update
```
public void update(long procId)
```

delete
```
public void delete(long procId)
```

trackProcIds

private void trackProcIds(long procId)

getUpdatedMinProcId
```
public long getUpdatedMinProcId()
```

getUpdatedMaxProcId
```
public long getUpdatedMaxProcId()
```

setDeleted

@InterfaceAudience.Private
public void setDeleted(long procId,
                                        boolean isDeleted)

reset
```
public void reset()
```

isDeleted

public ProcedureStoreTracker.DeleteState isDeleted(long procId)

getMinProcId
```
public long getMinProcId()
```

setKeepDeletes

public void setKeepDeletes(boolean keepDeletes)

setPartialFlag

public void setPartialFlag(boolean isPartial)

isEmpty
```
public boolean isEmpty()
```

isUpdated
```
public boolean isUpdated()
```

isTracking

public boolean isTracking(long minId,
                 long maxId)

resetUpdates
```
public void resetUpdates()
```

undeleteAll
```
public void undeleteAll()
```

getOrCreateNode

private ProcedureStoreTracker.BitSetNode getOrCreateNode(long procId)

growNode

private ProcedureStoreTracker.BitSetNode growNode(ProcedureStoreTracker.BitSetNode node,
                                        long procId)

mergeNodes

private ProcedureStoreTracker.BitSetNode mergeNodes(ProcedureStoreTracker.BitSetNode leftNode,
                                          ProcedureStoreTracker.BitSetNode rightNode)

dump
```
public void dump()
```

writeTo

public void writeTo(OutputStream stream)
             throws IOException

Throws:: IOException

readFrom

public void readFrom(InputStream stream)
              throws IOException

Throws:: IOException

Class ProcedureStoreTracker

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

map

keepDeletes

partial

minUpdatedProcId

maxUpdatedProcId

Constructor Detail

ProcedureStoreTracker

Method Detail

insert

insert

update

delete

trackProcIds

getUpdatedMinProcId

getUpdatedMaxProcId

setDeleted

reset

isDeleted

getMinProcId

setKeepDeletes

setPartialFlag

isEmpty

isUpdated

isTracking

resetUpdates

undeleteAll

getOrCreateNode

growNode

mergeNodes

dump

writeTo

readFrom