Sha256: 3eaa9ce35e53215c7818e8c452b7c4020f1f80d3bd6cfd7c8abde65edc1866ea

Contents?: true

Size: 623 Bytes

Versions: 23

Compression:

Stored size: 623 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::org.embulk.plugin.PluginManager.newPluginInstance(plugin_java_class, Embulk::Java::EmbulkSystemProperties))
        end
        # TODO transaction, resume, cleanup
      end

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

end

Version data entries

23 entries across 23 versions & 1 rubygems

Version Path
embulk-0.10.35-java lib/embulk/file_output_plugin.rb
embulk-0.10.34-java lib/embulk/file_output_plugin.rb
embulk-0.10.33-java lib/embulk/file_output_plugin.rb