Initial Commit · polyzos/flink-blogpost-examples

Initial Commit

ipolyzos committed on Feb 28, 2025, 08:26 AM

Showing 14 changed files +672 additions -0 deletions

A .gitignore +40

A README.md +25

A pom.xml +133

A src/main/java/io/ipolyzos/timers/SensorMonitoring.java +38

A src/main/java/io/ipolyzos/timers/SensorProcessorFn.java +135

A src/main/java/io/ipolyzos/timers/SensorReading.java +14

A src/main/java/io/ipolyzos/triggers/UserEvent.java +14

A src/main/java/io/ipolyzos/triggers/session/SessionEndTrigger.java +55

A src/main/java/io/ipolyzos/triggers/session/SessionProcessFn.java +24

A src/main/java/io/ipolyzos/triggers/session/SessionWTrigger.java +42

A src/main/java/io/ipolyzos/triggers/tumbling/CountEventsPerWindowFn.java +21

A src/main/java/io/ipolyzos/triggers/tumbling/CustomCountTrigger.java +73

A src/main/java/io/ipolyzos/triggers/tumbling/TumblingWTrigger.java +45

A src/main/resources/logback.xml +13