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

Exec.newTaskReport介绍

暂无

代码示例

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

public TaskReport commit() {
    return Exec.newTaskReport();
  }
};

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

public TaskReport commit() {
    TaskReport report = Exec.newTaskReport();
    // TODO better setting for Report
    // report.set("file_names", fileNames);
    // report.set("file_sizes", fileSizes);
    return report;
  }
};

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

@Override
public TaskReport commit() {
  return Exec.newTaskReport();
}

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

public TaskReport commit() {
    return Exec.newTaskReport();
  }
};

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

@Override
  public TaskReport commit() {
    transactionCompleted = true;
    return Exec.newTaskReport();
  }
};

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

@Override
public TaskReport run(TaskSource taskSource, Schema schema, int taskIndex, PageOutput output) {
  for (Page page : previewResult.getPages()) {
    output.add(page);
  }
  return Exec.newTaskReport();
}

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

public TaskReport commit() {
  completeWorkers();
  for (int i = 0; i < scatterCount; i++) {
    if (trans[i] != null) {
      int outputTaskIndex = taskIndex * scatterCount + i;
      TaskReport outputTaskReport = trans[i].commit();
      trans[i] = null;  // don't abort
      if (outputTaskReport == null) {
        outputTaskReport = Exec.newTaskReport();
      }
      state.getOutputTaskState(outputTaskIndex).setTaskReport(outputTaskReport);
    }
  }
  return null;
}

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

return Exec.newTaskReport();

代码示例来源：origin: embulk/embulk-input-s3

public TaskReport commit()
{
  return Exec.newTaskReport();
}

代码示例来源：origin: embulk/embulk-output-elasticsearch

@Override
  public TaskReport commitWithTaskReportUpdated(TaskReport taskReport)
  {
    if (records.size() > 0) {
      client.push(records, task);
      log.info("Inserted {} records", records.size());
    }
    return Exec.newTaskReport().set("inserted", totalCount);
  }
}

代码示例来源：origin: embulk/embulk-output-elasticsearch

@Override
  public List<TaskReport> run(TaskSource taskSource)
  {
    return Lists.newArrayList(Exec.newTaskReport());
  }
});

代码示例来源：origin: embulk/embulk-output-elasticsearch

@Override
  public List<TaskReport> run(TaskSource taskSource)
  {
    return Lists.newArrayList(Exec.newTaskReport());
  }
});

代码示例来源：origin: embulk/embulk-output-elasticsearch

@Override
  public List<TaskReport> run(TaskSource taskSource)
  {
    return Lists.newArrayList(Exec.newTaskReport());
  }
});

代码示例来源：origin: embulk/embulk-output-elasticsearch

@Override
  public List<TaskReport> run(TaskSource taskSource)
  {
    return Lists.newArrayList(Exec.newTaskReport());
  }
});

代码示例来源：origin: embulk/embulk-output-elasticsearch

@Override
  public List<TaskReport> run(TaskSource taskSource)
  {
    return Lists.newArrayList(Exec.newTaskReport());
  }
});

代码示例来源：origin: embulk/embulk-output-elasticsearch

@Override
  public List<TaskReport> run(TaskSource taskSource)
  {
    return Lists.newArrayList(Exec.newTaskReport());
  }
});

代码示例来源：origin: embulk/embulk-output-elasticsearch

@Override
  public List<TaskReport> run(TaskSource taskSource)
  {
    return Lists.newArrayList(Exec.newTaskReport());
  }
});

代码示例来源：origin: embulk/embulk-output-elasticsearch

@Override
  public List<TaskReport> run(TaskSource taskSource)
  {
    return Lists.newArrayList(Exec.newTaskReport());
  }
});

代码示例来源：origin: embulk/embulk-output-elasticsearch

@Test
public void testCleanup()
{
  ConfigSource config = utils.configJSON();
  Schema schema = utils.JSONSchema();
  PluginTask task = config.loadConfig(PluginTask.class);
  plugin.cleanup(task.dump(), schema, 0, Arrays.asList(Exec.newTaskReport()));
  // no error happens
}

代码示例来源：origin: embulk/embulk-output-elasticsearch

@Test
public void testCleanup()
{
  ConfigSource config = utils.config();
  Schema schema = config.getNested("parser").loadConfig(CsvParserPlugin.PluginTask.class).getSchemaConfig().toSchema();
  PluginTask task = config.loadConfig(PluginTask.class);
  plugin.cleanup(task.dump(), schema, 0, Arrays.asList(Exec.newTaskReport()));
  // no error happens
}