UDF Stream Source () reads streaming data generated programmatically using a User-Defined Function (UDF).
This source is typically used when data does not originate from an external system (Kafka, Socket, etc.) but is produced dynamically by custom logic, such as simulations, API polling, or proprietary connectors.

Parameters of UDF Stream Source

• UDF Class name
  Fully qualified Java class name of the UDF used as the streaming source
  This class must implement the required UDF Stream Source interface
  Refer to the Plugins Tutorial for UDF Stream Source plugins
• Parameter
  Input parameters passed to the UDF class
• Declared Output Field
  Names of fields produced by the UDF stream
  Defines the schema of the outgoing stream
  Field order must match the data emitted by the UDF

Supported Engines

Map Reduce	Spark 1.x RDD	Spark 2.x RDD	Spark 2.x Dataset	Apache Beam 2.29.0 Batch	Apache Beam 2.29.0 Streaming	Apache Flink 1.12.0 Batch	Apache Flink 1.12.0 Streaming	Apache Tez 0.9.1	PySpark