Re: [PROPOSAL] Connectors for memcache and Couchbase

2017-07-23 Thread Jean-Baptiste Onofré
Seshadri >> > >> > -Original Message----- >> > From: Eugene Kirpichov [mailto:kirpic...@google.com.INVALID] >> > Sent: Thursday, July 20, 2017 5:05 PM >> > To: dev@beam.apache.org >> > Subject: Re: [PROPOSAL] Connectors for memcache and Co

Re: [PROPOSAL] Connectors for memcache and Couchbase

2017-07-23 Thread Lukasz Cwik
t; wrote: > > > Yes, that is correct ! > > > > Regards, > > Seshadri > > > > -Original Message- > > From: Eugene Kirpichov [mailto:kirpic...@google.com.INVALID] > > Sent: Thursday, July 20, 2017 5:05 PM > > To: dev@beam.apache.org > >

Re: [PROPOSAL] Connectors for memcache and Couchbase

2017-07-21 Thread Madhusudan Borkar
lso please note that key-value set/lookup is what all memcache > > implementations do best, though there are other operations which are > > supported. Hence we feel that key-based read would be the primary use > > case for a memcache IO in Apache Beam. > > > > Consisten

RE: [PROPOSAL] Connectors for memcache and Couchbase

2017-07-20 Thread Seshadri Raghunathan
Yes, that is correct ! Regards, Seshadri -Original Message- From: Eugene Kirpichov [mailto:kirpic...@google.com.INVALID] Sent: Thursday, July 20, 2017 5:05 PM To: dev@beam.apache.org Subject: Re: [PROPOSAL] Connectors for memcache and Couchbase Hi, So, in short, the plan is

Re: [PROPOSAL] Connectors for memcache and Couchbase

2017-07-20 Thread Eugene Kirpichov
n point of time. > > Please let me know your comments, I plan to start developing this once we > have a consensus. > > Regards, > Seshadri > > -Original Message- > From: Ismaël Mejía [mailto:ieme...@gmail.com] > Sent: Tuesday, July 11, 2017 9:54 AM > To: de

RE: [PROPOSAL] Connectors for memcache and Couchbase

2017-07-20 Thread Seshadri Raghunathan
to start developing this once we have a consensus. Regards, Seshadri -Original Message- From: Ismaël Mejía [mailto:ieme...@gmail.com] Sent: Tuesday, July 11, 2017 9:54 AM To: dev@beam.apache.org Subject: Re: [PROPOSAL] Connectors for memcache and Couchbase Hello again, Thanks Luk

Re: [PROPOSAL] Connectors for memcache and Couchbase

2017-07-11 Thread Ismaël Mejía
Hello again, Thanks Lukasz for the details. We will take a look and discuss with the others on how to achieve this. We hadn’t considered the case of a full scan Read (as Eugene mentions) so now your comments about the snapshot make more sense, however I am still wondering if the snapshot is worth

Re: [PROPOSAL] Connectors for memcache and Couchbase

2017-07-10 Thread Eugene Kirpichov
I think Madhusudan's proposal does not involve reading the whole contents of the memcached cluster - it's applied to a PCollection of keys. So I'd suggest to call it MemcachedIO.lookup() rather than MemcachedIO.read(). And it will not involve the questions of splitting - however, it *will* involve

Re: [PROPOSAL] Connectors for memcache and Couchbase

2017-07-10 Thread Lukasz Cwik
Splitting on slabs should allow you to split more finely grained then per server since each server itself maintains this information. If you take a look at the memcached protocol, you can see that lru_crawler supports a metadump command which will enumerate all the key for a set of given slabs or f

Re: [PROPOSAL] Connectors for memcache and Couchbase

2017-07-10 Thread Ismaël Mejía
Hello, Thanks Lukasz for bring some of this subjects. I have briefly discussed with the guys working on this they are the same team who did HCatalogIO (Hive). We just analyzed the different libraries that allowed to develop this integration from Java and decided that the most complete implementat

Re: [PROPOSAL] Connectors for memcache and Couchbase

2017-07-09 Thread Lukasz Cwik
For the source: Do you plan to support enumerating all the keys via cachedump / lru_crawler metadump / ...? If there is an option which doesn't require enumerating the keys, how will splitting be done (no splitting / splitting on slab ids / ...)? Can the cache be read while its still being modified

Re: [PROPOSAL] Connectors for memcache and Couchbase

2017-07-08 Thread Jean-Baptiste Onofré
Hi, Great job ! I'm looking forward for the PRs review. Regards JB On 07/08/2017 09:50 AM, Madhusudan Borkar wrote: Hi, We are proposing to build connectors for memcache first and then use it for Couchbase. The connector for memcache will be build as a IOTransform and then it can be used for

[PROPOSAL] Connectors for memcache and Couchbase

2017-07-08 Thread Madhusudan Borkar
Hi, We are proposing to build connectors for memcache first and then use it for Couchbase. The connector for memcache will be build as a IOTransform and then it can be used for other memcache implementations including Couchbase. 1. As Source input will be a key(String / byte[]), output will be