[1/2] beam git commit: Drop late data in Flink runner

Repository: beam Updated Branches: refs/heads/master 4ccbdbc38 -> 72fef99a6 Drop late data in Flink runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0454a189 Tree:

[1/2] beam git commit: Gives the runner access to RestrictionTracker

Repository: beam Updated Branches: refs/heads/master 168d6a18f -> a27d3cfa2 Gives the runner access to RestrictionTracker Changes the SplittableParDo transform so that ProcessFn uses a runner-supplied hook to run the @ProcessElement method, giving it, among other things, the

[1/2] beam git commit: Removes inputProvider() and outputReceiver()

Repository: beam Updated Branches: refs/heads/master 77b136603 -> 38208eaa4 Removes inputProvider() and outputReceiver() Removes InputProvider itself too. Does not remove OutputReceiver because it's used in @SplitRestriction method. Cleans up tests that looked at InputProvider/OutputReceiver

[2/2] beam git commit: This closes #1860: Removes inputProvider() and outputReceiver()

This closes #1860: Removes inputProvider() and outputReceiver() Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/38208eaa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/38208eaa Diff:

[2/2] beam git commit: This closes #1748: Add some more RunnableOnService tests for stateful ParDo

This closes #1748: Add some more RunnableOnService tests for stateful ParDo Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a26fd1ff Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a26fd1ff Diff:

[1/2] beam git commit: Add some more RunnableOnService tests for stateful ParDo

Repository: beam Updated Branches: refs/heads/master 0c24286e1 -> a26fd1ff3 Add some more RunnableOnService tests for stateful ParDo Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6c00e912 Tree:

[1/2] beam git commit: Add wrapping of lambda in a SimpleFunction

Repository: beam Updated Branches: refs/heads/master ed7b82e7e -> 144bffd40 Add wrapping of lambda in a SimpleFunction Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/23152178 Tree:

[2/2] beam git commit: This closes #1855: Add wrapping of lambda in a SimpleFunction

This closes #1855: Add wrapping of lambda in a SimpleFunction Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/144bffd4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/144bffd4 Diff:

[1/2] beam git commit: [BEAM-65] ProcessFn: support setup/teardown

Repository: beam Updated Branches: refs/heads/master 224e44765 -> f4e109767 [BEAM-65] ProcessFn: support setup/teardown Previously, ProcessFn did not explicitly invoke the underlying fn's @Setup and @Teardown methods - it was assuming that those methods would get invoked on that fn

[2/2] beam git commit: This closes #1895: ProcessFn: support setup/teardown

This closes #1895: ProcessFn: support setup/teardown Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f4e10976 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f4e10976 Diff:

[1/2] beam git commit: Allow absolute timers

Repository: beam Updated Branches: refs/heads/master f4e109767 -> 0c24286e1 Allow absolute timers Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a93c5c05 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a93c5c05

[2/2] beam git commit: This closes #1827: Allow absolute timers

This closes #1827: Allow absolute timers Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0c24286e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0c24286e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0c24286e

[1/2] beam git commit: [BEAM-1434] Add new beam-sdk-java-core test deps to test scope for DataflowRunner

Repository: beam Updated Branches: refs/heads/master df2774cd8 -> cf1925fba [BEAM-1434] Add new beam-sdk-java-core test deps to test scope for DataflowRunner Since test dependencies are not transitively inherited, this is needed to prevent test-time crashes. Missed in #1948. Project:

[2/2] beam git commit: This closes #1949: Add new beam-sdk-java-core test deps to test scope for DataflowRunner

This closes #1949: Add new beam-sdk-java-core test deps to test scope for DataflowRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cf1925fb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/cf1925fb Diff:

[2/2] beam git commit: This closes #1912: Add license header to website Jenkins job descriptions

This closes #1912: Add license header to website Jenkins job descriptions Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/08e58e1d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/08e58e1d Diff:

[1/2] beam git commit: Add license header to website Jenkins job descriptions

Repository: beam Updated Branches: refs/heads/master 96a05a4b4 -> 08e58e1df Add license header to website Jenkins job descriptions Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/838ef04d Tree:

[2/4] beam git commit: Autoformat GroupAlsoByWindowsViaOutputBufferDoFn

Autoformat GroupAlsoByWindowsViaOutputBufferDoFn Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c2925feb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c2925feb Diff:

[1/4] beam git commit: Remove extraneous chunking from GroupAlsoByWindowsViaOutputBufferDoFn

Repository: beam Updated Branches: refs/heads/master b3d962df2 -> 7564486f5 Remove extraneous chunking from GroupAlsoByWindowsViaOutputBufferDoFn Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4800a3eb Tree:

[4/4] beam git commit: This closes #1924: Remove extraneous chunking from GroupAlsoByWindowsViaOutputBufferDoFn

This closes #1924: Remove extraneous chunking from GroupAlsoByWindowsViaOutputBufferDoFn Remove inaccurate pluralization from GABWViaOutputBufferDoFn Autoformat GroupAlsoByWindowsViaOutputBufferDoFn Remove extraneous chunking from GroupAlsoByWindowsViaOutputBufferDoFn Project:

[12/15] beam git commit: Upgrade Dataflow container version to beam-master-20170203

Upgrade Dataflow container version to beam-master-20170203 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fd7e6149 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fd7e6149 Diff:

[15/15] beam git commit: This closes #1858: Move state-oriented remnants of OldDoFn to runners/core-java

This closes #1858: Move state-oriented remnants of OldDoFn to runners/core-java Upgrade Dataflow container version to beam-master-20170203 Move StateNamespace and related to runners/core-java Move StateInternals to runners/core-java Move StateTable to runners/core-java Move

[02/15] beam git commit: Move InMemoryStateInternals to runners/core-java

Move InMemoryStateInternals to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/af391b88 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/af391b88 Diff:

[03/15] beam git commit: Eliminate use of InMemoryStateInternals in the Java SDK

Eliminate use of InMemoryStateInternals in the Java SDK Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2b6698d1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2b6698d1 Diff:

[07/15] beam git commit: Remove comment-only uses that block runners/core-java migrations

Remove comment-only uses that block runners/core-java migrations Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1d7c6b06 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1d7c6b06 Diff:

[11/15] beam git commit: Move TimerInternals to runners/core-java

Move TimerInternals to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b086d2fd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b086d2fd Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b086d2fd

[05/15] beam git commit: Move WindowingInternals to runners/core-java

Move WindowingInternals to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/949ab3ac Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/949ab3ac Diff:

[08/15] beam git commit: Move StateNamespace and related to runners/core-java

http://git-wip-us.apache.org/repos/asf/beam/blob/e77e7f0d/sdks/java/core/src/test/java/org/apache/beam/sdk/util/state/StateNamespacesTest.java -- diff --git

[01/15] beam git commit: Move TimerInternalsFactory to runners/core-java

Repository: beam Updated Branches: refs/heads/master e0189f352 -> 224e44765 Move TimerInternalsFactory to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/92b33bc7 Tree:

[04/15] beam git commit: Move StateInternalsFactory to runners/core-java

Move StateInternalsFactory to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2e6c1310 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2e6c1310 Diff:

[06/15] beam git commit: Delete long-deprecated StateContexts methods

Delete long-deprecated StateContexts methods Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b12e5ffb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b12e5ffb Diff:

[14/15] beam git commit: Move StateInternals to runners/core-java

Move StateInternals to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/144b1df8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/144b1df8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/144b1df8

[09/15] beam git commit: Move StateNamespace and related to runners/core-java

Move StateNamespace and related to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e77e7f0d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e77e7f0d Diff:

[2/2] beam git commit: This closes #1780: Simplified API surface verifications

This closes #1780: Simplified API surface verifications Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/26a2c47f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/26a2c47f Diff:

[1/2] beam git commit: [BEAM-882, BEAM-883, BEAM-878] Simplified API surface verifications.

Repository: beam Updated Branches: refs/heads/master a1a022d6b -> 26a2c47f4 [BEAM-882,BEAM-883,BEAM-878] Simplified API surface verifications. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/29ffaf38 Tree:

[2/2] beam git commit: This closes #1822: Revert "Simplified API surface verifications"

This closes #1822: Revert "Simplified API surface verifications" Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cb6e0a80 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/cb6e0a80 Diff:

[04/12] beam git commit: fix group by window

fix group by window Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e63d42d1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e63d42d1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e63d42d1 Branch:

[05/12] beam git commit: update to latest gearpump dsl function interface

update to latest gearpump dsl function interface Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3bf82638 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3bf82638 Diff:

[02/12] beam git commit: update ROS configurations

update ROS configurations Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cfdc971f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/cfdc971f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/cfdc971f Branch:

[10/12] beam git commit: Remove cache for Gearpump on travis

Remove cache for Gearpump on travis Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/85dcfbd1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/85dcfbd1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/85dcfbd1

[01/12] beam git commit: [BEAM-1180] Implement GearpumpPipelineResult

Repository: beam Updated Branches: refs/heads/gearpump-runner 4c445dd0b -> 1ed16f11a [BEAM-1180] Implement GearpumpPipelineResult Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/21554764 Tree:

[08/12] beam git commit: fix ParDo.BoundMulti translation

fix ParDo.BoundMulti translation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b2d326ff Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b2d326ff Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b2d326ff Branch:

[11/12] beam git commit: note thread is interrupted on InterruptedException

note thread is interrupted on InterruptedException Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d814857a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d814857a Diff:

[09/12] beam git commit: reduce timeout to wait for result

reduce timeout to wait for result Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7613ec44 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7613ec44 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7613ec44 Branch:

[12/12] beam git commit: This closes #1661: Implement GearpumpPipelineResult

This closes #1661: Implement GearpumpPipelineResult note thread is interrupted on InterruptedException Remove cache for Gearpump on travis reduce timeout to wait for result fix ParDo.BoundMulti translation return encoded key for GroupByKey translation support OutputTimeFn update to

[07/12] beam git commit: return encoded key for GroupByKey translation

return encoded key for GroupByKey translation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/364a3f08 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/364a3f08 Diff:

[2/2] beam git commit: This closes #1833: Removes ReduceFnExecutor interface

This closes #1833: Removes ReduceFnExecutor interface Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/11c3cd70 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/11c3cd70 Diff:

[2/2] beam git commit: This closes #1828: Fix PostCommit test confs for Gearpump runner

This closes #1828: Fix PostCommit test confs for Gearpump runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4001aeb1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4001aeb1 Diff:

[1/4] beam git commit: DoFnSignature: deprecate isStateful in favor of usesState

Repository: beam Updated Branches: refs/heads/master eecbcc48b -> 77c7505b8 DoFnSignature: deprecate isStateful in favor of usesState Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ed434ecf Tree:

[3/4] beam git commit: Set USES_KEYED_STATE in Dataflow when DoFn uses timers

Set USES_KEYED_STATE in Dataflow when DoFn uses timers Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f535d658 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f535d658 Diff:

[3/4] beam git commit: Point to new Dataflow worker

Point to new Dataflow worker Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a2b94eca Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a2b94eca Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a2b94eca Branch:

[2/4] beam git commit: Moves OldDoFn to runners-core

Moves OldDoFn 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/5f8b8c5b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5f8b8c5b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5f8b8c5b Branch:

[1/2] beam git commit: Fix some DoFn javadoc literals

Repository: beam Updated Branches: refs/heads/master 2e766ced5 -> 5fe78440b Fix some DoFn javadoc literals Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f360f47f Tree:

[2/2] beam git commit: This closes #1940: Fix some DoFn javadoc literals

This closes #1940: Fix some DoFn javadoc literals Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5fe78440 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5fe78440 Diff:

[1/2] beam git commit: Upgrade bytebuddy to 1.6.8 to jump past asm 5.0

Repository: beam Updated Branches: refs/heads/master 18f3767e3 -> 2e766ced5 Upgrade bytebuddy to 1.6.8 to jump past asm 5.0 There is a suspected bug in asm 5.0 that is considered the likely root cause of a bug sbt-assembly [1] that carried over to Gearpump [2]. This commit upgrades us to

[2/2] beam git commit: This closes #2014: Upgrade bytebuddy to 1.6.8 to jump past asm 5.0

This closes #2014: Upgrade bytebuddy to 1.6.8 to jump past asm 5.0 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2e766ced Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2e766ced Diff:

[1/2] beam git commit: Add ability to bundle any message with components in Runner API

Repository: beam Updated Branches: refs/heads/master 763fb50b5 -> 9151676a5 Add ability to bundle any message with components in Runner API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/368ad236 Tree:

[2/2] beam git commit: This closes #2023: Add ability to bundle any message with components in Runner API

This closes #2023: Add ability to bundle any message with components in Runner API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9151676a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9151676a Diff:

[1/2] beam git commit: Use strings for ids in Fn API

Repository: beam Updated Branches: refs/heads/master 4f56acbba -> 2c71354d0 Use strings for ids in Fn API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9933f271 Tree:

[2/2] beam git commit: This closes #1190: Use strings for ids in Fn API

This closes #1190: Use strings for ids in Fn API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2c71354d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2c71354d Diff:

[1/5] beam git commit: Factory method best practice for ReshuffleTriggerStateMachine

Repository: beam Updated Branches: refs/heads/master 3d0fe8539 -> 25a014f40 Factory method best practice for ReshuffleTriggerStateMachine Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bd8b72c6 Tree:

[2/5] beam git commit: Translate ReshuffleTrigger into Always trigger proto

Translate ReshuffleTrigger into Always trigger proto Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bfdbebdd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bfdbebdd Diff:

[3/5] beam git commit: Add dependency from runners-core-java to runner-api

Add dependency from runners-core-java to runner-api Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9dbaeaf5 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9dbaeaf5 Diff:

[4/5] beam git commit: Build trigger state machine from Runner API Trigger proto directly

Build trigger state machine from Runner API Trigger proto directly Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/27a482ba Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/27a482ba Diff:

[2/3] beam git commit: Condense FunctionSpec and remove SdkFunctionSpec, merging data and params

Condense FunctionSpec and remove SdkFunctionSpec, merging data and params Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3120fd9a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3120fd9a Diff:

[1/2] beam git commit: Ignore HBaseIOTest temporarily

Repository: beam Updated Branches: refs/heads/master 49c9de1e8 -> 8a06134c6 Ignore HBaseIOTest temporarily Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/916fe65e Tree:

[1/2] beam git commit: [BEAM-1554] Add verification of Coder structural equality after enc/dec

Repository: beam Updated Branches: refs/heads/master 415546eda -> 437ba2505 [BEAM-1554] Add verification of Coder structural equality after enc/dec This also improves the class documentation. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/4] beam git commit: Make SDK-specific serialized blob really a blob

Make SDK-specific serialized blob really a blob Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/380b75e2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/380b75e2 Diff:

[3/4] beam git commit: Add conversion to/from Runner API proto for WindowingStrategy

Add conversion to/from Runner API proto for WindowingStrategy Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7dd57105 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7dd57105 Diff:

[4/4] beam git commit: This closes #2030: Convert to/from WindowingStrategy proto in Java SDK

This closes #2030: Convert to/from WindowingStrategy proto in Java SDK Add conversion to/from Runner API proto for WindowingStrategy Add closing behavior to Runner API proto Make SDK-specific serialized blob really a blob Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[1/4] beam git commit: Add closing behavior to Runner API proto

Repository: beam Updated Branches: refs/heads/master 3fcc82081 -> 154c54305 Add closing behavior to Runner API proto Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aac38d60 Tree:

[2/2] beam git commit: This closes #1975: Changed name of ToString.of() to ToString.elements().

This closes #1975: Changed name of ToString.of() to ToString.elements(). Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/98d8834a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/98d8834a Diff:

[1/2] beam git commit: Changed name of ToString.of() to ToString.elements().

Repository: beam Updated Branches: refs/heads/master f32cb3e7a -> 98d8834af Changed name of ToString.of() to ToString.elements(). Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a49acdad Tree:

[2/2] beam git commit: This closes #1891: Correct Javadoc on accessing windows in DoFn

This closes #1891: Correct Javadoc on accessing windows in DoFn Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/49809d1d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/49809d1d Diff:

[1/2] beam git commit: Correct Javadoc on accessing windows in DoFn

Repository: beam Updated Branches: refs/heads/master 98d8834af -> 49809d1d4 Correct Javadoc on accessing windows in DoFn Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c1c8d838 Tree:

[1/2] beam git commit: Add proto definition for Runner API

Repository: beam Updated Branches: refs/heads/master cd6802bec -> 490ef8f09 Add proto definition for Runner API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a5ce3b43 Tree:

[2/2] beam git commit: This closes #1946: Add proto definition for Runner API

This closes #1946: Add proto definition for Runner API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/490ef8f0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/490ef8f0 Diff:

[4/5] beam git commit: Add SetState and MapState

Add SetState and MapState Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a0702f5b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a0702f5b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a0702f5b Branch:

[2/5] beam git commit: Exclude UsesSetState and UsesMapState categories from Dataflow runner

Exclude UsesSetState and UsesMapState categories from Dataflow runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/36604a01 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/36604a01 Diff:

[1/5] beam git commit: Add UsesMapState and UsesSetState JUnit categories

Repository: beam Updated Branches: refs/heads/master ed3ef11fa -> 2596d46a1 Add UsesMapState and UsesSetState JUnit categories Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/674bead8 Tree:

[3/5] beam git commit: Exclude UsesSetState and UsesMapState tests for Flink runner

Exclude UsesSetState and UsesMapState tests for Flink runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0f48321e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0f48321e Diff:

[5/5] beam git commit: This closes #1950: State for "Set" data and "Map" data

This closes #1950: State for "Set" data and "Map" data Add SetState and MapState Exclude UsesSetState and UsesMapState tests for Flink runner Exclude UsesSetState and UsesMapState categories from Dataflow runner Add UsesMapState and UsesSetState JUnit categories Project:

[4/9] beam git commit: Upgrade Java triggers to support runner API deserialization

Upgrade Java triggers to support runner API deserialization Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5d5602db Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5d5602db Diff:

[3/9] beam git commit: Fix typo in runner API generated Java class

Fix typo in runner API generated Java class Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/67854e66 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/67854e66 Diff:

[2/9] beam git commit: Flesh out triggers in Runner API proto

Flesh out triggers in Runner API proto Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/661cd8d7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/661cd8d7 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/661cd8d7

[8/9] beam git commit: Upgrade Dataflow container version to beam-master-20170214

Upgrade Dataflow container version to beam-master-20170214 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e097b757 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e097b757 Diff:

[6/9] beam git commit: Add runner API config to poms

Add runner API config to poms Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2803864b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2803864b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2803864b Branch:

[1/3] beam-site git commit: Fix typo in stateful processing post

Repository: beam-site Updated Branches: refs/heads/asf-site 00e375003 -> f3c189568 Fix typo in stateful processing post Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/47b1c5cd Tree:

[3/3] beam-site git commit: This closes #155: Fix typo in stateful processing post

This closes #155: Fix typo in stateful processing post Regenerate site Fix typo in stateful processing post Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/f3c18956 Tree:

[2/3] beam-site git commit: Regenerate site

Regenerate site Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/76021685 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/76021685 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/76021685

[7/9] beam git commit: Remove underscore from Runner API proto Java package

Remove underscore from Runner API proto Java package Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b6e9f73a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b6e9f73a Diff:

[5/9] beam git commit: Add conversion to/from Java SDK trigger to runner API proto

Add conversion to/from Java SDK trigger to runner API proto Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f4ceaeef Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f4ceaeef Diff:

[1/9] beam git commit: Reify delay and alignment in AfterProcessingTime transform

Repository: beam Updated Branches: refs/heads/master 9061c65e3 -> db19c7df5 Reify delay and alignment in AfterProcessingTime transform Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/40c4a5cb Tree:

[9/9] beam git commit: This resolves #1988: Add full-fidelity conversion to/from Java SDK triggers and Runner API protos

This resolves #1988: Add full-fidelity conversion to/from Java SDK triggers and Runner API protos Upgrade Dataflow container version to beam-master-20170214 Remove underscore from Runner API proto Java package Add conversion to/from Java SDK trigger to runner API proto Add runner API

[6/8] beam git commit: Move StateTag and friends to runners/core-java

Move StateTag and friends to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/07d93276 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/07d93276 Diff:

[7/8] beam git commit: Upgrade Dataflow container version to beam-master-20170208

Upgrade Dataflow container version to beam-master-20170208 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/255c7e28 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/255c7e28 Diff:

[2/8] beam git commit: Move StateMerging to runners/core-java

Move StateMerging to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9c0047f7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9c0047f7 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9c0047f7

[3/8] beam git commit: Move StateTag adapter code to StateTags

Move StateTag adapter code to StateTags Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c42a19b1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c42a19b1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c42a19b1

[5/8] beam git commit: Move StateTag and friends to runners/core-java

http://git-wip-us.apache.org/repos/asf/beam/blob/07d93276/sdks/java/core/src/test/java/org/apache/beam/sdk/util/state/StateTagTest.java -- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/util/state/StateTagTest.java

[2/3] beam-site git commit: Touch up some punctuation in state blog post

Touch up some punctuation in state blog post Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/f928b50e Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/f928b50e Diff:

[1/3] beam-site git commit: Fix some typos and small formatting issues.

Repository: beam-site Updated Branches: refs/heads/asf-site f3c189568 -> f48e97f67 Fix some typos and small formatting issues. Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/8518baa7 Tree:

  1   2   3   4   5   6   7   8   9   10   >