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

QueryContext.getSubmissionTime介绍

暂无

代码示例

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

@Override
 public int compare(QueryContext o1, QueryContext o2) {
  return Long.compare(o1.getSubmissionTime(), o2.getSubmissionTime());
 }
}

代码示例来源：origin: org.apache.lens/lens-server-api

@Override
 public int compare(QueryContext o1, QueryContext o2) {
  return Long.compare(o1.getSubmissionTime(), o2.getSubmissionTime());
 }
}

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

private List<QueryHandle> getQueriesInMemory(Set<Status> statuses, String userName, String driver,
 String queryName, long fromTime, long toTime) throws LensException {
 userName = UtilityMethods.removeDomain(userName);
 boolean filterByQueryName = StringUtils.isNotBlank(queryName);
 if (filterByQueryName) {
  queryName = queryName.toLowerCase();
 }
 boolean filterByDriver = StringUtils.isNotBlank(driver);
 List<QueryHandle> all = new ArrayList<QueryHandle>(allQueries.keySet());
 Iterator<QueryHandle> itr = all.iterator();
 while (itr.hasNext()) {
  QueryHandle q = itr.next();
  QueryContext context = allQueries.get(q);
  long querySubmitTime = context.getSubmissionTime();
  if ((!statuses.contains(context.getStatus().getStatus()))
   || (filterByQueryName && !context.getQueryName().toLowerCase().contains(queryName))
   || (filterByDriver && !context.getSelectedDriver().getFullyQualifiedName().equalsIgnoreCase(driver))
   || (!"all".equalsIgnoreCase(userName) && !userName.equalsIgnoreCase(context.getSubmittedUser()))
   || (!(fromTime <= querySubmitTime && querySubmitTime < toTime))) {
   itr.remove();
  }
 }
 return all;
}

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

@Test(dataProvider = "dpSubmitTimeCompare")
 public void testCompareOnQuerySubmitTime(final long submitTimeQuery1, final long submitTimeQuery2,
   final int expectedResult) {

  QueryContext query1 = mock(QueryContext.class);
  when(query1.getPriority()).thenReturn(Priority.HIGH);

  QueryCost s1 = new StaticQueryCost(0.0);
  QueryCost s2 = new StaticQueryCost(0.0);

  when(query1.getSelectedDriverQueryCost()).thenReturn(s1);

  QueryContext query2 = mock(QueryContext.class);
  when(query2.getPriority()).thenReturn(Priority.HIGH);
  when(query2.getSelectedDriverQueryCost()).thenReturn(s2);

  when(query1.getSubmissionTime()).thenReturn(submitTimeQuery1);
  when(query2.getSubmissionTime()).thenReturn(submitTimeQuery2);

  // Cost and Priority both are same, hence the comparison should happen
  // on query submission time
  assertEquals(priorityAndFifoComparator.compare(query1, query2), expectedResult);
  assertEquals(costAndFifoComparator.compare(query1, query2), expectedResult);

 }
}

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

case QUEUED:
 if (ctx.getFailedAttempts().size() > 0) {
  return new QueryQueuedForRetry(ctx.getSubmissionTime(), prevState, currState, query, ctx.getSubmittedUser());
 } else {
  return new QueryQueued(ctx.getSubmissionTime(), prevState, currState, query, ctx.getSubmittedUser());

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

long timeoutMillis, Configuration conf) throws LensException {
QueryHandle handle = submitQuery(ctx);
long timeOutTime = ctx.getSubmissionTime() + timeoutMillis;
log.info("query {} is executed with a timeout of {} and will timeout by {}", handle, timeoutMillis, timeOutTime);
QueryHandleWithResultSet result = new QueryHandleWithResultSet(handle);

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

event.setSubmitter(ctx.getSubmittedUser());
event.setClusterUser(ctx.getClusterUser());
event.setSubmissionTime(ctx.getSubmissionTime());
QueryDriverStatistics driverStats = new QueryDriverStatistics();
driverStats.setDriverQuery(ctx.getSelectedDriverQuery());

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

long submissionTime = queryContext.getSubmissionTime();
queryContext.setQueryName("daoTestQuery1");
queryContext.getDriverContext().setSelectedDriver(new MockDriver());

代码示例来源：origin: org.apache.lens/lens-server-api

this.userQuery = ctx.getUserQuery();
this.submitter = ctx.getSubmittedUser();
this.submissionTime = ctx.getSubmissionTime();
this.startTime = ctx.getLaunchTime();
this.endTime = ctx.getEndTime();

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

this.userQuery = ctx.getUserQuery();
this.submitter = ctx.getSubmittedUser();
this.submissionTime = ctx.getSubmissionTime();
this.startTime = ctx.getLaunchTime();
this.endTime = ctx.getEndTime();