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

项目：ditb 文件：TestScannerHeartbeatMessages.java

@BeforeClass
public static void setUpBeforeClass() throws Exception {
  ((Log4JLogger) ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger) HeartbeatRPCServices.LOG).getLogger().setLevel(Level.ALL);
  Configuration conf = TEST_UTIL.getConfiguration();

  conf.setStrings(HConstants.REGION_IMPL, HeartbeatHRegion.class.getName());
  conf.setStrings(HConstants.REGION_SERVER_IMPL, HeartbeatHRegionServer.class.getName());
  conf.setInt(HConstants.HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD, CLIENT_TIMEOUT);
  conf.setInt(HConstants.HBASE_RPC_TIMEOUT_KEY, CLIENT_TIMEOUT);
  conf.setInt(HConstants.HBASE_CLIENT_PAUSE, 1);

  // Check the timeout condition after every cell
  conf.setLong(StoreScanner.HBASE_CELLS_SCANNED_PER_HEARTBEAT_CHECK, 1);
  TEST_UTIL.startMiniCluster(1);

  TABLE = createTestTable(TABLE_NAME, ROWS, FAMILIES, QUALIFIERS, VALUE);
}

项目：flink 文件：HBaseTestingClusterAutostarter.java

@BeforeClass
public static void setUp() throws Exception {
    LOG.info("HBase minicluster: Starting");
    ((Log4JLogger) RpcServer.LOG).getLogger().setLevel(Level.ALL);
    ((Log4JLogger) AbstractRpcClient.LOG).getLogger().setLevel(Level.ALL);
    ((Log4JLogger) ScannerCallable.LOG).getLogger().setLevel(Level.ALL);

    TEST_UTIL.startMiniCluster(1);

    // https://issues.apache.org/jira/browse/HBASE-11711
    TEST_UTIL.getConfiguration().setInt("hbase.master.info.port", -1);

    // Make sure the zookeeper quorum value contains the right port number (varies per run).
    TEST_UTIL.getConfiguration().set("hbase.zookeeper.quorum", "localhost:" + TEST_UTIL.getZkCluster().getClientPort());

    conf = initialize(TEST_UTIL.getConfiguration());
    LOG.info("HBase minicluster: Running");
}

项目：flink 文件：HBaseTestingClusterAutostarter.java

@BeforeClass
public static void setUp() throws Exception {
    LOG.info("HBase minicluster: Starting");
    ((Log4JLogger) RpcServer.LOG).getLogger().setLevel(Level.ALL);
    ((Log4JLogger) AbstractRpcClient.LOG).getLogger().setLevel(Level.ALL);
    ((Log4JLogger) ScannerCallable.LOG).getLogger().setLevel(Level.ALL);

    TEST_UTIL.startMiniCluster(1);

    // https://issues.apache.org/jira/browse/HBASE-11711
    TEST_UTIL.getConfiguration().setInt("hbase.master.info.port", -1);

    // Make sure the zookeeper quorum value contains the right port number (varies per run).
    TEST_UTIL.getConfiguration().set("hbase.zookeeper.quorum", "localhost:" + TEST_UTIL.getZkCluster().getClientPort());

    initialize(TEST_UTIL.getConfiguration());
    LOG.info("HBase minicluster: Running");
}

项目：ditb 文件：TableRecordReaderImpl.java

/**
 * @param htable the {@link org.apache.hadoop.hbase.HTableDescriptor} to scan.
 */
public void setHTable(Table htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：ditb 文件：TableRecordReaderImpl.java

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link org.apache.hadoop.hbase.HTableDescriptor} to scan.
 */
public void setHTable(Table htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：ditb 文件：FilterTestingCluster.java

@BeforeClass
public static void setUp() throws Exception {
  ((Log4JLogger)RpcServer.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)AbstractRpcClient.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  TEST_UTIL.startMiniCluster(1);
  initialize(TEST_UTIL.getConfiguration());
}

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

/**
 * @param htable the {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

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

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：pbase 文件：TableRecordReaderImpl.java

/**
 * @param htable the {@link org.apache.hadoop.hbase.HTableDescriptor} to scan.
 */
public void setHTable(Table htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：pbase 文件：TableRecordReaderImpl.java

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link org.apache.hadoop.hbase.HTableDescriptor} to scan.
 */
public void setHTable(Table htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：pbase 文件：FilterTestingCluster.java

@BeforeClass
public static void setUp() throws Exception {
  ((Log4JLogger)RpcServer.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)AbstractRpcClient.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  TEST_UTIL.startMiniCluster(1);
  initialize(TEST_UTIL.getConfiguration());
}

项目：HIndex 文件：TableRecordReaderImpl.java

/**
 * @param htable the {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：HIndex 文件：TableRecordReaderImpl.java

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：HIndex 文件：TestFlushSnapshotFromClient.java

/**
 * Setup the config for the cluster
 * @throws Exception on failure
 */
@BeforeClass
public static void setupCluster() throws Exception {
  ((Log4JLogger)RpcServer.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)RpcClient.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  setupConf(UTIL.getConfiguration());
  UTIL.startMiniCluster(NUM_RS);
}

项目：HIndex 文件：TestFilterWithScanLimits.java

@BeforeClass
public static void setUp() throws Exception {
  ((Log4JLogger)RpcServer.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)RpcClient.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  TEST_UTIL.startMiniCluster(1);
  initialize(TEST_UTIL.getConfiguration());
}

项目：IRIndex 文件：TableRecordReaderImpl.java

/**
 * @param htable the {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：IRIndex 文件：TableRecordReaderImpl.java

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：hbase 文件：TableRecordReaderImpl.java

/**
 * @param htable the {@link org.apache.hadoop.hbase.HTableDescriptor} to scan.
 */
public void setHTable(Table htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：hbase 文件：TableRecordReaderImpl.java

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link org.apache.hadoop.hbase.HTableDescriptor} to scan.
 */
public void setHTable(Table htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：PyroDB 文件：TableRecordReaderImpl.java

/**
 * @param htable the {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：PyroDB 文件：TableRecordReaderImpl.java

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：PyroDB 文件：TestFlushSnapshotFromClient.java

/**
 * Setup the config for the cluster
 * @throws Exception on failure
 */
@BeforeClass
public static void setupCluster() throws Exception {
  ((Log4JLogger)RpcServer.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)RpcClient.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  setupConf(UTIL.getConfiguration());
  UTIL.startMiniCluster(NUM_RS);
}

项目：PyroDB 文件：TestFilterWithScanLimits.java

@BeforeClass
public static void setUp() throws Exception {
  ((Log4JLogger)RpcServer.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)RpcClient.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  TEST_UTIL.startMiniCluster(1);
  initialize(TEST_UTIL.getConfiguration());
}

项目：c5 文件：TableRecordReaderImpl.java

/**
 * @param htable the {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：c5 文件：TableRecordReaderImpl.java

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：c5 文件：TestFlushSnapshotFromClient.java

/**
 * Setup the config for the cluster
 * @throws Exception on failure
 */
@BeforeClass
public static void setupCluster() throws Exception {
  ((Log4JLogger)RpcServer.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)RpcClient.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  setupConf(UTIL.getConfiguration());
  UTIL.startMiniCluster(NUM_RS);
}

项目：c5 文件：TestFilterWithScanLimits.java

@BeforeClass
public static void setUp() throws Exception {
  ((Log4JLogger)RpcServer.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)RpcClient.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  TEST_UTIL.startMiniCluster(1);
  initialize(TEST_UTIL.getConfiguration());
}

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

/**
 * @param htable the {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

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

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

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

/**
 * @param htable the {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

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

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

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

/**
 * @param htable the {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

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

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：DominoHBase 文件：TableRecordReaderImpl.java

/**
 * @param htable the {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：DominoHBase 文件：TableRecordReaderImpl.java

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：SpyGlass 文件：HBaseRecordReaderBase.java

/**
 * @param htable
 *          the {@link org.apache.hadoop.hbase.client.HTable} to scan.
 */
public void setHTable(HTable htable) {
    Configuration conf = htable.getConfiguration();
    logScannerActivity = conf.getBoolean(ScannerCallable.LOG_SCANNER_ACTIVITY,
            false);
    logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
    this.htable = htable;
}

项目：hindex 文件：TableRecordReaderImpl.java

/**
 * @param htable the {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：hindex 文件：TableRecordReaderImpl.java

/**
 * Sets the HBase table.
 *
 * @param htable  The {@link HTable} to scan.
 */
public void setHTable(HTable htable) {
  Configuration conf = htable.getConfiguration();
  logScannerActivity = conf.getBoolean(
    ScannerCallable.LOG_SCANNER_ACTIVITY, false);
  logPerRowCount = conf.getInt(LOG_PER_ROW_COUNT, 100);
  this.htable = htable;
}

项目：hbase-secondary-index 文件：TransactionalTable.java

@Override
protected ScannerCallable getScannerCallable(final byte[] localStartKey, final int caching) {
    getScan().setStartRow(localStartKey);
    TransactionScannerCallable t = new TransactionScannerCallable(transactionState, getConnection(),
            getTableName(), getScan());
    t.setCaching(caching);
    return t;
}

项目：ditb 文件：IntegrationTestWithCellVisibilityLoadAndVerify.java

private static void setJobScannerConf(Job job) {
  job.getConfiguration().setBoolean(ScannerCallable.LOG_SCANNER_ACTIVITY, true);
  long lpr = job.getConfiguration().getLong(NUM_TO_WRITE_KEY, NUM_TO_WRITE_DEFAULT) / 100;
  job.getConfiguration().setInt(TableRecordReaderImpl.LOG_PER_ROW_COUNT, (int) lpr);
}