Data stream context

DataStreamContext(functions, schema, broker)

Container for the context of a data stream.

PARAMETER	DESCRIPTION
functions	StreamPipes Functions which require the data of this data stream. TYPE: List[StreamPipesFunction]
schema	The schema of this data stream. TYPE: DataStream
broker	The broker to connect to this data stream. TYPE: Broker

add_function(function)

Adds a new StreamPipes Function.

PARAMETER	DESCRIPTION
function	StreamPipesFunction which requires this data stream. TYPE: StreamPipesFunction

RETURNS	DESCRIPTION
None