ฉันมีสคริปต์ที่ใช้วัตถุ json ที่ซับซ้อน (หนึ่งรายการต่อบรรทัด) ในอินพุตและเอาต์พุตในรูปแบบ hadoc ฉันต้องการใช้ pig เพื่อสตรีมข้อมูลบางอย่างผ่านสคริปต์นี้โดยใช้ STREAM ฉันจะบังคับให้ Pig ส่งข้อมูลไปยังสตรีมมิ่งในรูปแบบ json ได้อย่างไร ฉันกำลังมองหาบางอย่างเช่น
C = stream A through `stream.py` USING JsonStorage()
