apache_beam.io.flink.flink_streaming_impulse_source module

A PTransform that provides an unbounded, streaming source of empty byte arrays.

This can only be used with the flink runner.

class apache_beam.io.flink.flink_streaming_impulse_source.FlinkStreamingImpulseSource(label: str | None = None)

Bases: PTransform

URN = 'flink:transform:streaming_impulse:v1'

config: Dict[str, Any] = {}

expand(pbegin)

get_windowing(unused_inputs)

infer_output_type(unused_input_type)

to_runner_api_parameter(context)

set_interval_ms(interval_ms)

Sets the interval (in milliseconds) between messages in the stream.

set_message_count(message_count)

If non-zero, the stream will produce only this many total messages. Otherwise produces an unbounded number of messages.

static from_runner_api_parameter(_ptransform, spec_parameter, _context)