Crate polars_stream 

Structs

GraphMetrics

GraphNodeKey

LogicalPipe

A pipe sends data between nodes.

LogicalPipeKey

NodeMetrics

PhysNode

A node in the physical plan.

PhysNodeKey

Key used for physical nodes.

StreamingQuery

Enums

NodeStyle

A style of a graph node.

PhysNodeKind

QueryResult

ZipBehavior

Behaviour when handling multiple DataFrames with different heights.

Functions

build_streaming_query_executor

run_query

Executes the IR with the streaming engine.

visualize_physical_plan

Visualizes the physical plan as a dot graph.