[GitHub] incubator-beam pull request: Fix misleading Javadoc on Trigger.onE...

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam/pull/122 Fix misleading Javadoc on Trigger.onElement() This has been bothering me for a while and I always have to go back to the code to check whether my assumption is right. The comment should

[GitHub] incubator-beam pull request #483: Use native Flink rebalance for Reshuffle T...

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam/pull/483 Use native Flink rebalance for Reshuffle Transform R: @mxm You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/incubator-beam

[1/2] incubator-beam git commit: [BEAM-321] Fix Flink Comparators

ttp://git-wip-us.apache.org/repos/asf/incubator-beam/tree/93ca508b Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/93ca508b Branch: refs/heads/master Commit: 93ca508bbdf558772e909df099148a9d03a1e6d4 Parents: 69a4141 Author: Aljoscha Krettek Authored: Wed Jun 1 11:56:18 2016 +0

[2/2] incubator-beam git commit: This closes #409

/diff/0e4d0a9a Branch: refs/heads/master Commit: 0e4d0a9ae0250863d7144ffdcc6c4e9cc099611f Parents: 69a4141 93ca508 Author: Aljoscha Krettek Authored: Sun Jun 19 11:35:19 2016 +0200 Committer: Aljoscha Krettek Committed: Sun Jun 19 11:35:19 2016 +0200

[2/3] incubator-beam git commit: [BEAM-392] Update flink dependency to the most recent stable version

: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/2d3d0f4c Branch: refs/heads/master Commit: 2d3d0f4c2bbfddaf36e6b1068739c9ea48587d6d Parents: df1d5f6 Author: Ismaël Mejía Authored: Wed Jun 29 23:00:02 2016 +0200 Committer: Aljoscha Krettek Committed: Fri Jul 1 07:50:35 2016 +0200

[3/3] incubator-beam git commit: This closes #561

/diff/b4c123cd Branch: refs/heads/master Commit: b4c123cd4d41234c28926e302c8ea7c8900d3672 Parents: df1d5f6 d8c01c8 Author: Aljoscha Krettek Authored: Fri Jul 1 07:53:18 2016 +0200 Committer: Aljoscha Krettek Committed: Fri Jul 1 07:53:18 2016 +0200

[1/3] incubator-beam git commit: [BEAM-392] Rename missing references to FlinkPipelineRunner

016 +0200 Committer: Aljoscha Krettek Committed: Fri Jul 1 07:50:35 2016 +0200 -- .../main/java/org/apache/beam/examples/MinimalWordCount.java | 6 +++--- .../java/org/apache/beam/examples/MinimalWordCountJava8.java | 6 +++---

[2/2] incubator-beam git commit: This closes #483

/diff/9adbecb6 Branch: refs/heads/master Commit: 9adbecb6aa9bd752a6e6e39f41f80a31128d0918 Parents: 56c5277 b58a19c Author: Aljoscha Krettek Authored: Mon Jul 4 16:56:47 2016 +0200 Committer: Aljoscha Krettek Committed: Mon Jul 4 16:56:47 2016 +0200

[1/2] incubator-beam git commit: Use native Flink rebalance for Reshuffle Transform

ree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b58a19ce Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b58a19ce Branch: refs/heads/master Commit: b58a19cebebddbfb5bc8ebe9cc2766c5eccbda59 Parents: 56c5277 Author: Aljoscha Krettek Authored: Fri Jun 17 15:16:19 2016 +0

[2/2] incubator-beam git commit: This closes #630

/diff/1a7cd411 Branch: refs/heads/master Commit: 1a7cd4112aab68d05dc59700883f63a082ea38e0 Parents: ee1a3bc 9000d95 Author: Aljoscha Krettek Authored: Wed Jul 13 14:16:02 2016 +0200 Committer: Aljoscha Krettek Committed: Wed Jul 13 14:16:02 2016 +0200

[1/2] incubator-beam git commit: Allow for custom timestamp/watermark function in FlinkPipelineRunner

master Commit: 9000d95d2b34ab45f799aedb140710986ff19452 Parents: ee1a3bc Author: David Desberg Authored: Mon Jul 11 12:24:18 2016 -0700 Committer: Aljoscha Krettek Committed: Wed Jul 13 14:15:54 2016 +0200 -- .../FlinkStreamingTransformTra

[GitHub] incubator-beam pull request #737: Add Side-Input Support in Flink Streaming ...

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam/pull/737 Add Side-Input Support in Flink Streaming Runner This does several things in somewhat isolated steps: - Unify the operator wrappers. Before there where 4 different DoFn/Window

svn commit: r16619 - /release/incubator/beam/KEYS

Author: aljoscha Date: Fri Oct 21 16:55:14 2016 New Revision: 16619 Log: Add aljoscha to incubator/beam/KEYS Modified: release/incubator/beam/KEYS Modified: release/incubator/beam/KEYS == --- release/incubator/beam

[GitHub] incubator-beam pull request #1166: Fixes for Javadoc and ReduceFnRunner

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam/pull/1166 Fixes for Javadoc and ReduceFnRunner Not sure if this is really wrong in `ReduceFnRunner`, was just a hunch. R: @kennknowles You can merge this pull request into a Git

svn commit: r16654 - /dev/incubator/beam/KEYS

Author: aljoscha Date: Mon Oct 24 14:43:26 2016 New Revision: 16654 Log: Add aljoscha to dev/incubator/beam/KEYS Modified: dev/incubator/beam/KEYS Modified: dev/incubator/beam/KEYS == --- dev/incubator/beam/KEYS

incubator-beam git commit: [maven-release-plugin] prepare branch release-0.3.0-incubating

mit/c26b63ba Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c26b63ba Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c26b63ba Branch: refs/heads/master Commit: c26b63baecde9105d32e3ba03874eb782162ecda Parents: 69ae8bd Author: Aljoscha Krettek Authored: Mon Oct 24 17:36

incubator-beam git commit: [maven-release-plugin] prepare for next development iteration

mit/8dfadbf0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8dfadbf0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8dfadbf0 Branch: refs/heads/master Commit: 8dfadbf01acc4fed6f604fe531e87730bab2b2bc Parents: c26b63b Author: Aljoscha Krettek Authored: Mon Oct 24 17:36

[incubator-beam] Git Push Summary

Repository: incubator-beam Updated Branches: refs/heads/release-0.3.0-incubating [created] c26b63bae

incubator-beam git commit: [maven-release-plugin] prepare release v0.3.0-incubating-RC1

tor-beam/commit/7a9ce4a4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7a9ce4a4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7a9ce4a4 Branch: refs/heads/release-0.3.0-incubating Commit: 7a9ce4a40e39b8afd66039434607c7cb2c0df4eb Parents: c26b63b Author: Aljos

incubator-beam git commit: [maven-release-plugin] rollback changes from release preparation of v0.3.0-incubating-RC1

nts: 7a9ce4a Author: Aljoscha Krettek Authored: Mon Oct 24 18:54:22 2016 +0200 Committer: Aljoscha Krettek Committed: Mon Oct 24 18:54:22 2016 +0200 -- examples/java/pom.xml | 2 +- examples/java8/pom.

[incubator-beam] Git Push Summary

Repository: incubator-beam Updated Tags: refs/tags/v0.3.0-incubating-RC1 [created] 47447b7e0

incubator-beam git commit: Manually change archetype versions to 0.3.0-incubating [Forced Update!]

hor: Aljoscha Krettek Authored: Mon Oct 24 21:04:37 2016 +0200 Committer: Aljoscha Krettek Committed: Mon Oct 24 21:04:37 2016 +0200 -- .../examples/src/main/resources/archetype-resources/pom.xml | 8 .../starter/src/m

incubator-beam git commit: [maven-release-plugin] prepare release v0.3.0-incubating-RC1

tor-beam/commit/564bbcc4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/564bbcc4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/564bbcc4 Branch: refs/heads/release-0.3.0-incubating Commit: 564bbcc4bc0ef12933302fa3e63c6942d4ee94dc Parents: e2d8a62 Author: Aljos

[incubator-beam] Git Push Summary

Repository: incubator-beam Updated Tags: refs/tags/v0.3.0-incubating-RC1 [deleted] 47447b7e0

[incubator-beam] Git Push Summary [forced push!] [Forced Update!]

Repository: incubator-beam Updated Branches: refs/heads/release-0.3.0-incubating 564bbcc4b -> e2d8a62e3 (forced update)

incubator-beam git commit: [maven-release-plugin] prepare release v0.3.0-incubating-RC1

tor-beam/commit/a4985be4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a4985be4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a4985be4 Branch: refs/heads/release-0.3.0-incubating Commit: a4985be4a2ba7a6780e8f637d313518add8b2c11 Parents: e2d8a62 Author: Aljos

[incubator-beam] Git Push Summary

Repository: incubator-beam Updated Tags: refs/tags/v0.3.0-incubating-RC1 [created] 5d86ff7f0

incubator-beam git commit: [maven-release-plugin] rollback changes from release preparation of v0.3.0-incubating-RC1

nts: a4985be Author: Aljoscha Krettek Authored: Mon Oct 24 21:45:25 2016 +0200 Committer: Aljoscha Krettek Committed: Mon Oct 24 21:45:25 2016 +0200 -- examples/java/pom.xml | 2 +- examples/java8/pom.

svn commit: r16664 - /dev/incubator/beam/0.3.0-incubating/

Author: aljoscha Date: Mon Oct 24 20:48:49 2016 New Revision: 16664 Log: Add Apache Beam 0.3.0-incubating RC1 Files Added: dev/incubator/beam/0.3.0-incubating/ dev/incubator/beam/0.3.0-incubating/apache-beam-0.3.0-incubating-source-release.zip (with props) dev/incubator/beam

[GitHub] incubator-beam-site pull request #52: Add pointers to 0.3.0-incubating relea...

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam-site/pull/52 Add pointers to 0.3.0-incubating release artifacts You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/incubator-beam-site

[GitHub] incubator-beam pull request #1207: Fix Failing Flink RunnableOnService Tests

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam/pull/1207 Fix Failing Flink RunnableOnService Tests The problem was that the DoFnInvoker was invoking createAggregatorForDoFn in the AggregatorFactory several times and Flink only allows

[1/2] incubator-beam git commit: [BEAM-862] Make Aggregator Creation Idempotent

ttp://git-wip-us.apache.org/repos/asf/incubator-beam/diff/837bb2b7 Branch: refs/heads/master Commit: 837bb2b71e515c9170fa2c031c86a618b085b249 Parents: e82c5d2 Author: Aljoscha Krettek Authored: Thu Oct 27 15:31:20 2016 +0200 Committer: Aljoscha Krettek Committed: Fri Oct 28 22:48:04 2016 +0

[2/2] incubator-beam git commit: This closes #1207

-beam/diff/beccdc68 Branch: refs/heads/master Commit: beccdc6867a5e6bb2517bc4cb31c0cbee202beac Parents: e82c5d2 837bb2b Author: Aljoscha Krettek Authored: Fri Oct 28 22:48:34 2016 +0200 Committer: Aljoscha Krettek Committed: Fri Oct 28 22:48:34 2016 +0200

[GitHub] incubator-beam-site pull request #57: Some additions to the Release Guide

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam-site/pull/57 Some additions to the Release Guide You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/incubator-beam-site update-release

svn commit: r16746 - /release/incubator/beam/0.3.0-incubating/

Author: aljoscha Date: Mon Oct 31 13:37:28 2016 New Revision: 16746 Log: Add Beam 0.3.0-incubating release artifacts Added: release/incubator/beam/0.3.0-incubating/ release/incubator/beam/0.3.0-incubating/apache-beam-0.3.0-incubating-source-release.zip (with props) release

[incubator-beam] Git Push Summary

Repository: incubator-beam Updated Tags: refs/tags/v0.3.0-incubating [created] fb7f162ab

[01/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site c60d96902 -> 141627ec4 http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/options/DataflowPipelineWorkerPoolOptions.TeardownPo

[09/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/DataflowPipelineRegistrar.Runner.html -- diff --git a/content/learn/sdks/javadoc

[24/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/DefaultTriggerStateMachine.html -- diff --git a/content/learn/sdks/javadoc/

[12/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/package-tree.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubati

[20/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html -- diff --git a/content/learn/sdks/

[30/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/class-use/UnboundedReadFromBoundedSource.BoundedToUnboundedSourceAdapter.html -- diff

[08/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html -- diff --git a/content/learn

[23/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/FinishedTriggersBitSet.html -- diff --git a/content/learn/sdks/javadoc/0.3.

[05/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/class-use/DataflowPipelineTranslator.TranslationContext.html -- diff --git a/con

[17/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/class-use/AfterPaneStateMachine.html -- diff --git a/content/learn/sdks/jav

[15/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/class-use/RepeatedlyStateMachine.html -- diff --git a/content/learn/sdks/ja

[06/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/class-use/DataflowJobException.html -- diff --git a/content/learn/sdks/javadoc/0

[50/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/contribute/contribution-guide/index.html -- diff --git a/content/contribute/contribution-guide/index.html b/content/contribute/contribution-guide/ind

[38/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/PaneInfoTracker.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/org

[10/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/DataflowJobUpdatedException.html -- diff --git a/content/learn/sdks/javadoc/0.3.

[44/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

0-incubating/options -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/options b/content/learn/sdks/javadoc/0.3.0-incubating/options new file mode 100644 index 000..746f61f --- /dev/null +++ b/content/learn/sdks/javadoc/0.3.0-

[43/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/DoFnRunner.ReduceFnExecutor.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-in

[40/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/GroupAlsoByWindowsViaOutputBufferDoFn.html -- diff --git a/content/learn/sdks/javado

[34/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/UnboundedReadFromBoundedSource.BoundedToUnboundedSourceAdapter.html -- diff --git a/

[07/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/DataflowRunner.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/

[25/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.AfterWatermarkEarlyAndLate.html -- diff --git a/

[46/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/deprecated-list.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/deprecated-list.html b/content/l

[28/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.html -- diff --git a/content/learn/s

[22/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/RepeatedlyStateMachine.html -- diff --git a/content/learn/sdks/javadoc/0.3.

[26/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/AfterPaneStateMachine.html -- diff --git a/content/learn/sdks/javadoc/0.3.0

[36/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/ReduceFnRunner.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/org/

[32/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/class-use/GBKIntoKeyedWorkItems.html -- diff --git a/content/learn/sdks/javadoc/0.3.

[13/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/class-use/TriggerStateMachine.html -- diff --git a/content/learn/sdks/javad

[11/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/DataflowJobAlreadyUpdatedException.html -- diff --git a/content/learn/sdks/javad

[02/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/options/DataflowPipelineOptions.html -- diff --git a/content/learn/sdks/javadoc/

[16/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/class-use/ExecutableTriggerStateMachine.html -- diff --git a/content/learn/

[39/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/GroupByKeyViaGroupByKeyOnly.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-in

[27/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/AfterEachStateMachine.html -- diff --git a/content/learn/sdks/javadoc/0.3.0

[47/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/constant-values.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/constant-values.html b/content/l

[45/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/index-all.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/index-all.html b/content/learn/sdks/ja

[48/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/allclasses-noframe.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/allclasses-noframe.html b/co

[35/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/SplittableParDo.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/org

[04/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/options/CloudDebuggerOptions.html -- diff --git a/content/learn/sdks/javadoc/0.3

[41/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/GroupAlsoByWindowViaWindowSetDoFn.html -- diff --git a/content/learn/sdks/javadoc/0.

[19/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/TriggerStateMachine.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-i

[51/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

/incubator-beam-site/diff/141627ec Branch: refs/heads/asf-site Commit: 141627ec4b6e57589deac52b284dcd4ed542e399 Parents: 1841a9a Author: Aljoscha Krettek Authored: Mon Oct 31 17:18:16 2016 +0100 Committer: Aljoscha Krettek Committed: Mon Oct 31 17:18:26 2016 +0100

[29/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/AfterAllStateMachine.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-

[18/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/TriggerStateMachineRunner.html -- diff --git a/content/learn/sdks/javadoc/0

[21/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/TriggerStateMachine.OnElementContext.html -- diff --git a/content/learn/sdk

[31/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/class-use/ReduceFn.Context.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-inc

[14/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/class-use/TriggerStateMachine.OnceTriggerStateMachine.html -- diff --git a/

[03/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/options/DataflowPipelineDebugOptions.html -- diff --git a/content/learn/sdks/jav

[33/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/class-use/DoFnRunner.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubatin

[42/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/ElementAndRestriction.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubati

[49/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/allclasses-frame.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/allclasses-frame.html b/content

[37/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/ReduceFn.OnMergeContext.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incuba

[GitHub] incubator-beam pull request #1311: [BEAM-931] Fix Findbugs Warnings in Flink...

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam/pull/1311 [BEAM-931] Fix Findbugs Warnings in Flink Runner I manually checked via `mvn findbugs:check`. This is not currently activated in the pre-commit hook, is it? R: @dhalperi You

[GitHub] incubator-beam pull request #1311: [BEAM-931] Fix Findbugs Warnings in Flink...

Github user aljoscha closed the pull request at: https://github.com/apache/incubator-beam/pull/1311 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[1/2] incubator-beam git commit: [BEAM-931] Fix Findbugs Warnings in Flink Runner

ttp://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a609a19e Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a609a19e Branch: refs/heads/master Commit: a609a19e6df763c0aa77d83f05e21ec343f6dcdb Parents: ef750c0 Author: Aljoscha Krettek Authored: Tue Nov 8 11:56:45 2016 +0

[2/2] incubator-beam git commit: This closes #1311

-beam/diff/66faf74d Branch: refs/heads/master Commit: 66faf74d084e4eba982063c9ca81673b0cfece4b Parents: ef750c0 a609a19 Author: Aljoscha Krettek Authored: Thu Nov 10 10:37:46 2016 +0100 Committer: Aljoscha Krettek Committed: Thu Nov 10 10:37:46 2016 +0100

[2/2] incubator-beam git commit: This closes #1333

-beam/diff/8daa8b51 Branch: refs/heads/master Commit: 8daa8b519fe5b2f3286c3f592a26841a374c057c Parents: 66faf74 d8f3da6 Author: Aljoscha Krettek Authored: Thu Nov 10 15:47:59 2016 +0100 Committer: Aljoscha Krettek Committed: Thu Nov 10 15:47:59 2016 +0100

[1/2] incubator-beam git commit: Remove Leftover Sysout Printing in Flink Runner

400 Committer: Aljoscha Krettek Committed: Thu Nov 10 15:47:15 2016 +0100 -- .../flink/translation/FlinkStreamingTransformTranslators.java | 2 -- 1 file changed, 2 deleti

[GitHub] incubator-beam pull request #1352: [BEAM-965] Set Correct Output Type on Sou...

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam/pull/1352 [BEAM-965] Set Correct Output Type on Sources in Flink Stream Runner R: @mxm You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha

[GitHub] incubator-beam-site pull request #79: [BEAM-899] Add Flink Instructions to q...

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam-site/pull/79 [BEAM-899] Add Flink Instructions to quickstart.md I added a section about runner specific dependencies in the Quickstart. R: @francesperry You can merge this pull request

[1/2] incubator-beam git commit: [BEAM-965] Set Correct Output Type on Sources in Flink Stream Runner

mit/a61832a8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a61832a8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a61832a8 Branch: refs/heads/master Commit: a61832a83c15e0aa5e3cc1985fc32aa1afb348e6 Parents: 8bfa085 Author: Aljoscha Krettek Authored: Fri Nov 11

[2/2] incubator-beam git commit: This closes #1352

-beam/diff/ee55f6e3 Branch: refs/heads/master Commit: ee55f6e39ff429cd406835c789ce89c4b01fb4c4 Parents: 8bfa085 a61832a Author: Aljoscha Krettek Authored: Mon Nov 14 22:07:53 2016 +0100 Committer: Aljoscha Krettek Committed: Mon Nov 14 22:07:53 2016 +0100

[GitHub] incubator-beam pull request #883: Address comments of Flink Side-Input PR

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam/pull/883 Address comments of Flink Side-Input PR R: @mxm You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/incubator-beam flink-fixes

[GitHub] incubator-beam pull request #883: Address comments of Flink Side-Input PR

Github user aljoscha closed the pull request at: https://github.com/apache/incubator-beam/pull/883 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[1/2] incubator-beam git commit: Address comments of Flink Side-Input PR

wip-us.apache.org/repos/asf/incubator-beam/tree/cae96380 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/cae96380 Branch: refs/heads/master Commit: cae96380f15fc293d00b444148e5d08c3f14d909 Parents: 33d747e Author: Aljoscha Krettek Authored: Thu Aug 25 11:00:39 2016 +0200 Commit

  1   2   3   >