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