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

QueryContext.getSubmittedUser介绍

暂无

代码示例

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

public String getClusterUser() {
 return conf.get(LensConfConstants.SESSION_CLUSTER_USER, getSubmittedUser());
}

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

public String getClusterUser() {
 return conf.get(LensConfConstants.SESSION_CLUSTER_USER, getSubmittedUser());
}

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

@Override
public boolean add(final QueryContext query) {
 queriesByUser.put(query.getSubmittedUser(), query);
 return queries.add(query);
}

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

public DefaultQueryCollection(final TreeSet<QueryContext> treeSet) {
 this.queries = treeSet;
 for (QueryContext query : treeSet) {
  queriesByUser.put(query.getSubmittedUser(), query);
 }
}

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

@Override
public boolean remove(final QueryContext query) {
 queriesByUser.remove(query.getSubmittedUser(), query);
 return queries.remove(query);
}

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

public static void stubSubmittedUserInMockQueries(final Set<QueryContext> mockQueries, final String mockUser) {
 for (QueryContext mockQuery : mockQueries) {
  when(mockQuery.getSubmittedUser()).thenReturn(mockUser);
 }
}

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

public QueryCancelled(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
  // TODO: correct username. put who cancelled it, not the submitter. Similar for others
  this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
 }
}

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

public QueryClosed(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
  this(ctx, ctx.getClosedTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
 }
}

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

public QueryCancelled(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
  // TODO: correct username. put who cancelled it, not the submitter. Similar for others
  this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
 }
}

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

public QueryClosed(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
  this(ctx, ctx.getClosedTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
 }
}

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

public QueryFailed(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
  this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
 }
}

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

public QueryFailed(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
  this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
 }
}

代码示例来源：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: org.apache.lens/lens-server-api

@Override
 public void preLaunch(QueryContext ctx) throws LensException {
  log.debug("Pre launch for user {}, user query: {}, driver {}, driver query: {}", ctx.getSubmittedUser(),
   ctx.getUserQuery(), ctx.getSelectedDriver().getFullyQualifiedName(), ctx.getSelectedDriverQuery());
 }
}

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

@Override
 public void preLaunch(QueryContext ctx) throws LensException {
  log.debug("Pre launch for user {}, user query: {}, driver {}, driver query: {}", ctx.getSubmittedUser(),
   ctx.getUserQuery(), ctx.getSelectedDriver().getFullyQualifiedName(), ctx.getSelectedDriverQuery());
 }
}

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

fs = FileSystemUtil.createFileSystem(ctx.getSubmittedUser(), new Path(pathStr));
} else {
 fs = finalPath.getFileSystem(ctx.getConf());

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

@Test(dataProvider = "dpTestAllowsLaunchOfQuery")
public void testAllowsLaunchOfQuery(final double totalQueryCostForCurrentUser, final boolean expectedCanLaunch) {
 final QueryCost totalQueryCostCeilingPerUser = new FactPartitionBasedQueryCost(90.0);
 final QueryLaunchingConstraint queryConstraint
  = new TotalQueryCostCeilingConstraint(Optional.of(totalQueryCostCeilingPerUser));
 final QueryContext query = mock(QueryContext.class);
 final EstimatedImmutableQueryCollection launchedQueries = mock(EstimatedImmutableQueryCollection.class);
 final String mockUser = "MockUser";
 when(query.getSubmittedUser()).thenReturn(mockUser);
 when(launchedQueries.getTotalQueryCost(mockUser))
  .thenReturn(new FactPartitionBasedQueryCost(totalQueryCostForCurrentUser));
 String actualCanLaunch = queryConstraint.allowsLaunchOf(query, launchedQueries);
 if (expectedCanLaunch) {
  assertNull(actualCanLaunch);
 } else {
  assertNotNull(actualCanLaunch);
 }
}

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

@Override
public Response getAuthorizedHttpResultSet(LensSessionHandle sessionHandle, QueryHandle queryHandle,
 String userPrincipalName) throws LensException {
 String loggedInUser;
 if (sessionHandle != null) {
  //@TODO this check can be introduced in other api calls as well if required
  validateAndAuthorizeSession(sessionHandle, userPrincipalName);
  loggedInUser = getSession(sessionHandle).getLoggedInUser();
 } else {
  loggedInUser = userPrincipalName;
 }
 final QueryContext ctx = getUpdatedQueryContext(sessionHandle, queryHandle);
 if (!loggedInUser.equals(ctx.getSubmittedUser())) {
  throw new PrivilegeException("Query", queryHandle.toString(), "download");
 }
 return getResponse(sessionHandle, queryHandle, ctx);
}
/*

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

this.handle = ctx.getQueryHandle().toString();
this.userQuery = ctx.getUserQuery();
this.submitter = ctx.getSubmittedUser();
this.submissionTime = ctx.getSubmissionTime();
this.startTime = ctx.getLaunchTime();

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

this.handle = ctx.getQueryHandle().toString();
this.userQuery = ctx.getUserQuery();
this.submitter = ctx.getSubmittedUser();
this.submissionTime = ctx.getSubmissionTime();
this.startTime = ctx.getLaunchTime();