could you show the example code of redis query with PCollection? 2016-11-21 16:41 GMT+08:00 Jean-Baptiste Onofré <[email protected]>:
> Hi, > > you can convert your PCollection<KV<?,?>> to a PCollection<POJO> and then > create a DoFn to do the query. > > By the way, I have a RedisIO mostly ready. > > Regards > JB > > > On 11/21/2016 09:14 AM, 陈竞 wrote: > >> my dataflow case is like that: >> stream: >> a stream want to query some data from redis with a key, >> >> batch: >> a table left join another table in with a key >> >> i want to unify the two sence above by a transform like MapJoin, so i >> need to use >> PCollection to represent the data in redis, but the question is that >> PCollection has no interface to make PCollection queryable, so is there >> any solution for my case? >> > > -- > Jean-Baptiste Onofré > [email protected] > http://blog.nanthrax.net > Talend - http://www.talend.com > -- 陈竞，中科院计算技术研究所，高性能计算机中心 Jing Chen HPCC.ICT.AC China
