org.embulk.spi.Exec.getBufferAllocator()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(1.8k)|赞(0)|评价(0)|浏览(85)

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

Exec.getBufferAllocator介绍

暂无

代码示例

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

private PageBuilder newPageBuilder(Schema schema, PageOutput output) {
  return new PageBuilder(Exec.getBufferAllocator(), schema, output);
}

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

@Override
public PageOutput open(TaskSource taskSource, Schema inputSchema,
    Schema outputSchema, PageOutput output) {
  PluginTask task = taskSource.loadTask(PluginTask.class);
  PageReader pageReader = new PageReader(inputSchema);
  PageBuilder pageBuilder = new PageBuilder(getBufferAllocator(), outputSchema, output);
  return new PageConverter(pageReader, pageBuilder, task.getIndexMapping());
}

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

final JsonParser jsonParser = new JsonParser();
try (final PageBuilder pageBuilder = new PageBuilder(Exec.getBufferAllocator(), schema, output)) {
  for (final List<JsonNode> rowValues : taskValues) {
    schema.visitColumns(new ColumnVisitor() {

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

final int skipHeaderLines = task.getSkipHeaderLines();
try (final PageBuilder pageBuilder = new PageBuilder(Exec.getBufferAllocator(), schema, output)) {
  while (tokenizer.nextFile()) {
    final String fileName = input.hintOfCurrentInputFileNameForLogging().orElse("-");

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

FileInput input, PageOutput output) {
try (final PageBuilder pageBuilder = new PageBuilder(
    Exec.getBufferAllocator(), schema, output)) {
  while (input.nextFile()) {
    Buffer buffer = input.poll();

代码示例来源:origin: sonots/embulk-filter-column

private PageBuilder pageBuilder = new PageBuilder(Exec.getBufferAllocator(), outputSchema, output);
private ColumnVisitorImpl visitor = new ColumnVisitorImpl(task, inputSchema, outputSchema, pageReader, pageBuilder);

相关文章