Java 类org.apache.hadoop.hbase.regionserver.snapshot.RegionServerSnapshotManager.SnapshotSubprocedurePool 实例源码

项目：ditb 文件：FlushSnapshotSubprocedure.java

public FlushSnapshotSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<Region> regions, SnapshotDescription snapshot,
    SnapshotSubprocedurePool taskManager) {
  super(member, snapshot.getName(), errorListener, wakeFrequency, timeout);
  this.snapshot = snapshot;

  if (this.snapshot.getType() == SnapshotDescription.Type.SKIPFLUSH) {
    snapshotSkipFlush = true;
  }
  this.regions = regions;
  this.taskManager = taskManager;
}

项目：LCIndex-HBase-0.94.16 文件：FlushSnapshotSubprocedure.java

public FlushSnapshotSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, SnapshotDescription snapshot,
    SnapshotSubprocedurePool taskManager) {
  super(member, snapshot.getName(), errorListener, wakeFrequency, timeout);
  this.snapshot = snapshot;
  this.regions = regions;
  this.taskManager = taskManager;
}

项目：pbase 文件：FlushSnapshotSubprocedure.java

public FlushSnapshotSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, SnapshotDescription snapshot,
    SnapshotSubprocedurePool taskManager) {
  super(member, snapshot.getName(), errorListener, wakeFrequency, timeout);
  this.snapshot = snapshot;

  if (this.snapshot.getType() == SnapshotDescription.Type.SKIPFLUSH) {
    snapshotSkipFlush = true;
  }
  this.regions = regions;
  this.taskManager = taskManager;
}

项目：HIndex 文件：FlushSnapshotSubprocedure.java

public FlushSnapshotSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, SnapshotDescription snapshot,
    SnapshotSubprocedurePool taskManager) {
  super(member, snapshot.getName(), errorListener, wakeFrequency, timeout);
  this.snapshot = snapshot;
  this.regions = regions;
  this.taskManager = taskManager;
}

项目：IRIndex 文件：FlushSnapshotSubprocedure.java

public FlushSnapshotSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, SnapshotDescription snapshot,
    SnapshotSubprocedurePool taskManager) {
  super(member, snapshot.getName(), errorListener, wakeFrequency, timeout);
  this.snapshot = snapshot;
  this.regions = regions;
  this.taskManager = taskManager;
}

项目：hbase 文件：FlushSnapshotSubprocedure.java

public FlushSnapshotSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, SnapshotDescription snapshot,
    SnapshotSubprocedurePool taskManager) {
  super(member, snapshot.getName(), errorListener, wakeFrequency, timeout);
  this.snapshot = snapshot;

  if (this.snapshot.getType() == SnapshotDescription.Type.SKIPFLUSH) {
    snapshotSkipFlush = true;
  }
  this.regions = regions;
  this.taskManager = taskManager;
}

项目：PyroDB 文件：FlushSnapshotSubprocedure.java

public FlushSnapshotSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, SnapshotDescription snapshot,
    SnapshotSubprocedurePool taskManager) {
  super(member, snapshot.getName(), errorListener, wakeFrequency, timeout);
  this.snapshot = snapshot;
  this.regions = regions;
  this.taskManager = taskManager;
}

项目：c5 文件：FlushSnapshotSubprocedure.java

public FlushSnapshotSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, SnapshotDescription snapshot,
    SnapshotSubprocedurePool taskManager) {
  super(member, snapshot.getName(), errorListener, wakeFrequency, timeout);
  this.snapshot = snapshot;
  this.regions = regions;
  this.taskManager = taskManager;
}

项目：HBase-Research 文件：FlushSnapshotSubprocedure.java

public FlushSnapshotSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, SnapshotDescription snapshot,
    SnapshotSubprocedurePool taskManager) {
  super(member, snapshot.getName(), errorListener, wakeFrequency, timeout);
  this.snapshot = snapshot;
  this.regions = regions;
  this.taskManager = taskManager;
}

项目：hbase-0.94.8-qod 文件：FlushSnapshotSubprocedure.java

public FlushSnapshotSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, SnapshotDescription snapshot,
    SnapshotSubprocedurePool taskManager) {
  super(member, snapshot.getName(), errorListener, wakeFrequency, timeout);
  this.snapshot = snapshot;
  this.regions = regions;
  this.taskManager = taskManager;
}

项目：hbase-0.94.8-qod 文件：FlushSnapshotSubprocedure.java

public FlushSnapshotSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, SnapshotDescription snapshot,
    SnapshotSubprocedurePool taskManager) {
  super(member, snapshot.getName(), errorListener, wakeFrequency, timeout);
  this.snapshot = snapshot;
  this.regions = regions;
  this.taskManager = taskManager;
}

项目：hindex 文件：FlushSnapshotSubprocedure.java

public FlushSnapshotSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, SnapshotDescription snapshot,
    SnapshotSubprocedurePool taskManager) {
  super(member, snapshot.getName(), errorListener, wakeFrequency, timeout);
  this.snapshot = snapshot;
  this.regions = regions;
  this.taskManager = taskManager;
}