Commits

Commits on Apr 8, 2020

Uses iterable coder for windows and copies all of timestamp encoding specification.
acrites
committedApr 8, 2020

Commits on Apr 7, 2020

Updates documentation for WINDOWED_VALUE coder.
acrites
committedApr 7, 2020

Commits on Apr 2, 2020

[BEAM-9624] Adds Convert to Accumulators operator for use in combiner lifting for streaming pipelines (apache#11271 )
acrites
committedApr 2, 2020

Commits on Mar 11, 2020

Adds clearing of pane info state when windows get merged away.
acrites
committedMar 11, 2020

Commits on Feb 26, 2020

Clean up of TestStreamTranscriptTests. Remvoes check for final field in PaneInfo since it is not reported properly by direct runner. Updates index for session panes and changes test with Count(2) e…
acrites
committedFeb 26, 2020

Commits on Feb 25, 2020

Changes TestStreamTranscriptTest to only emit two elements so that its behavior is the same across all runners.
acrites
committedFeb 25, 2020

Commits on Jan 15, 2020

Changes watermark advance from 1001 to 1000 since Dataflow TestStream only advances watermark at 1s resolution.
acrites
committedJan 15, 2020

Commits on Dec 20, 2019

Minor cleanup of tests using TestStream. (apache#10188 )

acrites
authored and
lukecwik
committedDec 20, 2019

Commits on Dec 2, 2019

Formatting cleanup using gradlew spotnessApply.
acrites
committedDec 2, 2019
Adds translation support for TestStream to Dataflow Java runner.
acrites
committedDec 2, 2019

Commits on Nov 8, 2019

Commits on Nov 7, 2019

Adds TestStream support for Dataflow runner.
acrites
committedNov 7, 2019