Java 类org.apache.hadoop.hbase.client.HTableMultiplexer 实例源码

public HBaseAsyncTemplate(Configuration conf, int perRegionServerBufferQueueSize) throws IOException {
    this.hTableMultiplexer = new HTableMultiplexer(conf, perRegionServerBufferQueueSize);
}

public HBaseAsyncTemplate(Connection connection, Configuration conf, int perRegionServerBufferQueueSize) throws IOException {
    this.hTableMultiplexer = new HTableMultiplexer(connection, conf, perRegionServerBufferQueueSize);
}

public HBaseAsyncTemplate(Configuration conf, int perRegionServerBufferQueueSize) throws IOException {
    this.hTableMultiplexer = new HTableMultiplexer(conf, perRegionServerBufferQueueSize);
}

public HBaseAsyncTemplate(Connection connection, Configuration conf, int perRegionServerBufferQueueSize) throws IOException {
    this.hTableMultiplexer = new HTableMultiplexer(connection, conf, perRegionServerBufferQueueSize);
}

/**
   * <b>NOTE: THIS METHOD IS NOT YET SUPPORTED!</b><br><br>
   * Create an HTableMultiplexer object.<br><br>
   * <b>SPECIAL NOTE:</b> An HTableMultiplexer returned by this method will (1) validate submitted
   * <i>Column</i> qualifiers and values (if
   * {@link RepositoryAdmin#enableColumnDefinitionEnforcement(boolean, org.apache.hadoop.hbase.TableName, byte[])
   * ColumnDefinitionsEnforced} is set to {@code true} for the related <i>Column Family</i>), (2)
   * process "put" requests in a standard manner (queuing them for subsequent <b>asynchronous</b>
   * processing by HBase) and then (3) perform <b>synchronous</b> ColumnManager Repository
   * processing upon the metadata of each successfully queued "put". <i>Be advised that the third
   * step will not take into account any potentially failed "put" transactions among those queued in
   * the second step; instead it assumes that all "put" transactions succeeded, updating the
   * ColumnManager Repository accordingly.</i>
   *
   * @param perRegionServerBufferQueueSize determines the max number of the buffered Put ops for
   * each region server before dropping a request.
   * @return HTableMultiplexer object
   * @throws IOException if a remote or network exception occurs
   */
  public HTableMultiplexer createHTableMultiplexer(int perRegionServerBufferQueueSize)
          throws IOException {
    throw new UnsupportedOperationException();
//    return new MTableMultiplexer(repository, hbaseConnection.getConfiguration(),
//            perRegionServerBufferQueueSize);
  }