The Beam GCP Pub/Sub : Subscribe transform gets messages from a Google Cloud Pub/Subarrow-up-right topic using a subscription with the Beam execution engine.
Hop Engine
X
Spark
✓
Flink
Dataflow
Transform name
Name of the transform, this name has to be unique in a single pipeline.
Subscription name
Name of the Google Cloud Pub/Sub subscription.
Topic to subscribe to
The Google Cloud Pub/Sub topic.
The type of message to read
String
PubsubMessage
The output field name
The field containing the result message.
Last updated 4 months ago
