I have just started using avro as a new logging system. I have able to successfully create avro logs & import them into HDFS. I now need to run these avro logs thru a map reduce job written in python using hadoop streaming. Can some give me an example of how to do that? Thanks, Mona