[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 counting

[GitHub] incubator-beam pull request: Update .travis.yml

GitHub user davorbonaci opened a pull request: https://github.com/apache/incubator-beam/pull/27 Update .travis.yml Revert "mvn verify" back to "mvn install" since it breaks the followup script. You can merge this pull request into a Git repository by running: $ git pull https:

[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 repositor

[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 feature

[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/25 Update sdk pregenerated protos to 0.5.160304 Newest version only contains generated protobuf code for Beam You can merge this pull request into a Git repository by running: $ git pull ht

[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

[2/3] incubator-beam git commit: [BEAM-95] Use snappy compression on objects serialized via SerializableUtils

[BEAM-95] Use snappy compression on objects serialized via SerializableUtils Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/aa1d7e5d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/aa1d7e5d

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

This closes #24 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bf15d2f3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bf15d2f3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/d

[GitHub] incubator-beam pull request: Upgrade mockito to 1.10.19

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

[1/2] incubator-beam git commit: Upgrade mockito to 1.10.19

Repository: incubator-beam Updated Branches: refs/heads/master 9be294458 -> bf15d2f3c Upgrade mockito to 1.10.19 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/65deff3a Tree: http://git-wip-us.apache.org

[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&focusedCommentId=15180735#comment-15180735 ] ASF GitHub Bot commented on BEAM-95: Github user asfgit closed the pull request at:

[3/3] incubator-beam git commit: Closes #22

Closes #22 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9be29445 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9be29445 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9

[1/3] incubator-beam git commit: [BEAM-95] Add dependency explicitly to SDK pom

Repository: incubator-beam Updated Branches: refs/heads/master 5fe73eee2 -> 9be294458 [BEAM-95] Add dependency explicitly to SDK pom Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a0f08bef Tree: http://g

[jira] [Created] (BEAM-97) Input watermarks can never be null

Mark Shields created BEAM-97: Summary: Input watermarks can never be null Key: BEAM-97 URL: https://issues.apache.org/jira/browse/BEAM-97 Project: Beam Issue Type: Bug Components: sdk-j

[GitHub] incubator-beam pull request: Upgrade mockito to 1.10.19

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/24 Upgrade mockito to 1.10.19 R: @davorbonaci You can merge this pull request into a Git repository by running: $ git pull https://github.com/peihe/incubator-beam upgrade-mockito Alternativ

[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&focusedCommentId=15180626#comment-15180626 ] ASF GitHub Bot commented on BEAM-96: GitHub user peihe opened a pull request: https:

[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] [Commented] (BEAM-96) Support composing combine functions

[ https://issues.apache.org/jira/browse/BEAM-96?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15180622#comment-15180622 ] Pei He commented on BEAM-96: Davor, please assign this issue to me. > Support composing combine

[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: sdk-java

[1/2] incubator-beam git commit: Fix malformatted @links in javadoc comments

Repository: incubator-beam Updated Branches: refs/heads/master 419b6f4ae -> 5fe73eee2 Fix malformatted @links in javadoc comments Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b8250d1b Tree: http://git-

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

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

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

This closes #21 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5fe73eee Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5fe73eee Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/d

[GitHub] incubator-beam pull request: BigtableIO.Read: use PBegin, rather t...

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

[1/2] incubator-beam git commit: BigtableIO.Read: use PBegin, rather than PInput

Repository: incubator-beam Updated Branches: refs/heads/master 4da935b65 -> 419b6f4ae BigtableIO.Read: use PBegin, rather than PInput Sources should start from the beginning of a pipeline. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.or

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

This closes #18 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/419b6f4a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/419b6f4a Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/d

[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&focusedCommentId=15180435#comment-15180435 ] Luke Cwik commented on BEAM-76: --- What if instead of a FileBasedSource taking a list of files/gl

[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&focusedCommentId=15180304#comment-15180304 ] ASF GitHub Bot commented on BEAM-95: GitHub user lukecwik opened a pull request: htt

[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 https://github.c

[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: http://git-wip-us.apache.org/repos/asf/incubator-

[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&focusedCommentId=15180284#comment-15180284 ] ASF GitHub Bot commented on BEAM-5: --- Github user asfgit closed the pull request at: htt

[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: http://git-wip-us.apache.org/repos/asf/i

[29/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/com/dataartisans/flink/dataflow/translation/FlinkStreamingTranslationContext.java -- diff --git a/runners/flink/src/main/java/com/data

[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: http://git-wip-us.apache.org/rep

[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 a/runners/flink/src/main/jav

[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 a/runners/flink/src/

[32/50] [abbrv] incubator-beam git commit: [travis] install snapshot version of SDK before running CI

[travis] install snapshot version of SDK before running CI Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c6630b90 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c6630b90 Diff: http://git-w

[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 a/runners/flink/src/main/java/org/apache/beam/runners/flink/examples/T

[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 a/runners/flink/src/main/java/org/

[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: http://git-wip-us.apache.org

[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: http://git-wip-us.apache.org/repos/asf/i

[22/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/state/FlinkStateInternals.java -- diff --git a/runners/flink/src/main/jav

[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: http://git-wip-us.apache.org/repos/asf/incubator-be

[03/50] [abbrv] incubator-beam git commit: [readme] add hint on how to submit jar to cluster

[readme] add hint on how to submit jar to cluster Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/517c1bd2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/517c1bd2 Diff: http://git-wip-us.apa

[27/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/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/AbstractFlinkTimerInternals.java -- diff --git a/runners/flink/sr

[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 a/runners/flink/src/main/j

[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: http://git-wip-us.apa

[25/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/FlinkBatchTransformTranslators.java -- diff --git a/runners/flink/src/main/java/org/apache/b

[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 a/runners/flink/src/test/java/org/apache/beam/runners/flink/Mayb

[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: http://git-wip-us.apache.org/repos/asf

[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 a/runners/flink/src/main

[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 a/runners/flink/src/test/java/com/dataartisans/flink/dataflow/

[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 a/runners/flink/src/main/java/com/dataarti

[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 a/runners/flink/src/main/java/com/dataartisans/fli

[28/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/com/dataartisans/flink/dataflow/translation/wrappers/SinkOutputFormat.java -- diff --git a/runners/flink/src/main/java/com/dataartisan

[30/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/com/dataartisans/flink/dataflow/examples/streaming/KafkaWindowedWordCountExample.java -- diff --git a/runners/flink/src/main/java/com/

[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: http://git-wip-us.

[07/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/FlinkBatchTransformTranslators.java -- diff --git a/runners/flink/src/main/java/com/dataar

[42/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/io/UnboundedSocketSource.java -- diff --git a/runners/flink/src/main/ja

[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: http://git-wip-us.apache.org/r

[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: http://git-wip-us.apache.org/repos/

[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 a/runners/flink/src/test/java/com/dataartisans

[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 a/runners/flink/src/test/java/com/dataartisans/flin

[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 a/runners/flink/src/main/java

[40/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/GroupAlsoByWindowTest.java -- diff --git a/runners/flink/src/test/java/com/dataartisans/flin

[46/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/examples/streaming/JoinExamples.java -- diff --git a/runners/flink/src/main/java/com/dataartisans/flin

[16/50] [abbrv] incubator-beam git commit: Rearranging the code and renaming certain classes.

Rearranging the code and renaming certain classes. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bc4c60eb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bc4c60eb Diff: http://git-wip-us.ap

[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: http://git-wip-us.apache.org/repos/asf/in

[02/50] [abbrv] incubator-beam git commit: [sink] generate unique id for writer initialization

[sink] generate unique id for writer initialization Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/336d394e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/336d394e Diff: http://git-wip-us.a

[19/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/streaming/StateSerializationTest.java -- diff --git a/runners/flink/src/test/java/org/apache/beam/runner

[34/50] [abbrv] incubator-beam git commit: [tests] suppress unnecessary log output

[tests] suppress unnecessary log output Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/dc7786f3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/dc7786f3 Diff: http://git-wip-us.apache.org/re

[10/50] [abbrv] incubator-beam git commit: [readme] update to reflect the current state

[readme] update to reflect the current state Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/70ae13c7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/70ae13c7 Diff: http://git-wip-us.apache.o

[33/50] [abbrv] incubator-beam git commit: Fixes the GroupAlsoByWindowTest.

Fixes the GroupAlsoByWindowTest. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/52614ea3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/52614ea3 Diff: http://git-wip-us.apache.org/repos/asf

[50/50] [abbrv] incubator-beam git commit: This closes #12

This closes #12 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4da935b6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4da935b6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/d

[35/50] [abbrv] incubator-beam git commit: [maven] add project for Runners

[maven] add project for Runners Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/730f092c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/730f092c Diff: http://git-wip-us.apache.org/repos/asf/

[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: http://git-wip-us

[17/50] [abbrv] incubator-beam git commit: Adds javadocs.

Adds javadocs. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/067837fa Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/067837fa Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/di

[06/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/FlinkTransformTranslators.java -- diff --git a/runners/flink/src/main/java/com/dataartisan

[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: http://git-wip-us.apache.org/repos/asf/incubator-be

[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 Tree

[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 Alt