Java 类org.apache.hadoop.hbase.procedure.flush.RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool 实例源码

项目:ditb    文件:FlushTableSubprocedure.java   
public FlushTableSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<Region> regions, String table,
    FlushTableSubprocedurePool taskManager) {
  super(member, table, errorListener, wakeFrequency, timeout);
  this.table = table;
  this.regions = regions;
  this.taskManager = taskManager;
}
项目:pbase    文件:FlushTableSubprocedure.java   
public FlushTableSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, String table,
    FlushTableSubprocedurePool taskManager) {
  super(member, table, errorListener, wakeFrequency, timeout);
  this.table = table;
  this.regions = regions;
  this.taskManager = taskManager;
}
项目:hbase    文件:FlushTableSubprocedure.java   
public FlushTableSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, String table,
    FlushTableSubprocedurePool taskManager) {
  super(member, table, errorListener, wakeFrequency, timeout);
  this.table = table;
  this.regions = regions;
  this.taskManager = taskManager;
}
项目:PyroDB    文件:FlushTableSubprocedure.java   
public FlushTableSubprocedure(ProcedureMember member,
    ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout,
    List<HRegion> regions, String table,
    FlushTableSubprocedurePool taskManager) {
  super(member, table, errorListener, wakeFrequency, timeout);
  this.table = table;
  this.regions = regions;
  this.taskManager = taskManager;
}