Public signup for this instance is disabled. Go to our Self serve sign up page to request an account.
Spark runner support for Read.Unbounded primitive.
BEAM-719 Run WindowedWordCount Integration Test in Spark Streaming
BEAM-785 Enable selected ROS tests for streaming.
BEAM-549 SparkRunner should support Beam's KafkaIO instead of providing it's own.
GitHub Pull Request #1143