Sha256: 9349f1bfa59a7f7edd77296f3ae4762b7d0abd3fd99957db0c7526622b75d0d5

Contents?: true

Size: 555 Bytes

Versions: 69

Compression:

Stored size: 555 Bytes

Contents

module Embulk

  class FileOutputPlugin
    # TODO transaction, resume, cleanup
    # TODO add, finish, close, abort, commit

    # TODO to_java

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

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

      # TODO add, finish, close, abort, commit
    end
  end

end

Version data entries

69 entries across 69 versions & 1 rubygems

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