Commits
Branch selector
User selector
Commit History
Commits on Sep 1, 2016
Commits on Jun 29, 2016
Commits on Jun 14, 2016
Bump up version to 0.2.7
Show description for 94aa8f9committedRetry idempotent I/O operations on GCS timeout
Show description for 68f85e3authored andcommittedUse multiple file rename threads in finalize_write
Show description for c2c1bc7committedRaise an IOError when source file in GcsIO.copy does not exist
Show description for 4e38084authored andcommittedRemove unused GcsIO class attribute
Show description for c752b7fauthored andcommittedImplement fixed sharding in Text sink.
Show description for 8a31915authored andcommittedFix is_service_runner to detect endpoints ending with /
Show description for 5ff2c3ecommittedReintroduce OperationCounters.should_sample
Show description for 5cf2b03authored andcommitted
Commits on Jun 10, 2016
Bump up version to 0.2.6
Show description for a0f881fcommittedAdd autoscaling pipeline options
Show description for 2f9e11cauthored andcommittedAugment file utils with recursive copy
Show description for 9782343authored andcommittedUndo introduction of OperationCounters.should_sample
Show description for 15bef52authored andcommittedAllow Pipeline objects to be used in Python with statements
Show description for c644665authored andcommittedIntroduce OperationCouters.should_sample
Show description for 30af51aauthored andcommittedFix buffer overruns in fast OutputStream implementaion
Show description for c731121committedMake retry logic idempotent in GcsIO.delete and GcsIO.rename
Show description for ba23ccaauthored andcommittedFix module dict pickling.
Show description for 4d1fedbauthored andcommittedInternal changes for documentation validation
Show description for ecaea38authored 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 4d230cdcommittedUpdate filehandling utilities
Show description for 46f758cauthored andcommittedUse shelve as a disk backed dictionary optionally in PValueCache
Show description for c586baccommittedUndo 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 andcommittedSkip modules without a __name__ attribute
Show description for de04d7eauthored andcommittedDynamic work rebalancing support for InMemory reader.
Show description for cb60c6cauthored andcommittedAdds the base API for creating new sources.
Show description for 1d44fdbauthored andcommittedIs_composite to return True instead of parts when there are parts
Show description for 0bee865committedUse worker harness container corresponding to SDK version
Show description for d931cddauthored andcommitted