Sha256: 8a6e96758a1a040ab94aef9fadf6d6dc281c0f65109e03bcc17641abc5fa7058

Contents?: true

Size: 485 Bytes

Versions: 46

Compression:

Stored size: 485 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(java_class))
        end
        # TODO transaction, resume, cleanup
      end

      # TODO run
    end
  end

end

Version data entries

46 entries across 46 versions & 1 rubygems

Version Path
embulk-0.7.5 lib/embulk/file_input_plugin.rb
embulk-0.7.5-java lib/embulk/file_input_plugin.rb
embulk-0.7.4 lib/embulk/file_input_plugin.rb
embulk-0.7.4-java lib/embulk/file_input_plugin.rb
embulk-0.7.3 lib/embulk/file_input_plugin.rb
embulk-0.7.3-java lib/embulk/file_input_plugin.rb