BeamFlow

Connectors
Drag to build your pipeline

Sources

BigQuery Source

Reads data from Google BigQuery.

Pub/Sub Source

Reads messages from Google Cloud Pub/Sub.

Text File Source

Reads text data from files.

Kafka Source

Reads data from Apache Kafka topics.

Transforms

Generic Transform

A generic data transformation step.

Sinks

BigQuery Sink

Writes data to Google BigQuery.

Pub/Sub Sink

Writes messages to Google Cloud Pub/Sub.

Text File Sink

Writes text data to files.

Kafka Sink

Writes data to Apache Kafka topics.

React Flow mini map