Commits
User selector
Commit History
Commits on Jun 14, 2016
Reintroduce OperationCounters.should_sample
Show description for 5cf2b03authored andcommitted
Commits on Jun 10, 2016
Undo introduction of OperationCounters.should_sample
Show description for 15bef52authored andcommittedIntroduce OperationCouters.should_sample
Show description for 30af51aauthored andcommittedRemove separate worker version file
Show description for 8f8c318authored andcommitted
Commits on May 31, 2016
Bump up version to 0.2.5
Show description for 4d230cdcommittedUndo introduction of OperationCounters.should_sample
Show description for f84b9d9authored andcommittedInternal rollback.
Show description for 2b670d8authored andcommittedRemove separate worker version file
Show description for 4e586c9authored andcommittedIgnore undeclared side outputs of DoFns in cloud executor
Show description for 96583d0committedAdds support for reading custom sources using DataflowPipelineRunner.
Show description for 574a29eauthored andcommittedNew method OperationCounters.should_sample
Show description for 67033fcauthored andcommittedDynamic work rebalancing support for InMemory reader.
Show description for cb60c6cauthored andcommittedAdds the base API for creating new sources.
Show description for 1d44fdbauthored andcommittedCreate separate worker version file
Show description for 13a733dauthored andcommitted
Commits on May 11, 2016
Rename GlobalWindows.WindowedValue to GlobalWindows.windowed_value
Show description for 4784ea5authored andcommittedFix issue in cache trimming logic for combiner lifting
Show description for 4f7605bauthored andcommittedImplement non-native TextFile Sink
Show description for e037beaauthored andcommittedSupport large iterable side inputs
Show description for 9c6e898authored andcommitted
Commits on Apr 29, 2016
Rolling back due to an internal test failure.
Show description for c22a4c3authored andcommittedEnable support for all supported counter types
Show description for 5f104d4authored andcommittedAdd check for SDK versus container language/version compatibility
Show description for 69889f6committedAdds dynamic work rebalancing support for InMemoryReader.
Show description for 517d355authored andcommitted
Commits on Apr 19, 2016
Remove perf regression in not yet finished size estimation code
Show description for 172bc1bcommittedTreat creation of side input views as a PTransform
Show description for 13efcddauthored andcommittedRenames Source/Reader classes for native sources/readers.
Show description for 77d500fauthored andcommittedAllow operations to override the coder passed to update_counters
Show description for cb1a6bbauthored andcommittedBreak up OperationCounters.update() into before and after pieces
Show description for 4bb35c6authored andcommittedMake element iterators observable
Show description for 6084ff5authored andcommittedUpdates BatchWorker to report failure to shutdown progress reporter to service properly.
Show description for 03a6da2authored andcommittedUpdates and simplifies logic related to progress reporting.
Show description for e958bbbauthored andcommittedUse a CounterFactory to create counters
Show description for 59a4566authored andcommittedImplement and use WindowedValue.with_value
Show description for 61453d8authored andcommittedSupport pagination for large list states in Windmill
Show description for 82dcca8authored andcommittedRemove sdk pipeline options from the DoFn context
Show description for b9fb8d6authored andcommittedAdd plumbing to pass a coder to the byte-size counter updater
Show description for 84fd2baauthored andcommitted