|
def | __init__ (self, reader, processor) |
|
def | setup_ex (self, init_net, finish_net) |
|
def | read_ex (self, init_net, exit_net) |
|
def | __init__ (self, schema=None) |
|
def | schema (self) |
|
def | setup_ex (self, init_net, finish_net) |
|
def | read_ex (self, local_init_net, local_finish_net) |
|
def | read_record_ex (self, local_init_net, local_finish_net) |
|
def | read (self, read_net) |
|
def | reset (self, net) |
|
def | read_record (self, read_net) |
|
def | execution_step (self, reader_net_name=None, external_should_stop=None) |
|
Reader that reads from an upstream reader, calls the processor, and returns
the processed record.
Definition at line 347 of file pipeline.py.