risingwave_connector::source

Module data_gen_util

Source

Functionsยง

spawn_data_generation_stream
Spawn the data generator to a dedicated runtime, returns a channel receiver for acquiring the generated data. This is used for the DatagenSplitReader and NexmarkSplitReader in case that they are CPU intensive and may block the streaming actors.