com.linkedin.parseq.Task.getName()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(4.0k)|赞(0)|评价(0)|浏览(92)

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

Task.getName介绍

[英]Returns the name of this task.
[中]返回此任务的名称。

代码示例

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

/**
 * {@inheritDoc}
 */
@Override
public String getName() {
 return _task.getName();
}

代码示例来源:origin: linkedin/parseq

public void logTaskStart(final Task<?> task) {
 if (_planLogger.isDebugEnabled()) {
  _planLogger.debug(START_TASK_FORMAT, _planId, task.getName());
 } else if (_rootLogger.isDebugEnabled() && _rootId.equals(task.getId())) {
  _rootLogger.debug(START_TASK_FORMAT, _planId, task.getName());
 } else if (_allLogger.isDebugEnabled()) {
  _allLogger.debug(START_TASK_FORMAT, _planId, task.getName());
 }
}

代码示例来源:origin: linkedin/parseq

/**
 * Equivalent to {@code andThen("andThen", task)}.
 * @see #andThen(String, Task)
 */
default <R> Task<R> andThen(final Task<R> task) {
 return andThen("andThen: " + task.getName(), task);
}

代码示例来源:origin: linkedin/parseq

@Override
public void uncaughtException(Throwable error) {
 final String msg = "Serial executor loop failed for plan: " + _task.getName();
 final SerialExecutionException ex = new SerialExecutionException(msg, error);
 final boolean wasCancelled = _task.cancel(ex);
 LOG.error(msg + ". The plan was " + (wasCancelled ? "" : "not ") + "cancelled.", ex);
}

代码示例来源:origin: linkedin/parseq

private int assertHasStartLog(String loggerName, Task<?> task, List<ListLogger.Entry> entries) {
 for (int i = 0; i < entries.size(); i++) {
  final String message = entries.get(i).getMessage();
  if (message.contains("Starting task") && message.contains(task.getName())) {
   return i;
  }
 }
 fail(loggerName + ": " + entries + " does not contain a start log entry for " + task.getName());
 throw new RuntimeException("Execution never gets here - see preceding fail");
}

代码示例来源:origin: linkedin/parseq

private int assertHasDebugEndLog(String loggerName, Task<?> task, List<ListLogger.Entry> entries) {
 for (int i = 0; i < entries.size(); i++) {
  final String message = entries.get(i).getMessage();
  if (message.contains("Ending task") && message.contains(task.getName())
    && message.contains(ResultType.fromTask(task).toString())) {
   return i;
  }
 }
 fail(loggerName + ": " + entries + " does not contain an end log entry for " + task.getName());
 throw new RuntimeException("Execution never gets here - see preceding fail");
}

代码示例来源:origin: linkedin/parseq

@Test
public void testTaskNameTruncation() {
 Task<?> t = Task.value(times("x", 4096), "hello");
 assertEquals(t.getName(), times("x", 1024));
}

相关文章