Fix schema match (#131)

trustgraph-parquet/trustgraph/dump/triples/parquet/processor.py

@@ -9,7 +9,7 @@
 import argparse
 import time
 
-from .... schema import Triple
+from .... schema import Triples
 from .... schema import triples_store_queue
 from .... base import Consumer
 
@@ -38,7 +38,7 @@ def __init__(self, **params):
             **params | {
                 "input_queue": input_queue,
                 "subscriber": subscriber,
-                "input_schema": Triple,
+                "input_schema": Triples,
             }
         )
 
@@ -51,7 +51,9 @@ def __del__(self):
     def handle(self, msg):
 
         v = msg.value()
-        self.writer.write(v.s.value, v.p.value, v.o.value)
+
+        for t in v.triples:
+            self.writer.write(t.s.value, t.p.value, t.o.value)
 
     @staticmethod
     def add_args(parser):