Skip to main content
Version: Current

Event Generator

Mode: Streaming

Description​

Generates events user-defined frequency.

There are two primary use cases for this component:

  • Generating a stream of data (typically for testing): The #input variable, available downstream, will be populated with the data generated by this component. Use functions from the #RANDOM function group to produce random values.
  • Periodically generating a trigger event: This enables your scenario to run periodically, unlocking additional use cases beyond the traditional stream processing.

Parameters and configuration​

NameDescription
ScheduleSpecifies how often events will be sent. Must not be negative; zero generates events at the maximum rate.
ValueExpression specifying data payload that event will contain. Expression will be evaluated for every generated event

Advanced parameters​

NameDescription
CountNumber of events that will be generated at every run
Event timeExpression which evaluates to the time when the event was created.
Max out-of-ordernessThe maximum amount of time the event is allowed to be late before being ignored when computing the result for time-based stream transformations: aggregates in time windows and joins. Must not be negative. To read more about this mechanism see Flink documentation