Skip to content
No description, website, or topics provided.
Groovy
Branch: master
Clone or download

Latest commit

Fetching latest commit…
Cannot retrieve the latest commit at this time.

Files

Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
data/input
gradle/wrapper
src/main
.gitignore
README.md
dataflow-sandbox.gradle
gradle.properties
gradlew
gradlew.bat
settings.gradle

README.md

dataflow-sandbox

Sandbox for testing with Google Dataflow.

YOU MUST: Change the installDirectory located in /${moduleName}/src/main/resources/application.yml to the directory you cloned this repository to.

To run the app (system properties are optional):

./gradlew run -DinputFile=data/input/input.txt

Executing the gradle run command will cause Spring Boot to run each class that implements CommandLineRunner. This repository contains three such classes:

  • EngineStatusCounterPipeline
  • EngineStatusCounterWindowedPipeline
  • EngineStatusTimerWindowedPipeline

Outputs for the pipeline will be found under: ${installDirectory}/data/output/

You can’t perform that action at this time.