Sha256: 133f413e51685ee2ac3678a8e0783a401f6121aa81a9b1d1864001d5821d3d54
Contents?: true
Size: 993 Bytes
Versions: 28
Compression:
Stored size: 993 Bytes
Contents
module Embulk
module Parser
class <%= ruby_class_name %> < ParserPlugin
Plugin.register_parser(<%= name.dump %>, self)
def self.transaction(config, &control)
# configuration code:
task = {
"property1" => config.param("property1", :string),
"property2" => config.param("property2", :integer, default: 0),
}
columns = [
Column.new(0, "example", :string),
Column.new(1, "column", :long),
Column.new(2, "name", :double),
]
yield(task, columns)
end
def init
# initialization code:
@property1 = task["property1"]
@property2 = task["property2"]
end
def run(file_input)
while file = file_input.next_file
file.each do |buffer|
# parsering code
record = ["col1", 2, 3.0]
page_builder.add(record)
end
end
page_builder.finish
end
end
end
end
Version data entries
28 entries across 28 versions & 1 rubygems