Class: Wukong::Load::Loader

Inherits:

Processor::FromJson

• Object
• Processor::FromJson
• Wukong::Load::Loader

Defined in:

lib/wukong-load/loader.rb

Overview

Base class from which to build Loaders.

Direct Known Subclasses

ElasticsearchLoader, KafkaLoader, MongoDBLoader, SQLLoader

Instance Method Summary

• #load(record) ⇒ Object

  Override this method to load a record into the data store.

• #process(line) ⇒ Object

  Calls super() to leverage its deserialization and then calls #load on the yielded record.

Instance Method Details

#load(record) ⇒ Object

Override this method to load a record into the data store.

Parameters:

• record (Hash)

# File 'lib/wukong-load/loader.rb', line 18

def load record
end

#process(line) ⇒ Object

Calls super() to leverage its deserialization and then calls

load on the yielded record.

Parameters:

• line (String) —

  JSON to parse.

# File 'lib/wukong-load/loader.rb', line 11

def process line
  super(line) { |record| load(record) }
end