FazBrowse GitHub Viewer | Trending | | Home

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

Commits · a2call/DataflowJavaSDK · GitHub

Repository navigation

Commits

Commits on Jul 11, 2016

Use HashBasedTable.create() instead of Tables.newCustomTable() (#336)

kluever
authored and
dhalperi
committed
07795e4
Changed JUnitMatchers to Matchers (#335)

ianzhou1
authored and
dhalperi
committed
f3b030b
Backport from Beam: Use UnboundedReadFromBoundedSource in dataflow runner (#333)

peihe
authored and
dhalperi
committed
77b4b7b

Commits on Jul 8, 2016

Update to bigtable-client-core-0.3.0 and use bulk writes (#326)

ianzhou1
authored and
dhalperi
committed
ce2e5c0

Commits on Jul 7, 2016

Merge pull request #327 from dhalperi/avro-source-fix
lukecwik
authored
3e9dc2b

Commits on Jul 2, 2016

AvroSource: use a 64K buffer size for Snappy codec
dhalperi
committed
564ee5c
Expose getSplitPointsConsumed() in BigtableIO (#325)

ianzhou1
authored and
dhalperi
committed
7b00b68
Added getSplitPointsConsumed() to ByteKeyRangeTracker

Ian Zhou
authored and
dhalperi
committed
e020901
Update OffsetRangeTracker progress tracking and start offset (#323)

ianzhou1
authored and
dhalperi
committed
d827645
Modified range tracker to use first response seen as start key (#322)

ianzhou1
authored and
dhalperi
committed
c22ebdb

Commits on Jul 1, 2016

Backport: Make IdentityWindowFn and NeverTrigger available (#315)

swegner
authored and
dhalperi
committed
9b12258

Commits on Jun 29, 2016

Configure the Surefire Argline in Travis (#320)

tgroh
authored and
dhalperi
committed
a82c158
Fix AutoComplete example streaming configuration (#308)

swegner
authored and
dhalperi
committed
84584dc

Commits on Jun 28, 2016

Merge pull request #319 from tgroh/backport_counting_rate
dhalperi
authored
0ab2872
Add UnboundedCountingInput#withRate
tgroh
committed
74f08ea
Backport from Beam: Increase the MESSAGES_POLLING_ATTEMPTS for slow backend starts (#318)

peihe
authored and
dhalperi
committed
590e90b
Update dataflow version in pom.xml to maven latest (#316)

joshualitt
authored and
dhalperi
committed
2b0e696

Commits on Jun 25, 2016

Add inprocess package-info (#305)

tgroh
authored and
dhalperi
committed
c42c333
Backport: Fix NullPointerException in AfterWatermark display data (#307)

swegner
authored and
dhalperi
committed
2d612a1
Reuse UnboundedReaders in the InProcessRunner (#312)

tgroh
authored and
dhalperi
committed
312feba

Commits on Jun 23, 2016

Upgrade the version of the Dataflow API

millsd
authored and
dhalperi
committed
9857150

Commits on Jun 17, 2016

Return from awaitCompletion if Already Done (#310)

tgroh
authored and
dhalperi
committed
3a38bf8
Shutdown the InProcessPipelineRunner after Terminating Abnormally (#311)

tgroh
authored and
dhalperi
committed
8bd5f55

Commits on Jun 15, 2016

Backport: Package javadoc for org.apache.beam.sdk.transforms.display (#306)

swegner
authored and
dhalperi
committed
5c69a4b

Commits on Jun 14, 2016

Merge pull request #304 from dhalperi/compressed-source-test
dhalperi
authored
8c7b286
Make example AddTimestampFn range deterministic (#303)

swegner
authored and
bjchambers
committed
444609f
CompressedSourceTest: simplify
dhalperi
committed
a7690a0

Commits on Jun 13, 2016

Merge pull request #302 from swegner/backport-achetype
lukecwik
authored
1c37830
Port cleanupDaemonThreads fix to archetype module
swegner
committed
f241d58

Commits on Jun 12, 2016

Version management: update to 1.7.0-SNAPSHOT
dhalperi
committed
f82fe56
Version management: restore 1.6.0-SNAPSHOT for 1.6.0 release
dhalperi
committed
79e9b31

Commits on Jun 9, 2016

Merge pull request #300 from swegner/backport-mvnexec
lukecwik
committed
1706a94
Disable exec-maven-plugin cleanupDaemonThreads
swegner
committed
f59379d

Commits on Jun 8, 2016

Back | FazBrowse Home | New Git URL