Searched refs:ProcedureStoreTracker (Results 1 – 8 of 8) sorted by relevance
45 ProcedureStoreTracker tracker = new ProcedureStoreTracker(); in testSeqInsertAndDelete()57 assertEquals(ProcedureStoreTracker.DeleteState.NO, tracker.isDeleted(j)); in testSeqInsertAndDelete()83 ProcedureStoreTracker tracker = new ProcedureStoreTracker(); in testPartialTracker()94 assertEquals(ProcedureStoreTracker.DeleteState.YES, tracker.isDeleted(1)); in testPartialTracker()100 assertEquals(ProcedureStoreTracker.DeleteState.YES, tracker.isDeleted(1)); in testPartialTracker()102 assertEquals(ProcedureStoreTracker.DeleteState.NO, tracker.isDeleted(579)); in testPartialTracker()116 ProcedureStoreTracker tracker = new ProcedureStoreTracker(); in testIsTracking()139 ProcedureStoreTracker tracker = new ProcedureStoreTracker(); in testBasicCRUD()180 final ProcedureStoreTracker tracker = new ProcedureStoreTracker(); in testRandLoad()202 final ProcedureStoreTracker tracker = new ProcedureStoreTracker(); in testLoad()[all …]
4793 public static final class ProcedureStoreTracker extends class in ProcedureProtos4803 private static final ProcedureStoreTracker defaultInstance;4804 public static ProcedureStoreTracker getDefaultInstance() { in getDefaultInstance()4808 public ProcedureStoreTracker getDefaultInstanceForType() { in getDefaultInstanceForType()4818 private ProcedureStoreTracker( in ProcedureStoreTracker() method in ProcedureProtos.ProcedureStoreTracker4876 public static com.google.protobuf.Parser<ProcedureStoreTracker> PARSER =4877 new com.google.protobuf.AbstractParser<ProcedureStoreTracker>() {4878 public ProcedureStoreTracker parsePartialFrom(4882 return new ProcedureStoreTracker(input, extensionRegistry);5752 …ated.ProcedureProtos.ProcedureStoreTracker other = (org.apache.hadoop.hbase.protobuf.generated.Pro… in equals()[all …]
40 public class ProcedureStoreTracker { class185 public ProcedureProtos.ProcedureStoreTracker.TrackerNode convert() { in convert()186 ProcedureProtos.ProcedureStoreTracker.TrackerNode.Builder builder = in convert()187 ProcedureProtos.ProcedureStoreTracker.TrackerNode.newBuilder(); in convert()196 public static BitSetNode convert(ProcedureProtos.ProcedureStoreTracker.TrackerNode data) { in convert()575 ProcedureProtos.ProcedureStoreTracker.Builder builder =576 ProcedureProtos.ProcedureStoreTracker.newBuilder();585 final ProcedureProtos.ProcedureStoreTracker data =586 ProcedureProtos.ProcedureStoreTracker.parseDelimitedFrom(stream);587 for (ProcedureProtos.ProcedureStoreTracker.TrackerNode protoNode: data.getNodeList()) {
32 import org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker;74 final ProcedureStoreTracker tracker, final Loader loader) throws IOException { in load()116 public static void writeTrailer(FSDataOutputStream stream, ProcedureStoreTracker tracker) in writeTrailer()
31 import org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker;86 public void readTracker(ProcedureStoreTracker tracker) throws IOException { in readTracker()
30 import org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker;104 private final ProcedureStoreTracker tracker;107 public ProcedureWALFormatReader(final ProcedureStoreTracker tracker) { in ProcedureWALFormatReader()221 return tracker.isDeleted(procId) == ProcedureStoreTracker.DeleteState.YES; in isDeleted()
51 import org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker;102 private final ProcedureStoreTracker storeTracker = new ProcedureStoreTracker();235 public ProcedureStoreTracker getStoreTracker() { in getStoreTracker()
95 message ProcedureStoreTracker { message