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::org.embulk.plugin.PluginManager.newPluginInstance(plugin_java_class, Embulk::Java::EmbulkSystemProperties), Embulk::Java::EmbulkSystemProperties)
        end
        # TODO transaction, resume, cleanup
      end

      # TODO run
    end
  end

end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
embulk-0.11.5-java	lib/embulk/file_input_plugin.rb
embulk-0.11.3-java	lib/embulk/file_input_plugin.rb
embulk-0.11.2-java	lib/embulk/file_input_plugin.rb
embulk-0.11.1-java	lib/embulk/file_input_plugin.rb
embulk-0.11.0-java	lib/embulk/file_input_plugin.rb
embulk-0.10.50-java	lib/embulk/file_input_plugin.rb
embulk-0.10.49-java	lib/embulk/file_input_plugin.rb
embulk-0.10.48-java	lib/embulk/file_input_plugin.rb