Sha256: b21853a8c04762187ca9bbcc44a3d6d45aa22fd988d40f3e3da2ae5af5f56240

Contents?: true

Size: 492 Bytes

Versions: 69

Compression:

Stored size: 492 Bytes

Contents

module Embulk

  class FileInputPlugin
    # TODO transaction, resume, cleanup
    # TODO run

    # TODO to_java

    def self.from_java(java_class)
      JavaPlugin.ruby_adapter_class(java_class, FileInputPlugin, RubyAdapter)
    end

    module RubyAdapter
      module ClassMethods
        def new_java
          Java::FileInputRunner.new(Java.injector.getInstance(plugin_java_class))
        end
        # TODO transaction, resume, cleanup
      end

      # TODO run
    end
  end

end

Version data entries

69 entries across 69 versions & 1 rubygems

Version Path
embulk-0.10.31.3-java lib/embulk/file_input_plugin.rb
embulk-0.10.32.3-java lib/embulk/file_input_plugin.rb
embulk-0.10.32.2-java lib/embulk/file_input_plugin.rb
embulk-0.10.32.1-java lib/embulk/file_input_plugin.rb
embulk-0.10.31.2-java lib/embulk/file_input_plugin.rb
embulk-0.10.29.2-java lib/embulk/file_input_plugin.rb
embulk-0.10.31.1-java lib/embulk/file_input_plugin.rb
embulk-0.10.29.1-java lib/embulk/file_input_plugin.rb
embulk-0.10.32-java lib/embulk/file_input_plugin.rb
embulk-0.10.31-java lib/embulk/file_input_plugin.rb
embulk-0.10.30-java lib/embulk/file_input_plugin.rb
embulk-0.10.29-java lib/embulk/file_input_plugin.rb
embulk-0.10.28-java lib/embulk/file_input_plugin.rb
embulk-0.10.27-java lib/embulk/file_input_plugin.rb
embulk-0.10.26-java lib/embulk/file_input_plugin.rb
embulk-0.10.25-java lib/embulk/file_input_plugin.rb
embulk-0.10.24-java lib/embulk/file_input_plugin.rb
embulk-0.8.39 lib/embulk/file_input_plugin.rb
embulk-0.8.39-java lib/embulk/file_input_plugin.rb
embulk-0.8.38 lib/embulk/file_input_plugin.rb