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
