I/O Connectors

Apache Beam I/O connectors provide read and write transforms for the most popular data storage systems so that Beam users can benefit from native optimised connectivity. With the available I/Os, Apache Beam pipelines can read and write data from and to an external storage type in a unified and distributed way.

I/O connectors denoted via X-language have been made available using the Apache Beam multi-language pipelines framework.

I/O connectors denoted as Supported via Managed API can be accessed using the simplified managed I/O_ APIs.

Built-in I/O Connectors

This table provides a consolidated, at-a-glance overview of the available built-in I/O connectors.

Connector Name	Source Supported	Sink Supported	Java	Python	Go	Typescript	Yaml	Batch Supported	Streaming Supported	Supported via Managed API
FileIO	✔	✔	✔ native	✔ native	✔ native	Not available	Not available	✔	✔	✘
AvroIO	✔	✔	✔ native	✔ native	✔ native	✔ via X-language	✔ read / write	✔	✔	✘
TextIO (metrics)	✔	✔	✔ native	✔ native	✔ native	✔ via X-language	✔ read / write	✔	✔	✘
TFRecordIO	✔	✔	✔ native	✔ native	Not available	Not available	✔ read / write	✔	✘	✘
XmlIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
TikaIO	✔	✘	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
ParquetIO (guide)	✔	✔	✔ native	✔ native	✔ native	✔ via X-language	✔ read / write	✔	✘	✘
ThriftIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
HadoopFileSystem	✔	✔	✔ native	✔ native	Not available	✔via X-language	Not available	✔	✘	✘
GcsFileSystem (metrics)	✔	✔	✔ native	✔ native	✔ native	✔via X-language	Not available	✔	✘	✘
LocalFileSystem	✔	✔	✔ native	✔ native	✔ native	✔via X-language	Not available	✔	✘	✘
S3FileSystem	✔	✔	✔ native	✔ native	Not available	✔via X-language	Not available	✔	✘	✘
In-memory	✘	✔	✘	✘	✔ native	✘	Not available	✔	✘	✘
KinesisIO	✔	✔	✔ native	✔ via X-language	Not available	Not available	✔ read / write	✔	✔	✘
AmqpIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
KafkaIO	✔	✔	✔ native	✔ via X-language	✔ via X-language	✔ via X-language	✔ read / write	✔	✔	✔
PubSubIO	✔	✔	✔ native	✔ native	✔ native	✔ via X-language	✔ read / write	✔	✔	✘
JmsIO	✔	✔	✔ native	✔ via X-language	Not available	Not available	✔ read / write	✔	✔	✘
MqttIO	✔	✔	✔ native	✔ via X-language	Not available	Not available	Not available	✔	✔	✘
RabbitMqIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
SqsIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
SnsIO	✘	✔	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
CassandraIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
HadoopFormatIO (guide)	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
HBaseIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
HCatalogIO (guide)	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
KuduIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
SolrIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
ElasticsearchIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
BigQueryIO (guide) (metrics)	✔	✔	✔ native	✔ native	✔ native ✔ via X-language	✔ via X-language	✔ read / write	✔	✔	✔
BigtableIO (metrics)	✔	✔	✔ native	✔ native (sink) ✔ via X-language	✔ native (sink) ✔ via X-language	Not available	✔ read / write	✔	✔	✘
DatastoreIO	✔	✔	✔ native	✔ native	✔ native	Not available	Not available	✔	✔	✘
SnowflakeIO (guide)	✔	✔	✔ native	✔ via X-language	Not available	Not available	✔ read / write	✔	✘	✘
SpannerIO	✔	✔	✔ native	✔ via X-language	✔ native	Not available	✔ read / write / read CDC	✔	✔	✘
JdbcIO	✔	✔	✔ native	✔ via X-language	✔ via X-language	Not available	✔ read / write	✔	✘	✘
DebeziumIO	✔	✘	✔ native	✔ via X-language	✔ via X-language	Not available	✔ read	✔	✔	✘
MongoDbIO	✔	✔	✔ native	✔ native	✔ native	Not available	✔ read / write	✔	✘	✘
MongoDbGridFSIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
RedisIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
DynamoDBIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
ClickHouseIO	✘	✔	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
ArrowFlightIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
DatabaseIO	✔	✔	✘	✘	✔ native	Not available	Not available	✔	✘	✘
GenerateSequence	✔	✘	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
SplunkIO	✘	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
FhirIO	✔	✔	✔ native	Not available	✔ native	Not available	Not available	✔	✔	✘
HL7v2IO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
DicomIO	✔	✔	✔ native	✔ native	Not available	Not available	Not available	✔	✔	✘
FlinkStreaming ImpulseSource	✔	✘	Not available	✔ native	Not available	Not available	Not available	✔	✔	✘
Firestore IO	✔	✔	✔ native	Not available	Not available	Not available	✔ read / write	✔	✘	✘
Neo4j	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
InfluxDB	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
SparkReceiverIO (guide)	✔	✘	✔ native	Not available	Not available	Not available	Not available	✘	✔	✘
CdapIO (guide)	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
SingleStoreDB (guide)	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
GoogleAdsIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
Web APIs (guide)	✔	✔	✔ native	✔ native	Not available	Not available	Not available	✔	✔	✘
Iceberg (guide)	✔	✔	✔ native	✔ via X-language	Not available	Not available	✔ read / write / read CDC	✔	✔	✔
CsvIO	✔	✔	✔ native	✔ native	Not available	Not available	✔ read / write	✔	✘	✘
JsonIO	✔	✔	✔ native	✔ native	Not available	Not available	✔ read / write	✔	✘	✘
ContextualTextIO	✔	✘	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
PulsarIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
SolaceIO	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✔	✘
DatadogIO	✘	✔	✔ native	✔ via X-language	Not available	Not available	✔ write	✔	✔	✘
CosmosIO (Azure Cosmos DB)	✔	✘	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
AzureBlobStoreFileSystem	✔	✔	✔ native	Not available	Not available	Not available	Not available	✔	✘	✘
Delta Lake	✔	✘	✔ native	✔ via X-language	Not available	Not available	✔ read / read CDC	✔	✘	✔

Other I/O Connectors for Apache Beam

Connector Name	Source Supported	Sink Supported	Language	Batch Supported	Streaming Supported
Cloud Bigtable (HBase based)	✔	✔	Java	✔	✘
Cognite Data Fusion	✔	✔	Java	✔	✔
KineticaDB	✔	✔	Java	✔	✘
SAP Hana to Google BigQuery	✔	✔	Java	✔	✘
TrepWsIO	✔	✘	Java	✔	✔
Beam PyIO (Collection of Python IO connectors)	✔	✔	Python	✔	✔
Cloud SQL	✔	✘	Python	✔	✘
MySQL	✔	✔	Python	✔	✘
Pyodbc	✔	✔	Python	✔	✘
Tinybird	✘	✔	Python	✔	✔
Go Connect	✔	✔	Go	✔	✔
MySQL, PostgreSQL, Oracle, SQL Server	✔	✔	Yaml	✔	✘

Last updated on 2026/10/26

Have you found everything you were looking for?

Was it all useful and clear? Is there anything that you would like to change? Let us know!