FazBrowse GitHub Viewer | Trending | | Home

Tools: [Download Repo ZIP] [Original HTTPS Page]

Commits · dralves/DataflowJavaSDK · GitHub

Repository navigation

Commits

Commits on Feb 4, 2015

Merge the streaming runner code into the main sdk.

millsd
authored and
davorbonaci
committed
95bb0ea
Tweaks to support OSX.

andersgoog
authored and
davorbonaci
committed
c3627f4
Attempt to fix .travis.yml for OSX
davorbonaci
committed
242b4c3

Commits on Feb 3, 2015

Make test_wordcount.sh script executable by changing the file's mode.
davorbonaci
committed
ffbf31f
Updates to Dataflow README on GitHub.
davorbonaci
committed
56e2399
Moves class GlobalWindows.GlobalWindow to top-level for consistency with other window types. This change is backward-incompatible but unlikely to affect many users.

zhanyong-wan
authored and
davorbonaci
committed
1848854
Updated DataStoreWordCount so that it can be adapted as an integration test for

chamikaramj
authored and
davorbonaci
committed
a46c40d
Adds protobuf for communicating with Windmill service.

millsd
authored and
davorbonaci
committed
d692b7c
Automated rollback of a previous change.

reuvenlax
authored and
davorbonaci
committed
774c368
Allows users of PubsubIO to specify which pubsub labels are used to propagate record timestamps and record ids. Strictly SDK changes, cannot yet be used.

reuvenlax
authored and
davorbonaci
committed
62b0dd4
FIX: 1. not depends on UnsupportedOperationException. 2. removeWindow from

peihe
authored and
davorbonaci
committed
39a8210
Move path validation, credential validation, and file staging into separate classes that can be overridden.

reuvenlax
authored and
davorbonaci
committed
8b9f2b8
Modify .travis.yml file also to test on osx, and add test_wordcount.sh, which it uses.

andersgoog
authored and
davorbonaci
committed
fbdd33e
Windowing: Worker code for ReifyTsAndWindowsParDoFn and

peihe
authored and
davorbonaci
committed
e3c4ded
Explicitly close the underlying readChannel before retries in

dennishuo
authored and
davorbonaci
committed
a741a31
Adds support for compressed (gzip and bzip2) text sources.

ml8
authored and
davorbonaci
committed
815fb45
Renames InvalidWindowFn to InvalidWindows to conform with the convention that concrete window-fn classes are plural nouns. This is backward-incompatible but unlikely to affect users.

zhanyong-wan
authored and
davorbonaci
committed
0272993
Fix issue with retrying GCS staging, where we would log the "going to retry" message after actually retrying.

sammcveety
authored and
davorbonaci
committed
4c16878
Rename GlobalWindow (the fn) to GlobalWindows for consistency.

robertwb
authored and
davorbonaci
committed
33e72de
Drop the differentiation between user and worker credentials since the getUserCredentials is able to get credentials when executed from the worker for all the use cases the worker got them from.

lukecwik
authored and
davorbonaci
committed
84c8ea2
Update dependencies to latest versions of Google API services.

lukecwik
authored and
davorbonaci
committed
2ee5d35
Make LogSaver thread-safe so that ExpectedLogs can be used to capture logs which are output from multiple threads.

lukecwik
authored and
davorbonaci
committed
0fdcc1b
Updated test for Filter Transform.

ananvay
authored and
davorbonaci
committed
caecd62

Commits on Jan 27, 2015

Fix a typo: UserDame->UserName

vanya
authored and
davorbonaci
committed
8d5718a
Adding a filter transform.

ananvay
authored and
davorbonaci
committed
f4922de
Report GCS path of error-producing write in Dataflow SDK GoogleCloudStorageWriteChannel.

charlesccychen
authored and
davorbonaci
committed
c000e5b
Rename WindowingFn to WindowFn for consistency with the other *Fns.

robertwb
authored and
davorbonaci
committed
5a4d6e3
Don't rewrap UserCodeException for cleaner user error messages.

charlesccychen
authored and
davorbonaci
committed
e88a302
Throw return value from Throwables.propagate in NormalParDoFn exception handling.

charlesccychen
authored and
davorbonaci
committed
f8329b2
Don't rewrap RuntimeException in NormalParDoFn$1.output for cleaner error reporting.

charlesccychen
authored and
davorbonaci
committed
006401c
Fix parts of flakiness in RateLimitingTest.
davorbonaci
committed
00dc941
Fixes a couple window comparison issues in CalendarWindows.

vgough
authored and
davorbonaci
committed
e09e643
Use deterministic tag ids for tags created in static initializers.

robertwb
authored and
davorbonaci
committed
1942ce0
Fixes a randomization bug and removes some unused checks in ProxyInvocationHandler.

vgough
authored and
davorbonaci
committed
6616fd6
Update the BigQueryReaderTest to use fake JSON data rather than constructed

bchambers
authored and
davorbonaci
committed
24d0020

Back | FazBrowse Home | New Git URL