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

Exec.newTaskSource介绍

暂无

代码示例

代码示例来源：origin: embulk/embulk

@Override
public ConfigDiff transaction(ConfigSource config,
    Schema schema, int taskCount,
    OutputPlugin.Control control) {
  return resume(Exec.newTaskSource(), schema, taskCount, control);
}

代码示例来源：origin: embulk/embulk

public ConfigDiff transaction(ConfigSource config, FileInputPlugin.Control control) {
  control.run(Exec.newTaskSource(), 1);
  return Exec.newConfigDiff();
}

代码示例来源：origin: embulk/embulk

@Override
public ConfigDiff transaction(ConfigSource config,
    FileInputPlugin.Control control) {
  control.run(Exec.newTaskSource(), 1);
  return null;
}

代码示例来源：origin: embulk/embulk

public ProcessTask buildProcessTask() {
  return new ProcessTask(
      plugins.getInputPluginType(), plugins.getOutputPluginType(), plugins.getFilterPluginTypes(),
      inputTaskSource, outputTaskSource, filterTaskSources,
      schemas, executorSchema, Exec.newTaskSource());
}

代码示例来源：origin: embulk/embulk

@Before
public void setup() throws Exception {
  taskSource = Exec.newTaskSource();
  taskSource.set("Boolean", false);
  taskSource.set("Double", 0.5);
  taskSource.set("Int", 0);
  taskSource.set("Long", 0);
  taskSource.set("String", "");
}