[FLINK-28055] Introduce Source API utilities for throttling number of records emitted per second.

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.7.3
• Component/s: Connectors / Common
• Release Note: Is covered by the DataGeneratorSource implementation: https://issues.apache.org/jira/browse/FLINK-27919
• Assignee: Alexander Fedulov
• Reporter: Alexander Fedulov
• Created: 14/Jun/22 13:22
• Updated: 29/Jun/23 11:34
• Resolved: 29/Jun/23 11:34

Description

SourceFunctions used in demos typically employ some throughput throttling during data generation. Utilities to achieve the same need to added to the new Source API.