Skip to content

This is a basic example to show CEP in flink with kafka

Notifications You must be signed in to change notification settings

ASKRAJPUT5/Flink-CEP

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

1 Commit
 
 
 
 
 
 

Repository files navigation

#THIS IS FLINK EXAMPLE

This function takes a data stream and matches it against a query

It's similar to CEP

It gives out the location's which have temperature more than the Threshold Temperature