Class: Fairy::PIOFilter

Inherits:

PFilter

• Object
• PFilter
• Fairy::PIOFilter

Defined in:

lib/fairy/node/p-io-filter.rb

Direct Known Subclasses

PBasicGroupBy, PBasicMGroupBy, Fairy::PDirectProduct::PPreFilter, PFindResult, PHere, PInject, POutputFile, POutputNull, POutputVArray, PSegSplit, PSingleExportFilter, PSingleExportInput, PWC, Fairy::PWC::PPostFilter

Constant Summary

ST_WAIT_IMPORT =

:ST_WAIT_IMPORT

Constants inherited from PFilter

Fairy::PFilter::END_OF_STREAM, Fairy::PFilter::ST_ACTIVATE, Fairy::PFilter::ST_FINISH, Fairy::PFilter::ST_INIT

Instance Attribute Summary

Attributes inherited from PFilter

#IGNORE_EXCEPTION, #id, #log_id, #ntask

Instance Method Summary

• #initialize(id, ntask, bjob, opts = nil, *rests) ⇒ PIOFilter constructor

  A new instance of PIOFilter.

• #input=(input) ⇒ Object

Methods inherited from PFilter

#abort_running, #basic_start, #break_running, #each, #global_break, #global_break_from_other, #handle_exception, #key, #key=, #next, #no, #no=, #notice_status, #processor, #start, #start_export, #start_watch_status, #status=, #terminate, #terminate_proc

Constructor Details

#initialize(id, ntask, bjob, opts = nil, *rests) ⇒ PIOFilter

Returns a new instance of PIOFilter.

# File 'lib/fairy/node/p-io-filter.rb', line 14

def initialize(id, ntask, bjob, opts=nil, *rests)
  super
  self.status = ST_WAIT_IMPORT
end

Instance Method Details

#input=(input) ⇒ Object

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

def input=(input)
  @input = input
  if input.kind_of?(Import)
	input.njob_id = @id
  end
  self.no = input.no
  self.key = input.key
end