Google Cloud Dataflow adapter for the Culvert framework. Provides
DataflowPipeline, a Pipeline implementation that holds the stage
topology (per the Pipeline contract — name + stages + validate)
plus utility methods for bridging to Apache Beam: buildBeam()
translates the stage graph into a beam.sdk.Pipeline and
runOnDataflow() submits it via the DataflowPipelineRunner.
Sprint-2 deliverable (issue #25).
Latest Versions
1 versions →| Version | Vulnerabilities | Usages | Date | |
|---|---|---|---|---|
0.1.x | 0.1.0 |
0
| Jul 15, 2026 |