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

Query.getUncaughtExceptionHandler介绍

暂无

代码示例

代码示例来源：origin: NationalSecurityAgency/datawave

public Thread newThread(Runnable r) {
  Thread thread = dtf.newThread(r);
  thread.setName(name + " Session " + threadIdentifier + " -" + threadNum++);
  thread.setDaemon(true);
  thread.setUncaughtExceptionHandler(config.getQuery().getUncaughtExceptionHandler());
  return thread;
}

代码示例来源：origin: NationalSecurityAgency/datawave

public Thread newThread(Runnable r) {
  Thread thread = dtf.newThread(r);
  thread.setName("Datawave FixUnfieldedTermsVisitor Session " + threadIdentifier + " -" + threadNum++);
  thread.setDaemon(true);
  thread.setUncaughtExceptionHandler(config.getQuery().getUncaughtExceptionHandler());
  return thread;
}

代码示例来源：origin: NationalSecurityAgency/datawave

this.uncaughtExceptionHandler = this.settings.getUncaughtExceptionHandler();

代码示例来源：origin: NationalSecurityAgency/datawave

private void testForUncaughtException(int numResults) throws QueryException {
    QueryUncaughtExceptionHandler handler = settings.getUncaughtExceptionHandler();
    if (handler != null) {
      if (handler.getThrowable() != null) {
        if (numResults > 0) {
          log.warn("Exception with Partial Results: resultList.getResults().size() is " + numResults + ", and there was an UncaughtException:"
                  + handler.getThrowable() + " in thread " + handler.getThread());
        } else {
          if (log.isDebugEnabled()) {
            log.debug("Throwing:" + handler.getThrowable() + " for query with no results");
          }
        }
        if (handler.getThrowable() instanceof QueryException) {
          throw ((QueryException) handler.getThrowable());
        }
        throw new QueryException(handler.getThrowable());
      }
    }
  }
}

代码示例来源：origin: NationalSecurityAgency/datawave

public Query create(String userDN, List<String> dnList, SecurityMarking marking, String queryLogicName, QueryParameters qp,
        MultivaluedMap<String,String> optionalQueryParameters) {
  Query q = responseObjectFactory.getQueryImpl();
  q.initialize(userDN, dnList, queryLogicName, qp, optionalQueryParameters);
  q.setColumnVisibility(marking.toColumnVisibilityString());
  q.setUncaughtExceptionHandler(new QueryUncaughtExceptionHandler());
  Thread.currentThread().setUncaughtExceptionHandler(q.getUncaughtExceptionHandler());
  // Persist the query object if required
  if (qp.getPersistenceMode().equals(QueryPersistence.PERSISTENT)) {
    log.debug("Persisting query with id: " + q.getId());
    create(q);
  }
  return q;
}

代码示例来源：origin: NationalSecurityAgency/datawave

private void testForUncaughtException(Query settings, ResultsPage resultList) throws QueryException {
    QueryUncaughtExceptionHandler handler = settings.getUncaughtExceptionHandler();
    if (handler != null) {
      if (handler.getThrowable() != null) {
        if (resultList.getResults() != null && !resultList.getResults().isEmpty()) {
          log.warn("Exception with Partial Results: resultList.getResults().size() is " + resultList.getResults().size()
                  + ", and there was an UncaughtException:" + handler.getThrowable() + " in thread " + handler.getThread());
        } else {
          if (log.isDebugEnabled()) {
            log.debug("Throwing:" + handler.getThrowable() + " for query with no results");
          }
        }
        if (handler.getThrowable() instanceof QueryException) {
          throw ((QueryException) handler.getThrowable());
        }
        throw new QueryException(handler.getThrowable());
      }
    }
  }
}

代码示例来源：origin: NationalSecurityAgency/datawave

else
  rangeConsumerThread.setName("RangeBundlerIterator for ");
rangeConsumerThread.setUncaughtExceptionHandler(settings.getUncaughtExceptionHandler());

代码示例来源：origin: NationalSecurityAgency/datawave

boolean nextTooLong = !clearAll && query.hasActiveCall() && isNextTooLong(query, now);
if (clearAll || idleTooLong || nextTooLong) {
  if (query.getSettings().getUncaughtExceptionHandler() == null) {
    query.getSettings().setUncaughtExceptionHandler(new QueryUncaughtExceptionHandler());
    if (clearAll) {
      query.getMetric().setLifecycle(QueryMetric.Lifecycle.SHUTDOWN);
      query.getSettings().getUncaughtExceptionHandler()
              .uncaughtException(Thread.currentThread(), new QueryException(DatawaveErrorCode.SERVER_SHUTDOWN));
    } else {
      query.getSettings().getUncaughtExceptionHandler()
              .uncaughtException(Thread.currentThread(), new QueryException(DatawaveErrorCode.QUERY_TIMEOUT));

代码示例来源：origin: NationalSecurityAgency/datawave

q.setId(originalQuery.getId());
q.setUncaughtExceptionHandler(new QueryUncaughtExceptionHandler());
Thread.currentThread().setUncaughtExceptionHandler(q.getUncaughtExceptionHandler());