Cookies and Privacy

We use technology on our website to collect information that helps us enhance your experience and understand what information is most useful to visitors.
By clicking "I ACCEPT," you agree to the terms of our privacy policy.

Cirata applies the highest standards to its use of data and its compliance with data-protection regulations across our marketing and website. Our Data Protection Officer can be contacted at DPO@cirata.com. You can change your cookie settings at any time via the link in our footer.

Cookie Setting

Ice Flow extension

Ice Flow extension

Manage data in Iceberg-native, open standard formats, between any pair of catalogs, across vendors, clouds, and on-premises, without compromise or lock-in.

Built by Cirata | Tech Preview

Built for the multi-catalog data estate

Iceberg is the open table format every cloud and every vendor now supports. None of them offer a clean way to move tables between each other. Ice Flow is the vendor-neutral mobility layer that sits in the middle, one extension, one operator surface, every catalog.


Source from:
Hive Metastore · AWS Glue · Iceberg REST · Project Nessie · JDBC (PostgreSQL, MySQL, others) · Hadoop / HDFS


Target to:
Any of the above. Either direction. Cross-cloud, cross-vendor, or on-prem-to-cloud.

Built for

What it does

  • Replicate Iceberg tables and views between Hive, AWS Glue, JDBC, REST, Nessie, and Hadoop catalogs, any direction, any pair.
  • Run continuous, event-driven replication from Hive sources, or one-time replication from any source.
  • Preserve full snapshot history on the target so time-travel queries work exactly as they do on the source.
  • Translate file paths automatically for cross-cloud and cross-storage targets, HDFS to S3, S3 to ADLS, prod bucket to DR bucket.
  • Prove the target matches the source with a built-in consistency check that returns pass/fail per table, with reasons.
What it does screenshot 1
What it does screenshot 2

Use cases

Hybrid and cross-cloud migration

Lift an on-prem Hive estate into a cloud Iceberg catalog incrementally, source stays live, target catches up, cutover happens with rollback available.

Multi-cloud disaster recovery

Keep production in one cloud catalog and a DR copy in another, with location mappings handling the cross-storage path rewrite and snapshot history preserved end-to-end.

Regulated-industry evidence

Answer DORA, Basel III, NYDFS, and APRA CPS 230 with rehearsable failover ceremonies, per-table consistency proof, and full audit trails — without building any of it yourself.

Data product distribution

Push a producing team's catalog into a consuming team's catalog with provable consistency, the producing side keeps authority, the consuming side gets verified currency.


How it works

Connect

Register source and target catalogs side-by-side in the Symphony sidebar.

Define

Pick tables with reusable scopes, set location mappings for cross-storage targets, choose latest-snapshot or all-snapshots mode.

Replicate and verify

Continuous or one-time replication runs; the consistency check proves the target matches the source, table by table.


Technical details

Supported catalogs Hive Metastore, AWS Glue, Iceberg REST, Project Nessie, JDBC, Hadoop / source or target
Replication modes Continuous (Hive source, event-driven) or one-time (any source)
Snapshot handling Latest-snapshot or all-snapshots copy strategy, preserve full time-travel history on the target
Cross-storage support Global location mappings rewrite file paths during replication; works across HDFS, S3, ADLS, GCS
Verification Built-in consistency check; pass/fail per table and view with reason text, re-runnable on demand
Deployment Distributed + hybrid environments, horizontally scalable via Cirata Symphony WorkPartitioner
Time-to-value Minutes to first replication; no agents on source or target, no metas-tore patches, no broker plugins

Other Cirata Symphony extensions

Cirata Symphony Pulse extension
Control, understand, coordinate, and automate your data estate using simple prompts.
Data Migrator extension
Fully automated, zero-downtime or risk, continuous petabyte scale data migration between data environments.
Observability extension
See your entire Cirata Symphony estate as one OpenTelemetry stream, every extension, every signal, into any backend you already run.
Intelligence extension
Connect your data estate to any AI model, without writing a line of integration code.
Orchestration extension
A vendor-neutral control plane for workflow orchestration on Cirata Symphony. Orchestration connects to the workflow engines you already run, behind one unified Orchestrator interface.
Canon extension
Replicate Kafka across any vendor mix, with offsets every instance agrees on, schemas that travel with records, and failover you can actually rehearse.

Want to see the Cirata Symphony Ice Flow extension in action?

Let us show you how the Cirata Symphony Ice Flow extension is a revolutionary new data extension to fit your organizational needs.
Schedule a direct 1:1 demo with our CTO, Paul Scott-Murphy.