[GitHub] incubator-beam pull request: Fixup CountingInputTest.java by addin...

GitHub user davorbonaci opened a pull request: https://github.com/apache/incubator-beam/pull/28 Fixup CountingInputTest.java by adding JUnit version number You can merge this pull request into a Git repository by running: $ git pull https://github.com/davorbonaci/beam

[GitHub] incubator-beam pull request: Update sdk pregenerated protos to 0.5...

GitHub user dpmills opened a pull request: https://github.com/apache/incubator-beam/pull/26 Update sdk pregenerated protos to 0.5.160304 Newest version only contains generated protobuf code for Beam @davorbonaci to review You can merge this pull request into a Git

[GitHub] incubator-beam pull request: Update sdk pregenerated protos to 0.5...

Github user dpmills closed the pull request at: https://github.com/apache/incubator-beam/pull/25 --- 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

[GitHub] incubator-beam pull request: [BEAM-95] Use snappy compression on o...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/22 --- 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 feature

[jira] [Commented] (BEAM-96) Support composing combine functions

[ https://issues.apache.org/jira/browse/BEAM-96?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15180626#comment-15180626 ] ASF GitHub Bot commented on BEAM-96: GitHub user peihe opened a pull request:

[GitHub] incubator-beam pull request: [BEAM-96] Add composed combine functi...

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/23 [BEAM-96] Add composed combine functions builders in CombineFns * compose() or composeKeyed() are used to start composition * with() is used to add an input-transformation, a combine fn and

[jira] [Created] (BEAM-96) Support composing combine functions

Pei He created BEAM-96: -- Summary: Support composing combine functions Key: BEAM-96 URL: https://issues.apache.org/jira/browse/BEAM-96 Project: Beam Issue Type: New Feature Components:

[jira] [Commented] (BEAM-76) FileBasedSource should take a list of files/globs

[ https://issues.apache.org/jira/browse/BEAM-76?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15180435#comment-15180435 ] Luke Cwik commented on BEAM-76: --- What if instead of a FileBasedSource taking a list of files/globs, we support

[jira] [Commented] (BEAM-95) Compress DoFn's / SerializableCoder / ... when serializing objects

[ https://issues.apache.org/jira/browse/BEAM-95?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15180304#comment-15180304 ] ASF GitHub Bot commented on BEAM-95: GitHub user lukecwik opened a pull request:

[GitHub] incubator-beam pull request: [BEAM-95] Use snappy compression on o...

GitHub user lukecwik opened a pull request: https://github.com/apache/incubator-beam/pull/22 [BEAM-95] Use snappy compression on objects serialized via SerializabUtils R: @davorbonaci You can merge this pull request into a Git repository by running: $ git pull

[38/50] [abbrv] incubator-beam git commit: [flink] update README

[flink] update README Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ceb2c87f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ceb2c87f Diff:

[jira] [Commented] (BEAM-5) Import Flink Runner code

[ https://issues.apache.org/jira/browse/BEAM-5?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15180284#comment-15180284 ] ASF GitHub Bot commented on BEAM-5: --- Github user asfgit closed the pull request at:

[jira] [Updated] (BEAM-95) Compress DoFn's / SerializableCoder / ... when serializing objects

[ https://issues.apache.org/jira/browse/BEAM-95?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-95: -- Issue Type: Improvement (was: Bug) > Compress DoFn's / SerializableCoder / ... when serializing objects >

[12/50] [abbrv] incubator-beam git commit: [cleanup] remove obsolete code

[cleanup] remove obsolete code Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f0cb5f07 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f0cb5f07 Diff:

[18/50] [abbrv] incubator-beam git commit: [maven] correct license and formatting

[maven] correct license and formatting Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ea1095af Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ea1095af Diff:

[23/50] [abbrv] incubator-beam git commit: [flink] adjust directories according to package name

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/51bec310/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java -- diff --git

[48/50] [abbrv] incubator-beam git commit: [flink] update license headers

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/28fcfd7a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/AbstractFlinkTimerInternals.java -- diff --git

[26/50] [abbrv] incubator-beam git commit: [flink] adjust directories according to package name

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/51bec310/runners/flink/src/main/java/org/apache/beam/runners/flink/examples/TFIDF.java -- diff --git

[24/50] [abbrv] incubator-beam git commit: [flink] adjust directories according to package name

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/51bec310/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkMultiOutputDoFnFunction.java -- diff --git

[13/50] [abbrv] incubator-beam git commit: [tests] add streaming mode to TestPipeline

[tests] add streaming mode to TestPipeline Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0be42cbf Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0be42cbf Diff:

[49/50] [abbrv] incubator-beam git commit: [flink] update license headers

[flink] update license headers Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/28fcfd7a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/28fcfd7a Diff:

[jira] [Created] (BEAM-95) Compress DoFn's / SerializableCoder / ... when serializing objects

Luke Cwik created BEAM-95: - Summary: Compress DoFn's / SerializableCoder / ... when serializing objects Key: BEAM-95 URL: https://issues.apache.org/jira/browse/BEAM-95 Project: Beam Issue Type: Bug

[37/50] [abbrv] incubator-beam git commit: Fixes Void handling

Fixes Void handling Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a4e9b09f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a4e9b09f Diff:

[43/50] [abbrv] incubator-beam git commit: [flink] convert tabs to 2 spaces

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/8852eb15/runners/flink/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java -- diff --git

[08/50] [abbrv] incubator-beam git commit: [runner] add streaming support with checkpointing

[runner] add streaming support with checkpointing Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/edff0785 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/edff0785 Diff:

[GitHub] incubator-beam pull request: [BEAM-5] Add Flink Runner

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/12 --- 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 feature

[20/50] [abbrv] incubator-beam git commit: [flink] adjust directories according to package name

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/51bec310/runners/flink/src/test/java/org/apache/beam/runners/flink/MaybeEmptyTestITCase.java -- diff --git

[47/50] [abbrv] incubator-beam git commit: [flink] convert tabs to 2 spaces

[flink] convert tabs to 2 spaces Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8852eb15 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8852eb15 Diff:

[41/50] [abbrv] incubator-beam git commit: [flink] convert tabs to 2 spaces

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/8852eb15/runners/flink/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/StateCheckpointWriter.java -- diff --git

[21/50] [abbrv] incubator-beam git commit: [flink] adjust directories according to package name

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/51bec310/runners/flink/src/test/java/com/dataartisans/flink/dataflow/WordCountJoin3ITCase.java -- diff --git

[45/50] [abbrv] incubator-beam git commit: [flink] convert tabs to 2 spaces

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/8852eb15/runners/flink/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkBatchTranslationContext.java -- diff --git

[44/50] [abbrv] incubator-beam git commit: [flink] convert tabs to 2 spaces

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/8852eb15/runners/flink/src/main/java/com/dataartisans/flink/dataflow/translation/functions/UnionCoder.java -- diff --git

[31/50] [abbrv] incubator-beam git commit: [flink] adjust directories according to package name

[flink] adjust directories according to package name Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/51bec310 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/51bec310 Diff:

[15/50] [abbrv] incubator-beam git commit: [tests] integrate Wikipedia session test

[tests] integrate Wikipedia session test Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/37a9b292 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/37a9b292 Diff:

[36/50] [abbrv] incubator-beam git commit: [flink] adjust root pom.xml to Beam

[flink] adjust root pom.xml to Beam Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/39f08fa7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/39f08fa7 Diff:

[39/50] [abbrv] incubator-beam git commit: [flink] convert tabs to 2 spaces

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/8852eb15/runners/flink/src/test/java/com/dataartisans/flink/dataflow/streaming/TopWikipediaSessionsITCase.java -- diff --git

[04/50] [abbrv] incubator-beam git commit: [runner] add streaming support with checkpointing

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/edff0785/runners/flink/src/test/java/com/dataartisans/flink/dataflow/streaming/GroupAlsoByWindowTest.java -- diff --git

[05/50] [abbrv] incubator-beam git commit: [runner] add streaming support with checkpointing

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/edff0785/runners/flink/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupByKeyWrapper.java -- diff --git

[14/50] [abbrv] incubator-beam git commit: [runner] add Create transform

[runner] add Create transform Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3227fccd Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3227fccd Diff:

[09/50] [abbrv] incubator-beam git commit: [readme] add hint that streaming support is available

[readme] add hint that streaming support is available Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8434c3c0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8434c3c0 Diff:

[11/50] [abbrv] incubator-beam git commit: [cleanup] various small improvements

[cleanup] various small improvements - removed duplicate declarations in pom.xml - removed reference to junit.framework.* - removed 'static' from interface declarations Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[01/50] [abbrv] incubator-beam git commit: [readme] add a section on how to submit cluster programs

Repository: incubator-beam Updated Branches: refs/heads/master 052857023 -> 4da935b65 [readme] add a section on how to submit cluster programs Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d7bd7f4e

[GitHub] incubator-beam pull request: Fix malformatted @links in javadoc co...

GitHub user swegner opened a pull request: https://github.com/apache/incubator-beam/pull/21 Fix malformatted @links in javadoc comments You can merge this pull request into a Git repository by running: $ git pull https://github.com/swegner/incubator-beam fix-javadoc-links