import org.embulk.spi.util.InputStreamFileInput; //导入依赖的package包/类
@Override
public FileInput open(TaskSource taskSource, FileInput fileInput) {
  final PluginTask task = taskSource.loadTask(PluginTask.class);

  final FileInputInputStream files = new FileInputInputStream(fileInput);

  return new InputStreamFileInput(
      task.getBufferAllocator(),
      new InputStreamFileInput.Provider() {
        public InputStream openNext() throws IOException {
          if (!files.nextFile()) {
            return null;
          }
          LOGGER.debug("generate LZ4FrameInputStream for {}", files.toString());
          return new LZ4FrameInputStream(files);
        }

        public void close() throws IOException {
          files.close();
        }
      }
  );
}
 

import org.embulk.spi.util.InputStreamFileInput; //导入依赖的package包/类
private FileInput fileInput(String... lines)
        throws Exception
{
    StringBuilder sb = new StringBuilder();
    for (String line : lines) {
        sb.append(line).append("\n");
    }

    ByteArrayInputStream in = new ByteArrayInputStream(sb.toString().getBytes(StandardCharsets.UTF_8));
    return new InputStreamFileInput(runtime.getBufferAllocator(), provider(in));
}
 

import org.embulk.spi.util.InputStreamFileInput; //导入依赖的package包/类
private FileInput fileInput(String... lines)
        throws Exception
{
    StringBuilder sb = new StringBuilder();
    for (String line : lines) {
        sb.append(line).append("\n");
    }

    ByteArrayInputStream in = new ByteArrayInputStream(sb.toString().getBytes());
    return new InputStreamFileInput(runtime.getBufferAllocator(), provider(in));
}
 

import org.embulk.spi.util.InputStreamFileInput; //导入依赖的package包/类
private FileInput fileInput(File file)
        throws Exception
{
    FileInputStream in = new FileInputStream(file);
    return new InputStreamFileInput(runtime.getBufferAllocator(), provider(in));
}
 

import org.embulk.spi.util.InputStreamFileInput; //导入依赖的package包/类
private InputStreamFileInput.IteratorProvider provider(InputStream... inputStreams)
        throws IOException
{
    return new InputStreamFileInput.IteratorProvider(
            ImmutableList.copyOf(inputStreams));
}