Output collector

OutputCollector(data_stream)

Collector for output events. The events are published to an output data stream. Therefore, the output collector establishes a connection to the broker.

PARAMETER	DESCRIPTION
data_stream	The output data stream that will receive the events. TYPE: DataStream

ATTRIBUTE	DESCRIPTION
broker	The broker instance that sends the data to StreamPipes TYPE: Broker

collect(event)

Publishes an event to the output stream.

PARAMETER	DESCRIPTION
event	The event to be published. TYPE: Dict[str, Any]

RETURNS	DESCRIPTION
None

disconnect()

Disconnects the broker of the output collector.

RETURNS	DESCRIPTION
None