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.8.13 lib/embulk/file_input_plugin.rb
embulk-0.8.13-java lib/embulk/file_input_plugin.rb
embulk-0.8.12 lib/embulk/file_input_plugin.rb
embulk-0.8.12-java lib/embulk/file_input_plugin.rb
embulk-0.8.11-java lib/embulk/file_input_plugin.rb
embulk-0.8.11 lib/embulk/file_input_plugin.rb
embulk-0.8.10 lib/embulk/file_input_plugin.rb
embulk-0.8.10-java lib/embulk/file_input_plugin.rb
embulk-0.8.9 lib/embulk/file_input_plugin.rb
embulk-0.8.9-java lib/embulk/file_input_plugin.rb
embulk-0.8.8 lib/embulk/file_input_plugin.rb
embulk-0.8.8-java lib/embulk/file_input_plugin.rb
embulk-0.8.7 lib/embulk/file_input_plugin.rb
embulk-0.8.7-java lib/embulk/file_input_plugin.rb
embulk-0.8.6 lib/embulk/file_input_plugin.rb
embulk-0.8.6-java lib/embulk/file_input_plugin.rb
embulk-0.8.5 lib/embulk/file_input_plugin.rb
embulk-0.8.5-java lib/embulk/file_input_plugin.rb
embulk-0.8.4 lib/embulk/file_input_plugin.rb
embulk-0.8.4-java lib/embulk/file_input_plugin.rb