Last Updated: November 21, 2025
Key Concepts
| Concept | Use |
|---|---|
PCollection
|
Immutable datasets |
PTransform
|
Data ops |
Windowing
|
Group events |
Triggers
|
Emit results |
Commands
mvn compile exec:java
Run locally
gcloud dataflow jobs run
Deploy
beam_metrics
Inspect stats
Tips
Monitor watermarks, handle late data, and instrument custom metrics.
💡 Pro Tip:
Pick a runner, instrument watermarks, and test with DirectRunner.