Module stream_manager

Source

Structsยง

CreateStreamingJobContext
CreateStreamingJobContext carries one-time infos for creating a streaming job.
CreateStreamingJobOption
CreatingStreamingJobInfo ๐Ÿ”’
GlobalStreamManager
GlobalStreamManager manages all the streams in the system.
ReplaceStreamJobContext
ReplaceStreamJobContext carries one-time infos for replacing the plan of an existing stream job.
StreamingJobExecution ๐Ÿ”’

Enumsยง

CreatingState

Type Aliasesยง

CreatingStreamingJobInfoRef ๐Ÿ”’
GlobalStreamManagerRef