Sha256: cfbb84386f88c70329977136039ad10bd055a605271b296834745858bbc9a252
Contents?: true
Size: 686 Bytes
Versions: 7
Compression:
Stored size: 686 Bytes
Contents
# frozen_string_literal: true
require "kiba"
module Ductr
module ETL
#
# A runner based on kiba's streaming runner
# @see Kiba's streaming runner source code to get details about its forwarded methods
#
class KibaRunner < Runner
extend Forwardable
def_delegators Kiba::StreamingRunner, :source_stream, :transform_stream, :process_rows, :close_destinations
#
# Calls kiba's streaming runner #process_rows and #close_destinations like Kiba::StreamingRunner#run
#
# @return [void]
#
def run
process_rows(sources, transforms, destinations)
close_destinations(destinations)
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems