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;
}