Re: Issue adding new IO(InfluxDB) with coder in Apache Beam

I'm avialable @ Hangout On Fri, Jun 30, 2017 at 11:25 AM, Jean-Baptiste Onofré wrote: > Thanks, let me paste in an editor and do a review. > > I keep you posted. By the way, are you on Slack or Hangout to chat quickly > ? > > Regards > JB > > > On 06/30/2017 07:46 AM, P. Ramanjaneya Reddy wrote:

Re: Issue adding new IO(InfluxDB) with coder in Apache Beam

Thanks, let me paste in an editor and do a review. I keep you posted. By the way, are you on Slack or Hangout to chat quickly ? Regards JB On 06/30/2017 07:46 AM, P. Ramanjaneya Reddy wrote: Hi JB, Here is complete code for InfluxDB read/write methods, I have followed generic method as other

Re: Issue adding new IO(InfluxDB) with coder in Apache Beam

Hi JB, Here is complete code for InfluxDB read/write methods, I have followed generic method as other IO's. package org.apache.beam.sdk.io.influxdb; import static com.google.common.base.Preconditions.checkArgument; import static com.google.common.base.Preconditions.checkNotNull; import static co

Re: Issue adding new IO(InfluxDB) with coder in Apache Beam

Hi, can you share your code ? I will fix that with you. I suggest to check the expand() method in the read PTransform and the way you use generic there. Any plan to donate this IO: I would be happy to review the PR ! Do you leverage some InfluxDB feature (like splitting/sharding) ? Regards J

Issue adding new IO(InfluxDB) with coder in Apache Beam

Hi Beam Dev, We have developed our own sdk io functions for read/write InfluxDBIO operations in apache BEAM. it is works with default coder, which is StringUtf8Coder.of(). PCollection output = pipeline.apply( InfluxDbIO.read() .withUri("http://localhost:8086";)