Sha256: d44105d1b12ab1475d37352831e7f128b8c788f81dae0586856e66964f6c1ab8

Contents?: true

Size: 548 Bytes

Versions: 46

Compression:

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

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

end

Version data entries

46 entries across 46 versions & 1 rubygems

Version Path
embulk-0.8.13 lib/embulk/file_output_plugin.rb
embulk-0.8.13-java lib/embulk/file_output_plugin.rb
embulk-0.8.12 lib/embulk/file_output_plugin.rb
embulk-0.8.12-java lib/embulk/file_output_plugin.rb
embulk-0.8.11-java lib/embulk/file_output_plugin.rb
embulk-0.8.11 lib/embulk/file_output_plugin.rb
embulk-0.8.10 lib/embulk/file_output_plugin.rb
embulk-0.8.10-java lib/embulk/file_output_plugin.rb
embulk-0.8.9 lib/embulk/file_output_plugin.rb
embulk-0.8.9-java lib/embulk/file_output_plugin.rb
embulk-0.8.8 lib/embulk/file_output_plugin.rb
embulk-0.8.8-java lib/embulk/file_output_plugin.rb
embulk-0.8.7 lib/embulk/file_output_plugin.rb
embulk-0.8.7-java lib/embulk/file_output_plugin.rb
embulk-0.8.6 lib/embulk/file_output_plugin.rb
embulk-0.8.6-java lib/embulk/file_output_plugin.rb
embulk-0.8.5 lib/embulk/file_output_plugin.rb
embulk-0.8.5-java lib/embulk/file_output_plugin.rb
embulk-0.8.4 lib/embulk/file_output_plugin.rb
embulk-0.8.4-java lib/embulk/file_output_plugin.rb