TINYINT, data STRING ) WITH ( 'connector' = 'datagen', 'fields.id.kind' = 'sequence', 'fields.id.start' = '1', 'fields.id.end' = '2', 'fields.data.kind' = 'random' ) """) table = table_env.from_path("random_source") TableDescriptor .for_connector('datagen') .option('fields.id.kind', 'sequence') .option('fields.id.start', '1') .option('fields.id.end', '2') .option('fields.data.kind', 'random') .schema(schema) .build())

TINYINT, data STRING ) WITH ( 'connector' = 'datagen', 'fields.id.kind' = 'sequence', 'fields.id.start' = '1', 'fields.id.end' = '2', 'fields.data.kind' = 'random' ) """) table = table_env.from_path("random_source") TableDescriptor .for_connector('datagen') .option('fields.id.kind', 'sequence') .option('fields.id.start', '1') .option('fields.id.end', '2') .option('fields.data.kind', 'random') .schema(schema) .build())

A POJO (plain old Java object) is any Java class that • has an empty default constructor • all fields are either ◦public, or ◦have a default getter and setter Tuple2 person =

language A(X>0) & (B(Y=10);[timespan:5] C(Z<5))[within:15] A, B, C are topics X, Y, Z are inner fields The rule fires when an item of type A having an attribute X > 0 enters the system and also an