带有flink的apache波束中的CEP

pip install apache-beam[gcp]
pip install apache-flink

import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions, StandardOptions
from apache_beam.transforms.window import FixedWindows
from apache_beam.transforms.trigger import AfterWatermark, AfterProcessingTime
from apache_beam.transforms.core import MapElements, Filter, ParDo
from apache_beam.io.gcp.bigquery import WriteToBigQuery
from apache_beam.io.gcp.pubsub import ReadFromPubSub
from apache_beam.io.gcp.pubsub import PubSubMessage
import apache_beam.io.gcp.pubsub import PubSubOptions
import apache_beam.io.gcp.pubsub import GCP PubSubReadSource
import apache_beam.io.gcp.pubsub import GCP PubSubWriteSource
import apache_beam.io.gcp.pubsub import GCP PubSubClient
import apache_beam.io.gcp.pubsub import GCP PubSubClientFactory
```我似乎没有在您发入的链接中找到与Apache Beam结合Flink进行CEP相关的内容。