parquet

import parquet import json import os # Create a dummy Parquet file for demonstration # This library only supports reading, so we'll simulate a file. # In a real scenario, you'd have an existing .parquet file. # For demonstration, we'll write a simple text file # and ask the user to manually create a test.parquet file # since this library does not support writing. # You would replace 'test.parquet' with your actual file. print("This library is read-only. Please ensure 'test.parquet' exists.") print("Example content (replace with actual Parquet data):") print("## foo bar baz\n## 1 2 3\n## 4 5 6") # Assuming a 'test.parquet' file exists with data: # {'foo': 1, 'bar': 2, 'baz': 3} # {'foo': 4, 'bar': 5, 'baz': 6} try: with open("test.parquet", "rb") as fo: print("\nReading 'test.parquet' with DictReader (columns 'foo', 'bar'):") for row in parquet.DictReader(fo, columns=['foo', 'bar']): print(json.dumps(row)) with open("test.parquet", "rb") as fo: print("\nReading 'test.parquet' with reader (columns 'foo', 'bar'):") for row in parquet.reader(fo, columns=['foo', 'bar']): print(",".join([str(r) for r in row])) except FileNotFoundError: print("Error: 'test.parquet' not found. Please create one for testing.") except Exception as e: print(f"An error occurred: {e}")