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