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)[source]
Bases:
PTransform
- URN = 'flink:transform:streaming_impulse:v1'
- set_interval_ms(interval_ms)[source]
Sets the interval (in milliseconds) between messages in the stream.