Commits
User selector
Commit History
Commits on Jun 14, 2016
Implement fixed sharding in Text sink.
Show description for 8a31915authored andcommitted
Commits on May 31, 2016
Use shelve as a disk backed dictionary optionally in PValueCache
Show description for c586baccommittedIgnore undeclared side outputs of DoFns in cloud executor
Show description for 96583d0committedImplement EagerPipelineRunner, useful for running in a repl.
Show description for a724abbauthored andcommitted
Commits on May 11, 2016
Generalize base PTransform._extract_input_pvalues
Show description for 2843cf9authored andcommittedRename GlobalWindows.WindowedValue to GlobalWindows.windowed_value
Show description for 4784ea5authored andcommittedUpdate equal_to matcher with clearer error message
Show description for a113e83authored andcommittedSupport large iterable side inputs
Show description for 9c6e898authored andcommitted
Commits on Apr 29, 2016
Enable support for all supported counter types
Show description for 5f104d4authored andcommittedUse WindowFn-specified Coders for the Windows
Show description for 99bb95bauthored andcommittedPipeline and runner cleanup
Show description for b0826b6authored andcommitted
Commits on Apr 19, 2016
Treat creation of side input views as a PTransform
Show description for 13efcddauthored andcommittedMake element iterators observable
Show description for 6084ff5authored andcommittedClean up PValue and PCollection with clearer argument passing
Show description for 0499bbeauthored andcommittedImplement and use WindowedValue.with_value
Show description for 61453d8authored andcommittedRemove sdk pipeline options from the DoFn context
Show description for b9fb8d6authored andcommittedMake sdk pipeline options available in the DoFn context
Show description for 7aca3a3authored andcommitted
Commits on Mar 24, 2016
Rename OutputTimeFn.OUTPUT_AT_MAX to OUTPUT_AT_LATEST for clarity
Show description for 66cd0e6authored andcommittedStore timestamps and time intervals with microsecond granularity
Show description for 0228864authored andcommitted
Commits on Mar 21, 2016
Reformat some doc strings to be acceptable to Pydocs Sphinx
Show description for 9bbc79eauthored andcommittedRemove some deprecated names.
Show description for 20e2e6dauthored andcommitted
Commits on Mar 16, 2016
Implement continuous combining in pre-shuffle combining table.
Show description for 493afc5authored andcommittedImprove labeling of transforms.
Show description for 472f8f8authored andcommittedSnippets for type hint docs.
Show description for 0e47c91authored andcommitted
Commits on Mar 8, 2016
Support timer-based triggers, watermark holds in streaming jobs
Show description for b7ec119authored andcommittedImprove the str() output of various Dataflow classes
Show description for 1eadec7authored andcommittedMany pickling fixes.
Show description for 19748caauthored andcommittedImprove pickling robustness
Show description for 1015945authored andcommittedSupport combiner lifting, update batch job major version to 4
Show description for c2cd956authored andcommittedPython Dataflow fit-n-finish.
Show description for 274b541authored andcommitted
Commits on Feb 25, 2016
Loading