import parquet
import json
import logging

## assuming parquet file with two rows and three columns:
## foo bar baz
## 1   2   3
## 4   5   6

#logging.basicConfig(level=logging.DEBUG)
logging.basicConfig(level=logging.DEBUG,  
                    format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s',  
                    datefmt='%a, %d %b %Y %H:%M:%S',
                    filename='/tmp/test.log',  
                    filemode='w+') 
logger = logging.getLogger("parquet")  # pylint: disable=invalid-name
with open("/tmp/tb/000000_0", "rb+") as fo:
# prints:
# {"foo": 1, "bar": 2}
# {"foo": 4, "bar": 5}
    #for row in parquet.DictReader(fo, columns=['name']):
#with open("/home/sqm/parquet-python/test-data/nation.dict.parquet") as fo:
    for row in parquet.DictReader(fo):
        print(json.dumps(row))

'''
with open("test.parquet") as fo:
# prints:
# 1,2
# 4,5
for row in parquet.reader(fo, columns=['foo', 'bar]):
    print(",".join([str(r) for r in row]))
'''