Sha256: ab35685a9f27bac32488a8568e0462e6b62fa045ae96a9c5e998d7c555d2814a
Contents?: true
Size: 560 Bytes
Versions: 15
Compression:
Stored size: 560 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::org.embulk.plugin.PluginManager.newPluginInstance(plugin_java_class, Embulk::Java::EmbulkSystemProperties))
end
# TODO transaction, resume, cleanup
end
# TODO run
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems