Easy to use Java 8 DSL for the Beam Java SDK. Provides a high-level abstraction of Beam transformations, which is both easy to read and write. Can be used as a complement to existing Beam pipelines (convertible back and forth).
Integration of Euphoria API to Beam is in progress (BEAM-3900).
Euphoria is located in dsl-euphoria
branch. To build euphoria
subprojects use command:
./gradlew :beam-sdks-java-extensions-euphoria:build
Documentation is located at euphoria.md