本文整理了Java中org.apache.kylin.common.QueryContext.checkMillisBeforeDeadline方法的一些代码示例，展示了QueryContext.checkMillisBeforeDeadline的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QueryContext.checkMillisBeforeDeadline方法的具体详情如下：
包路径：org.apache.kylin.common.QueryContext
类名称：QueryContext
方法名：checkMillisBeforeDeadline

QueryContext.checkMillisBeforeDeadline介绍

暂无

代码示例

代码示例来源：origin: apache/kylin

@Override
public ITuple next() {
  if (scanCount++ % 100 == 1) {
    QueryContextFacade.current().checkMillisBeforeDeadline();
  }
  if (++scanCountDelta >= 1000) {
    flushScanCountDelta();
  }
  return tupleIterator.next();
}

代码示例来源：origin: apache/kylin

protected long getCoprocessorTimeoutMillis() {
  long coopTimeout;
  if (BackdoorToggles.getQueryTimeout() != -1) {
    coopTimeout = BackdoorToggles.getQueryTimeout();
  } else {
    coopTimeout = cubeSeg.getConfig().getQueryCoprocessorTimeoutSeconds() * 1000L;
  }
  
  int rpcTimeout;
  Configuration hconf = HBaseConnection.getCurrentHBaseConfiguration();
  rpcTimeout = hconf.getInt(HConstants.HBASE_RPC_TIMEOUT_KEY, HConstants.DEFAULT_HBASE_RPC_TIMEOUT);
  
  // HBase rpc timeout must be longer than coprocessor timeout
  if ((int) (coopTimeout * 1.1) > rpcTimeout) {
    rpcTimeout = (int) (coopTimeout * 1.1);
    hconf.setInt(HConstants.HBASE_RPC_TIMEOUT_KEY, rpcTimeout);
  }
  
  // coprocessor timeout is 0 by default
  if (coopTimeout <= 0) {
    coopTimeout = (long) (rpcTimeout * 0.9);
  }
  queryContext.checkMillisBeforeDeadline();
  logger.debug("{} = {} ms, use {} ms as timeout for coprocessor", HConstants.HBASE_RPC_TIMEOUT_KEY, rpcTimeout, coopTimeout);
  return coopTimeout;
}

代码示例来源：origin: apache/kylin

QueryContextFacade.current().checkMillisBeforeDeadline();

代码示例来源：origin: org.apache.kylin/kylin-core-storage

@Override
public ITuple next() {
  if (scanCount++ % 100 == 1) {
    QueryContextFacade.current().checkMillisBeforeDeadline();
  }
  if (++scanCountDelta >= 1000) {
    flushScanCountDelta();
  }
  return tupleIterator.next();
}

代码示例来源：origin: org.apache.kylin/kylin-storage-hbase

protected long getCoprocessorTimeoutMillis() {
  long coopTimeout;
  if (BackdoorToggles.getQueryTimeout() != -1) {
    coopTimeout = BackdoorToggles.getQueryTimeout();
  } else {
    coopTimeout = cubeSeg.getConfig().getQueryCoprocessorTimeoutSeconds() * 1000L;
  }
  
  int rpcTimeout;
  Configuration hconf = HBaseConnection.getCurrentHBaseConfiguration();
  rpcTimeout = hconf.getInt(HConstants.HBASE_RPC_TIMEOUT_KEY, HConstants.DEFAULT_HBASE_RPC_TIMEOUT);
  
  // HBase rpc timeout must be longer than coprocessor timeout
  if ((int) (coopTimeout * 1.1) > rpcTimeout) {
    rpcTimeout = (int) (coopTimeout * 1.1);
    hconf.setInt(HConstants.HBASE_RPC_TIMEOUT_KEY, rpcTimeout);
  }
  
  // coprocessor timeout is 0 by default
  if (coopTimeout <= 0) {
    coopTimeout = (long) (rpcTimeout * 0.9);
  }
  queryContext.checkMillisBeforeDeadline();
  logger.debug("{} = {} ms, use {} ms as timeout for coprocessor", HConstants.HBASE_RPC_TIMEOUT_KEY, rpcTimeout, coopTimeout);
  return coopTimeout;
}

代码示例来源：origin: org.apache.kylin/kylin-core-storage

QueryContextFacade.current().checkMillisBeforeDeadline();