Review Request 33146: Adding a new KV store contract: BatchingKeyValueStore

2015-04-13 Thread Mohamed Mahmoud (El-Geish)
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33146/ --- Review request for samza. Bugs: SAMZA-647 https://issues.apache.org/jira/br

Review Request 33142: [SAMZA-561] Review in progress

2015-04-13 Thread Yi Pan (Data Infrastructure)
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33142/ --- Review request for samza and Milinda Pathirage. Bugs: SAMZA-561 https://iss

Re: Joining Avro records

2015-04-13 Thread Roger Hoover
Hi all, In case this helps anyone, I was able to create a simple class to do the join and it works nicely for my use case. It assumes you have schema for the input and output records. Example ( https://github.com/Quantiply/rico/blob/master/avro-serde/src/test/java/com/quantiply/avro/JoinTest.jav

Re: Joining Avro records

2015-04-13 Thread Julian Hyde
I think using nested fields would be a mistake. In SQL, you have two namespaces when joining two tables (or N namespaces when joining N tables), but what outputs the query is a flat namespace. For example: select emp.name from ( select emp.*, dept.* from emp join dept on emp.deptno