[3/3] beam-site git commit: This closes #156: Fix some typos and small formatting issuesin the last stateful processing blog post

This closes #156: Fix some typos and small formatting issuesin the last stateful processing blog post Touch up some punctuation in state blog post Fix some typos and small formatting issues. Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit:

[1/2] beam git commit: [BEAM-79] Support merging windows in GearpumpRunner

Repository: beam Updated Branches: refs/heads/gearpump-runner 4001aeb19 -> 2d0aed922 [BEAM-79] Support merging windows in GearpumpRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7af64720 Tree:

[2/2] beam git commit: This closes #1935: Support merging windows in GearpumpRunner

This closes #1935: Support merging windows in GearpumpRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2d0aed92 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2d0aed92 Diff:

[5/7] beam git commit: Removes some OldDoFn code from DoFnRunners

Removes some OldDoFn code from DoFnRunners DoFnRunners.createDefault() can be replaced with simpleRunner() at the existing call sites, since it is never called with a ReduceFnExecutor at those call sites. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[6/7] beam git commit: Points Dataflow runner to updated worker images

Points Dataflow runner to updated worker images Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b17e5b0b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b17e5b0b Diff:

[2/7] beam git commit: Removes ArgumentProvider.windowingInternals

Removes ArgumentProvider.windowingInternals Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/50979f72 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/50979f72 Diff:

[3/7] beam git commit: Moves DoFnAdapters to runners-core

Moves DoFnAdapters to runners-core Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/149d52b5 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/149d52b5 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/149d52b5

[1/7] beam git commit: Removes code for wrapping DoFn as an OldDoFn

Repository: beam Updated Branches: refs/heads/master eaf4450f2 -> a91571ef9 Removes code for wrapping DoFn as an OldDoFn Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ad5eb066 Tree:

[7/7] beam git commit: This closes #1773: Removes or moves away all OldDoFn code from SDK except OldDoFn itself

This closes #1773: Removes or moves away all OldDoFn code from SDK except OldDoFn itself Points Dataflow runner to updated worker images Moves PerKeyCombineFnRunners to Flink runner Removes some OldDoFn code from DoFnRunners Moves DoFnAdapters to runners-core Removes

[1/2] beam git commit: Moves PerKeyCombineFnRunners back to runners-core

Repository: beam Updated Branches: refs/heads/master 420367088 -> 2f580caff Moves PerKeyCombineFnRunners back to runners-core It is used by the Dataflow worker. However, this change moves only the non-OldDoFn related part to runners-core. The OldDoFn-related part stays in Flink. Project:

[2/2] beam git commit: This closes #1798: Moves PerKeyCombineFnRunners back to runners-core

This closes #1798: Moves PerKeyCombineFnRunners back to runners-core Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2f580caf Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2f580caf Diff:

[2/2] beam git commit: This closes #1752: Make DataflowPipelineTranslator public

This closes #1752: Make DataflowPipelineTranslator public Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b81bd25e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b81bd25e Diff:

[1/2] beam git commit: Make DataflowPipelineTranslator public

Repository: beam Updated Branches: refs/heads/master 70dd54625 -> b81bd25e1 Make DataflowPipelineTranslator public There are a couple places outside the Beam codebase that still refer to this, and no great reason to break them. Project: http://git-wip-us.apache.org/repos/asf/beam/repo

[2/2] beam git commit: This closes #1767: Revert "Captures assertion site and message in PAssert"

This closes #1767: Revert "Captures assertion site and message in PAssert" Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/07020c96 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/07020c96 Diff:

[1/2] beam git commit: Revert "Captures assertion site and message in PAssert"

Repository: beam Updated Branches: refs/heads/master 51820cbe0 -> 07020c961 Revert "Captures assertion site and message in PAssert" This reverts commit c62611c73ab0f9a5769f3ee9b28b11e917628f78. It breaks post-commit Dataflow and Flink runners. Project:

[1/2] beam git commit: Captures assertion site and message in PAssert

Repository: beam Updated Branches: refs/heads/master 055f452c0 -> 51820cbe0 Captures assertion site and message in PAssert This makes PAssert failures quite a bit easier to debug. Example message after this commit: java.lang.AssertionError: Some message at

[2/5] beam git commit: Move some pieces of Dataflow translator to top level

Move some pieces of Dataflow translator to top level Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5d2cb3e2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5d2cb3e2 Diff:

[3/5] beam git commit: Reduce visibility of many Dataflow runner internals

http://git-wip-us.apache.org/repos/asf/beam/blob/33907f89/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowUnboundedReadFromBoundedSourceTest.java -- diff --git

[5/5] beam git commit: This closes #1678: Refactor Dataflow translator to decouple steps

This closes #1678: Refactor Dataflow translator to decouple steps Reduce visibility of many Dataflow runner internals Move some pieces of Dataflow translator to top level Add explicit translation builder for a Step to in Dataflow translator Project:

[3/3] beam git commit: This closes #1742: Rollforwards "Allow stateful DoFn in DataflowRunner"

This closes #1742: Rollforwards "Allow stateful DoFn in DataflowRunner" Rollforwards "Allow stateful DoFn in DataflowRunner" Update Dataflow worker to beam-master-20170106 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/3] beam git commit: Update Dataflow worker to beam-master-20170106

Repository: beam Updated Branches: refs/heads/master a6caa82a6 -> 418c597c4 Update Dataflow worker to beam-master-20170106 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5af7f42d Tree:

[2/3] beam git commit: Rollforwards "Allow stateful DoFn in DataflowRunner""

Rollforwards "Allow stateful DoFn in DataflowRunner"" This rolls forward 42bb15d, allowing stateful DoFn in DataflowRunner. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d583a1ce Tree:

[1/3] beam git commit: Added a new method on Coder which returns a TypeDescriptor.

Repository: beam Updated Branches: refs/heads/master 1e2f90c17 -> 13767de88 http://git-wip-us.apache.org/repos/asf/beam/blob/7b98fa08/sdks/java/core/src/test/java/org/apache/beam/sdk/coders/StandardCoderTest.java -- diff --git

[3/3] beam git commit: This closes #1537: Add a new method on Coder which returns a TypeDescriptor

This closes #1537: Add a new method on Coder which returns a TypeDescriptor Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/13767de8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/13767de8 Diff:

[2/3] beam git commit: Deliver timers in the direct runner

Deliver timers in the direct runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d4cc0c33 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d4cc0c33 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d4cc0c33

[1/4] beam git commit: Remove deprecated RunnableOnService

Repository: beam Updated Branches: refs/heads/master 61fad2a66 -> 1d36d32fe Remove deprecated RunnableOnService Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/488dc99d Tree:

[4/4] beam git commit: This closes #2157: Port Java modules from RunnableOnService to ValidatesRunner

This closes #2157: Port Java modules from RunnableOnService to ValidatesRunner Remove deprecated RunnableOnService Port Java modules from RunnableOnService to ValidatesRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/4] beam git commit: Port Java modules from RunnableOnService to ValidatesRunner

http://git-wip-us.apache.org/repos/asf/beam/blob/a58a7412/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupByKeyTest.java -- diff --git

[3/4] beam git commit: Port Java modules from RunnableOnService to ValidatesRunner

Port Java modules from RunnableOnService to ValidatesRunner Python is already using ValidatesRunner, as per dev list consensus. A deprecated RunnableOnService is left in place as a superclass so anything remaining that scrapes for it can be ported gradually. Project:

[1/2] beam git commit: [BEAM-1778] Second clean up pass of dataflow references/URLs in Java SDK

Repository: beam Updated Branches: refs/heads/master 1ea3b35ba -> ced1e5c3a [BEAM-1778] Second clean up pass of dataflow references/URLs in Java SDK Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/07a50b48 Tree:

[2/2] beam git commit: This closes #2311: Second clean up pass of dataflow references/URLs in Java SDK

This closes #2311: Second clean up pass of dataflow references/URLs in Java SDK [BEAM-1778] Second clean up pass of dataflow references/URLs in Java SDK Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ced1e5c3 Tree:

[1/2] beam git commit: Rename RunnableOnService to ValidatesRunner in poms and Jenkins jobs

Repository: beam Updated Branches: refs/heads/master 118da8171 -> 0582eb9fc Rename RunnableOnService to ValidatesRunner in poms and Jenkins jobs Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8cff7442 Tree:

[2/2] beam git commit: This closes #2343: Rename RunnableOnService to ValidatesRunner in poms and Jenkins jobs

This closes #2343: Rename RunnableOnService to ValidatesRunner in poms and Jenkins jobs Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0582eb9f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0582eb9f Diff:

[1/2] beam git commit: [BEAM-972] Add unit tests to Gearpump runner

Repository: beam Updated Branches: refs/heads/gearpump-runner 555842a1a -> f4f233304 [BEAM-972] Add unit tests to Gearpump runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/eb0d333d Tree:

[2/2] beam git commit: This closes #2302: Add unit tests to Gearpump runner

This closes #2302: Add unit tests to Gearpump runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f4f23330 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f4f23330 Diff:

[07/50] [abbrv] beam git commit: Auto-generated runner api proto bindings.

http://git-wip-us.apache.org/repos/asf/beam/blob/3bb125e1/sdks/python/run_pylint.sh -- diff --git a/sdks/python/run_pylint.sh b/sdks/python/run_pylint.sh index afc5fb4..5e63856 100755 --- a/sdks/python/run_pylint.sh +++

[32/50] [abbrv] beam git commit: [BEAM-1551] Allow `PAssert`s to take a message

[BEAM-1551] Allow `PAssert`s to take a message Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e3cafb42 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e3cafb42 Diff:

[39/50] [abbrv] beam git commit: This closes #2224

This closes #2224 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f29bf89c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f29bf89c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f29bf89c Branch:

[47/50] [abbrv] beam git commit: Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner

Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3f917987 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3f917987 Diff:

[42/50] [abbrv] beam git commit: This closes #2109: Allow `PAssert`s to take a message

This closes #2109: Allow `PAssert`s to take a message Remove exception suppression from PAssert.SideInputCheckerDoFn Added assertion failure tests for `PAssert#thatSingleton` Added a test of default PAssert failure reason Javadoc changes [BEAM-1551] Allow `PAssert`s to take a message

[49/50] [abbrv] beam git commit: [BEAM-79] Fix gearpump-runner merge conflicts and test failure

[BEAM-79] Fix gearpump-runner merge conflicts and test failure Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3eab6a64 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3eab6a64 Diff:

[19/50] [abbrv] beam git commit: [BEAM-1661] Shade guava in the JdbcIO

[BEAM-1661] Shade guava in the JdbcIO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/818e521f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/818e521f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/818e521f

[06/50] [abbrv] beam git commit: Runner API context helper classes.

Runner API context helper classes. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bc76a186 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bc76a186 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bc76a186

[45/50] [abbrv] beam git commit: Revert BigQueryIO bit of 'Make all uses of CountingOutputStream close their resources'

Revert BigQueryIO bit of 'Make all uses of CountingOutputStream close their resources' This reverts the portion of commit 3115dbdca1858511e98476b5c79e6cca98782b0b that touches BigQueryIO, which caused a double close bug. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[05/50] [abbrv] beam git commit: This closes #2197: Bump Dataflow ROS timeout to 120 minutes

This closes #2197: Bump Dataflow ROS timeout to 120 minutes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f13a84d6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f13a84d6 Diff:

[36/50] [abbrv] beam git commit: Add README to python tarball.

Add README to python tarball. And, delete test created files, to avoid them being included in the tarball. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ec6da893 Tree:

[13/50] [abbrv] beam git commit: Move pipeline context and add more tests.

Move pipeline context and add more tests. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/deff128f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/deff128f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/deff128f

[26/50] [abbrv] beam git commit: This closes #2210

This closes #2210 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/54390a33 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/54390a33 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/54390a33 Branch:

[23/50] [abbrv] beam git commit: [BEAM-1686] This closes #2219

[BEAM-1686] This closes #2219 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/818fc941 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/818fc941 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/818fc941 Branch:

[28/50] [abbrv] beam git commit: This closes #2144: Remove Pipeline.getRunner

This closes #2144: Remove Pipeline.getRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e31cb2b4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e31cb2b4 Diff:

[04/50] [abbrv] beam git commit: This closes #1994

This closes #1994 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b79dd642 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b79dd642 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b79dd642 Branch:

[38/50] [abbrv] beam git commit: Ignore results from the tox clean up phase

Ignore results from the tox clean up phase Some temporary files are generated only under certain conditions and this should not fail tox. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/12016e59 Tree:

[41/50] [abbrv] beam git commit: This closes #2225

This closes #2225 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7c78480c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7c78480c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7c78480c Branch:

[03/50] [abbrv] beam git commit: HadoopInputFormatIO with junits

HadoopInputFormatIO with junits Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d01620c0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d01620c0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d01620c0 Branch:

[11/50] [abbrv] beam git commit: Runner API translation of triggers and windowing strategies.

Runner API translation of triggers and windowing strategies. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5b86e1fc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5b86e1fc Diff:

[24/50] [abbrv] beam git commit: Remove Pipeline.getRunner

Remove Pipeline.getRunner Runners need not be instantiated until after pipeline construction, so they should not be exposed by the Pipeline class. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d41fe1df Tree:

[12/50] [abbrv] beam git commit: Runner API encoding of WindowFns.

Runner API encoding of WindowFns. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aad32b7a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/aad32b7a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/aad32b7a Branch:

[48/50] [abbrv] beam git commit: [BEAM-79] Fix gearpump-runner merge conflicts and test failure

http://git-wip-us.apache.org/repos/asf/beam/blob/3eab6a64/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/WindowBoundTranslator.java -- diff --git

[29/50] [abbrv] beam git commit: Javadoc changes

Javadoc changes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0d08d2a4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0d08d2a4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0d08d2a4 Branch:

[02/50] [abbrv] beam git commit: HadoopInputFormatIO with junits

http://git-wip-us.apache.org/repos/asf/beam/blob/d01620c0/sdks/java/io/hadoop-input-format/src/test/java/org/apache/beam/sdk/io/hadoop/inputformat/HadoopInputFormatIOTest.java -- diff --git

[46/50] [abbrv] beam git commit: This closes #2226

This closes #2226 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/781e4172 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/781e4172 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/781e4172 Branch:

[50/50] [abbrv] beam git commit: This closes #2241: merge master to gearpump-master and fixup

This closes #2241: merge master to gearpump-master and fixup [BEAM-79] Fix gearpump-runner merge conflicts and test failure Revert BigQueryIO bit of 'Make all uses of CountingOutputStream close their resources' [BEAM-1629] Init metrics/aggregators accumulators before traversing pipeline

[14/50] [abbrv] beam git commit: Closes #2190

Closes #2190 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2c2424cb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2c2424cb Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2c2424cb Branch:

[40/50] [abbrv] beam git commit: Generate zip distribution for pyhthon

Generate zip distribution for pyhthon Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/466e83fd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/466e83fd Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/466e83fd

[27/50] [abbrv] beam git commit: This closes #2217: Fix Flink State GC

This closes #2217: Fix Flink State GC Properly deal with late processing-time timers Introduce Flink-specific state GC implementations Move GC timer checking to StatefulDoFnRunner.CleanupTimer Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[21/50] [abbrv] beam git commit: [BEAM-1661] This closes #2205

[BEAM-1661] This closes #2205 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fdba784a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fdba784a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fdba784a Branch:

[09/50] [abbrv] beam git commit: Auto-generated runner api proto bindings.

Auto-generated runner api proto bindings. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3bb125e1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3bb125e1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3bb125e1

[34/50] [abbrv] beam git commit: Remove exception suppression from PAssert.SideInputCheckerDoFn

Remove exception suppression from PAssert.SideInputCheckerDoFn Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3669146c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3669146c Diff:

[31/50] [abbrv] beam git commit: Added assertion failure tests for `PAssert#thatSingleton`

Added assertion failure tests for `PAssert#thatSingleton` Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/59fd45b8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/59fd45b8 Diff:

[43/50] [abbrv] beam git commit: [BEAM-1629] Init metrics/aggregators accumulators before traversing pipeline

[BEAM-1629] Init metrics/aggregators accumulators before traversing pipeline Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/874c8d0d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/874c8d0d Diff:

[17/50] [abbrv] beam git commit: [BEAM-797] A PipelineVisitor that creates a Spark-native pipeline.

[BEAM-797] A PipelineVisitor that creates a Spark-native pipeline. [BEAM-797] Remove unnecessary temp dir from test Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/94bef14e Tree:

[16/50] [abbrv] beam git commit: Move GC timer checking to StatefulDoFnRunner.CleanupTimer

Move GC timer checking to StatefulDoFnRunner.CleanupTimer Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bf6d2748 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bf6d2748 Diff:

[15/50] [abbrv] beam git commit: Introduce Flink-specific state GC implementations

Introduce Flink-specific state GC implementations We now set the GC timer for window.maxTimestamp() + 1 to ensure that a user timer set for window.maxTimestamp() still has all state. This also adds tests for late data dropping and state GC specifically for the Flink DoFnOperator. Project:

[35/50] [abbrv] beam git commit: This closes #2221

This closes #2221 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9299e263 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9299e263 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9299e263 Branch:

[01/50] [abbrv] beam git commit: This closes #2142: Deprecate Pipeline.getOptions

Repository: beam Updated Branches: refs/heads/gearpump-runner 15a8ad62a -> 555842a1a This closes #2142: Deprecate Pipeline.getOptions Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ef256df1 Tree:

[08/50] [abbrv] beam git commit: Auto-generated runner api proto bindings.

http://git-wip-us.apache.org/repos/asf/beam/blob/3bb125e1/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py -- diff --git a/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py

[37/50] [abbrv] beam git commit: This closes #2222

This closes # Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/39688d8d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/39688d8d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/39688d8d Branch:

[25/50] [abbrv] beam git commit: add unicode type to the typeDict attribute in Python SDK

add unicode type to the typeDict attribute in Python SDK Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7daf9abd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7daf9abd Diff:

[18/50] [abbrv] beam git commit: This closes #1868

This closes #1868 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c12d432d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c12d432d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c12d432d Branch:

[1/2] beam git commit: Prune branches in Jenkins build

Repository: beam Updated Branches: refs/heads/master 32f7e0c71 -> 1d9772a3a Prune branches in Jenkins build This avoids possible conflicts in evolution of the configuration of how remote branches are mapped to local branches. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/2] beam git commit: This closes #1662: Prune branches in Jenkins build

This closes #1662: Prune branches in Jenkins build Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1d9772a3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1d9772a3 Diff:

[1/2] beam git commit: Dataflow streaming config for WordCountIT and WindowedWordCountIT

Repository: beam Updated Branches: refs/heads/master 6fa1fca4f -> 32f7e0c71 Dataflow streaming config for WordCountIT and WindowedWordCountIT Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b58117c6 Tree:

[2/2] beam git commit: This closes #2155: Dataflow streaming config for WordCountIT and WindowedWordCountIT

This closes #2155: Dataflow streaming config for WordCountIT and WindowedWordCountIT Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/32f7e0c7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/32f7e0c7 Diff:

[2/2] beam git commit: This closes #2416: Remove getProducingTransformInternal

This closes #2416: Remove getProducingTransformInternal Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2dc61f63 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2dc61f63 Diff:

[1/2] beam git commit: Remove GetProducingTransformInternal

Repository: beam Updated Branches: refs/heads/master 697063297 -> 2dc61f637 Remove GetProducingTransformInternal This isn't part of the PValue API, so remove from POutputValueBase. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/2] beam git commit: JavaDoc for function `PaneInfo.getTiming()`

Repository: beam Updated Branches: refs/heads/master 8b119bcdf -> 8a8dbcfc5 JavaDoc for function `PaneInfo.getTiming()` Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5959110a Tree:

[2/2] beam git commit: This closes #2452: Rename FunctionSpec and UrnWithParameter to their (hopefully) final names

This closes #2452: Rename FunctionSpec and UrnWithParameter to their (hopefully) final names Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0a176454 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0a176454 Diff:

[1/2] beam git commit: Rename FunctionSpec and UrnWithParameter to their (hopefully) final names

Repository: beam Updated Branches: refs/heads/master 37e4cc1b8 -> 0a176454c Rename FunctionSpec and UrnWithParameter to their (hopefully) final names Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fa47527e Tree:

[1/2] beam git commit: Rename filePath to filePattern in NumbedShardedFile

Repository: beam Updated Branches: refs/heads/master 61790f038 -> 07a49e90b Rename filePath to filePattern in NumbedShardedFile This probably would have saved a few hours of debugging by signposting the intended usage more clearly. Project: http://git-wip-us.apache.org/repos/asf/beam/repo

[2/2] beam git commit: This closes #2425: Rename filePath to filePattern in NumbedShardedFile

This closes #2425: Rename filePath to filePattern in NumbedShardedFile Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/07a49e90 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/07a49e90 Diff:

[2/3] beam git commit: Remove NeedsRunner category tags from non-core libraries

Remove NeedsRunner category tags from non-core libraries Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0683ac12 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0683ac12 Diff:

[3/3] beam git commit: This closes #2359: Remove NeedsRunner and ValidatesRunner category tags from non-core libraries

This closes #2359: Remove NeedsRunner and ValidatesRunner category tags from non-core libraries Remove ValidatesRunner category tags from non-core libraries Remove NeedsRunner category tags from non-core libraries Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/3] beam git commit: Remove ValidatesRunner category tags from non-core libraries

Repository: beam Updated Branches: refs/heads/master 07a49e90b -> bb1838476 Remove ValidatesRunner category tags from non-core libraries Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f388cc71 Tree:

[4/6] beam git commit: Rename AccumulatorCombiningState to CombiningState

http://git-wip-us.apache.org/repos/asf/beam/blob/ef480a37/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupIntoBatches.java -- diff --git

[2/6] beam git commit: Rename combiningValue to combining in StateSpecs

Rename combiningValue to combining in StateSpecs Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/33259d05 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/33259d05 Diff:

[5/6] beam git commit: Rename AccumulatorCombiningState to CombiningState

Rename AccumulatorCombiningState to CombiningState Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ef480a37 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ef480a37 Diff:

[1/6] beam git commit: Upgrade Dataflow worker image to beam-master-20170405

Repository: beam Updated Branches: refs/heads/master bb1838476 -> b92032ff6 Upgrade Dataflow worker image to beam-master-20170405 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/359040e8 Tree:

[3/6] beam git commit: Rename CombiningState to GroupingState

Rename CombiningState to GroupingState Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/24c0495a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/24c0495a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/24c0495a

[6/6] beam git commit: This closes #2413: Rename CombiningState and friends to be more user-friendly

This closes #2413: Rename CombiningState and friends to be more user-friendly Upgrade Dataflow worker image to beam-master-20170405 Rename combiningValue to combining in StateSpecs Rename AccumulatorCombiningState to CombiningState Rename CombiningState to GroupingState Project:

[2/3] beam git commit: Add windowing support to FileBasedSink

Add windowing support to FileBasedSink Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6addc95f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6addc95f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6addc95f

<    1   2   3   4   5   6   7   8   9   10   >