fixed #71

Author: mgeipel

src/main/java/org/culturegraph/mf/stream/pipe/sort/TripleCollect.java

@@ -35,22 +35,21 @@
 @In(Triple.class)
 @Out(StreamReceiver.class)
 public final class TripleCollect extends DefaultObjectPipe<Triple, StreamReceiver> {
-	private final FormetaParser parser = new FormetaParser();
-	private final PartialRecordEmitter emitter = new PartialRecordEmitter();
-	
+
 	private String currentSubject;
+	private final PartialRecordEmitter emitter = new PartialRecordEmitter();
+	private final FormetaParser parser = new FormetaParser();
 
 	public TripleCollect() {
 		parser.setEmitter(emitter);
 	}
-
+	
 	@Override
 	public void process(final Triple triple) {
 		if (currentSubject == null) {
 			currentSubject = triple.getSubject();
 			getReceiver().startRecord(currentSubject);
 		}
-		
 		if (currentSubject.equals(triple.getSubject())) {
 			decodeTriple(triple);
 		} else {
@@ -61,14 +60,14 @@ public void process(final Triple triple) {
 		}
 	}
 
-	public void decodeTriple(final Triple triple) {
+	private void decodeTriple(final Triple triple) {
 		if(triple.getObjectType() == ObjectType.STRING){
 			getReceiver().literal(triple.getPredicate(), triple.getObject());
-		}else if (triple.getObjectType() == ObjectType.ENTITY){
+		}else{
+			//getReceiver().startEntity(triple.getPredicate());
 			emitter.setDefaultName(triple.getPredicate());
 			parser.parse(triple.getObject());
-		}else{
-			throw new UnsupportedOperationException(triple.getObjectType() + " can not yet be decoded");
+			//getReceiver().endEntity();
 		}
 	}