What is the paper that the FlinkCep implementation based on?

I need to know the if there is/are paper(s) behind the implementation of FlinkCEP. If there, then what are they?

Solution

I believe the overall approach is based on a paper from SIGMOD '08 by Agrawal, etal.

Flink Kafka GroupId seems to be ignored when using KafkaSource
Flink: Could not find any factory for identifier 'kafka' that implements 'org.apache.flink.table.factories.CatalogFactory' in the classpath
How does the file system connector sink work
Is there a count-based window in Apache Flink?
Set a Job Name to Flink job using Table API
Flink Operator stuck at 100% busy, how do I get it down?
Not able to see flink custom metrics to Prometheus
Bootstrap broadcast state and keyed state of the same operator
Flink FileSink output in multi files
Intermittent High Latency in Flink
what is best way to Order a Batch in Flink or Spark?
classNotFound Apache Flink in java
How to implement a BOUNDED source for Flink's batch execution mode?
Does PieCloudDB support Flink?
How do I listen to checkpoints/savepoint creation in Flink?
watermarks not increasing in flink
Sedona Flink SQL Lookup on external database failing when using 'FOR SYSTEM_TIME AS OF' statement
Could not find any factory for identifier 'kinesis' that implements 'org.apache.flink.table.f actories.DynamicTableFactory' in the classpath
Sedona + Flink JDBC and Postgis data types (UUID, Geography)
Sink Data to DB and Kafka/Axon in a single Transaction
java.lang.reflect.InaccessibleObjectException: Unable to make field private final java.lang.Object[] java.util.Arrays$ArrayList.a accessible
In-memory, replicated cache for Apache Flink tasks
Flink can't parse Avro schema written by Debezium to Kafka in DataStream API
Flink trigger registered timer on process function when source input has been exhausted
What is the difference b/w TestProcessingTimeService and InternalTimeServiceManagerImpl?
Flink Job design - working with hybrid Kafka topic
Fetch new records from DB dynamically using Flink and post to kafka/axon topic
Why does PyFlink give me a time in the past
Does the current Apache Flink Flamegraph allow for email alerts?
How to upgrade Amazon Kinesis Analytics Apache Flink runtime?