Beam GCP Pub/Sub : Subscribe

Beam GCP Pub/Sub : Subscribe

Description

The Beam GCP Pub/Sub : Subscribe transform gets messages from a Google Cloud Pub/Sub topic using a subscription with the Beam execution engine.

Hop Engine	X
Spark	✓
Flink	✓
Dataflow	✓

Options

Option	Description
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.