pyflink.datastream.connectors.number_seq.NumberSequenceSource

class NumberSequenceSource(start: int, end: int)

A data source that produces a sequence of numbers (longs). This source is useful for testing and for cases that just need a stream of N events of any kind.

The source splits the sequence into as many parallel sub-sequences as there are parallel source readers. Each sub-sequence will be produced in order. Consequently, if the parallelism is limited to one, this will produce one sequence in order.

This source is always bounded. For very long sequences (for example over the entire domain of long integer values), user may want to consider executing the application in a streaming manner, because, despite the fact that the produced stream is bounded, the end bound is pretty far away.

Methods

get_java_function()