Consumer

ABC Consumer

---

source

Consumer

 Consumer ()

Consumer consumes data into the pipeline. It provides the unified interface for data consumption consume()

---

source

Consumer.consume

 Consumer.consume (pipeline:tspace.dataflow.pipeline.queue.Pipeline[~T],
                   start_event:Optional[threading.Event]=None,
                   stop_event:Optional[threading.Event]=None,
                   interrupt_event:Optional[threading.Event]=None,
                   exit_event:Optional[threading.Event]=None,
                   flash_event:Optional[threading.Event]=None)

consume data into the pipeline

	Type	Default	Details
pipeline	Pipeline		T: pd.DataFrame
start_event	Optional	None	input event: start
stop_event	Optional	None	input event: stop
interrupt_event	Optional	None	input event: interrupt
exit_event	Optional	None	input event: exit
flash_event	Optional	None	output event: flash