Sha256: 2afa6fd9f2255f4643d6aee7928b101306fcac93c56f26551fc3e4dd8acb2baf

Contents?: true

Size: 539 Bytes

Versions: 51

Compression:

Stored size: 539 Bytes

Contents

module Embulk

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

    if Embulk.java?
      # 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

end

Version data entries

51 entries across 51 versions & 1 rubygems

Version Path
embulk-0.6.27 lib/embulk/file_input_plugin.rb
embulk-0.7.2 lib/embulk/file_input_plugin.rb
embulk-0.7.2-java lib/embulk/file_input_plugin.rb
embulk-0.6.26 lib/embulk/file_input_plugin.rb
embulk-0.7.1 lib/embulk/file_input_plugin.rb
embulk-0.7.1-java lib/embulk/file_input_plugin.rb
embulk-0.7.0 lib/embulk/file_input_plugin.rb
embulk-0.7.0-java lib/embulk/file_input_plugin.rb
embulk-0.6.25 lib/embulk/file_input_plugin.rb
embulk-0.6.24 lib/embulk/file_input_plugin.rb
embulk-0.6.23 lib/embulk/file_input_plugin.rb
embulk-0.6.22 lib/embulk/file_input_plugin.rb
embulk-0.6.21 lib/embulk/file_input_plugin.rb
embulk-0.6.20 lib/embulk/file_input_plugin.rb
embulk-0.6.19 lib/embulk/file_input_plugin.rb
embulk-0.6.18 lib/embulk/file_input_plugin.rb
embulk-0.6.17 lib/embulk/file_input_plugin.rb
embulk-0.6.16 lib/embulk/file_input_plugin.rb
embulk-0.6.15 lib/embulk/file_input_plugin.rb
embulk-0.6.14 lib/embulk/file_input_plugin.rb