This repository has been archived by the owner on Nov 11, 2022. It is now read-only.
Version 0.3.20150210
Pre-release
Pre-release
Caution: depends on the gcloud core component version 2015.02.05 or newer.
- Included streaming pipeline runner, which, for now, requires additional whitelisting.
- Renamed several windowing-related APIs in a non-backward-compatible way.
- Added support for custom sources, which you can use to read from your own input formats.
- Introduced worker parallelism: one task per processor.