本文整理了Java中com.linkedin.parseq.Task.getName()
方法的一些代码示例,展示了Task.getName()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.getName()
方法的具体详情如下:
包路径:com.linkedin.parseq.Task
类名称: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));
}
内容来源于网络,如有侵权,请联系作者删除!