Re: Introduction

Welcome aboard !! Looking for your contributions ! Regards JB On 02/27/2017 11:51 PM, Roberto Bentivoglio wrote: Hi Everyone, I am a big fan of distributed streaming engine and I'm currently working at Radicalbit. My colleagues and I are planning to start to contribute actively on Beam in

RE: Enforcer Rule- JDK1.7 for Beam

Sure , I am going to investigate this. Will update the thread shortly. -Original Message- From: Dan Halperin [mailto:dhalp...@google.com.INVALID] Sent: Monday, February 27, 2017 11:32 PM To: dev@beam.apache.org Subject: Re: Enforcer Rule- JDK1.7 for Beam I think there are a few

Re: Release 0.6.0

+1 On Mon, Feb 27, 2017 at 3:28 PM, Dan Halperin wrote: > Sounds great to me! > > On Mon, Feb 27, 2017 at 2:10 PM, Sourabh Bajaj < > sourabhba...@google.com.invalid> wrote: > > > +1 for the new release > > > > On Mon, Feb 27, 2017 at 2:06 PM Davor Bonaci

Re: tf.Transform library for using TensorFlow with Beam

The Beam portability framework will enable this in Java too; not sure we can do much sooner than that! On Fri, Feb 24, 2017 at 3:33 PM, Amit Sela wrote: > That's great! many people have asked me about that and I'm glad to see this > happening. > Anyone know if there's

Re: Release 0.6.0

+1 for the new release On Mon, Feb 27, 2017 at 2:06 PM Davor Bonaci wrote: > +1 -- let's get it started! > > On Mon, Feb 27, 2017 at 2:01 PM, Ahmet Altay > wrote: > > > Hi all, > > > > It's been about a month since the last release. I would like

Release 0.6.0

Hi all, It's been about a month since the last release. I would like propose starting the next release. There are no releasing blocking bugs in JIRA [1]. Are there any release blocking issues I am missing? Unless there is an objection I will volunteer to manage this release. This will be the

[BEAM-301] Add a Beam SQL DSL

Hello all, Would like to pop up this task, to see any interest to move it forward. I've a project to run SQL queries with an interactive interface, and would like to share my ideas. A draft doc is available to describe how it works with Calcite. --A little different from BEAM-301, that I choose

Re: Adding to the Contributor List

Done Regards JB On 02/27/2017 06:17 PM, Neelesh Salian wrote: Thanks JB. On Mon, Feb 27, 2017 at 9:14 AM, Jean-Baptiste Onofré wrote: Hi Neelesh, sure, I will update. Regards JB On 02/27/2017 06:08 PM, Neelesh Salian wrote: Hi, Had to change my username due to

Re: Adding to the Contributor List

Thanks JB. On Mon, Feb 27, 2017 at 9:14 AM, Jean-Baptiste Onofré wrote: > Hi Neelesh, > > sure, I will update. > > Regards > JB > > On 02/27/2017 06:08 PM, Neelesh Salian wrote: > >> Hi, >> >> Had to change my username due to email issues. >> Could someone please add my

Enforcer Rule- JDK1.7 for Beam

Hi all, While working on HadoopInputFormatIO, when I rebased my code to fetch the latest from Beam repo, I see an Enforcer rule added to the parent POM to ensure that all dependencies used are compliant with JDK 1.7 I have written tests for Cassandra and Elasticsearch to test if HIFIO works ok

[DISCUSS] Per-Key Watermark Maintenance

We recently started a discussion on the Flink ML about this topic: [1] The gist of it is that for some use cases tracking the watermark per-key instead of globally (or rather per partition) can be useful for some cases. Think, for example, of tracking some user data off mobile phones where the

Re: Flink Runner with Flink 1.2

Hi, I'm afraid you'll have to either use master or wait until the 0.6 release. We're currently releasing quite frequently, though, so that shouldn't take to long. Best, Aljoscha On Sun, 26 Feb 2017 at 23:31 Sathya Hariesh Prakash (sathypra) < sathy...@cisco.com> wrote: > Hi Guys – We are in