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 consumer to connect to this data stream. TYPE: Consumer

add_function(function)

Adds a new StreamPipes Function.

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

RETURNS	DESCRIPTION
None

---

Last update: December 7, 2024