Class: Fairy::IOFilter

Inherits:

Filter

• Object
• Filter
• Fairy::IOFilter

Defined in:

lib/fairy/client/io-filter.rb

Direct Known Subclasses

Barrier, BasicGroupBy, BasicMGroupBy, Cat, DirectProduct, Find, GroupBy, GroupBy::PostFilter, Here, Inject, Junction, Map, MergeGroupBy, SegJoin, SegJoin::PreJoinedFilter, SegMap, SegShuffle, SegSplit, SegZip, SegZip::PreSegZipFilter, Select, Sort::PostSort, Sort::PreSort, WC, WC::PostFilter

Instance Method Summary

• #backend_class_name ⇒ Object
• #initialize(fairy, *rests) ⇒ IOFilter constructor

  A new instance of IOFilter.

• #input=(job) ⇒ Object

Methods inherited from Filter

#backend, #backend=, #backend_class, #def_pool_variable

Constructor Details

#initialize(fairy, *rests) ⇒ IOFilter

Returns a new instance of IOFilter.

# File 'lib/fairy/client/io-filter.rb', line 11

def initialize(fairy, *rests)
  super
end

Instance Method Details

#backend_class_name ⇒ Object

# File 'lib/fairy/client/io-filter.rb', line 15

def backend_class_name
  ERR::Raise ERR::INTERNAL::UndefinedBackendClass
end

#input=(job) ⇒ Object

# File 'lib/fairy/client/io-filter.rb', line 19

def input=(job)
  @input=job
#      atom = Atom.new(backend, :input=, job.backend)
#      @fairy.send_atom(atom)
  backend.input=job.backend
end