Merge branch 'master' of

ssh://[email protected]/culturegraph/metafacture-core.git

Conflicts:
	examples/morph/morph-marc21.flux

Author: mgeipel

src/main/java/org/culturegraph/mf/stream/converter/bib/MabDecoder.java

@@ -20,6 +20,9 @@
 import org.culturegraph.mf.exceptions.FormatException;
 import org.culturegraph.mf.framework.DefaultObjectPipe;
 import org.culturegraph.mf.framework.StreamReceiver;
+import org.culturegraph.mf.framework.annotations.Description;
+import org.culturegraph.mf.framework.annotations.In;
+import org.culturegraph.mf.framework.annotations.Out;
 
 
 /**
@@ -31,6 +34,9 @@
  * @author Markus Michael Geipel, Christoph Böhme
  *
  */
+@Description("Parses a raw Mab2 stream (UTF-8 encoding expected).")
+@In(String.class)
+@Out(StreamReceiver.class)
 public final class MabDecoder 
 		extends DefaultObjectPipe<String, StreamReceiver> {
 

src/main/java/org/culturegraph/mf/stream/converter/bib/MarcDecoder.java

@@ -20,6 +20,9 @@
 import org.culturegraph.mf.exceptions.FormatException;
 import org.culturegraph.mf.framework.DefaultObjectPipe;
 import org.culturegraph.mf.framework.StreamReceiver;
+import org.culturegraph.mf.framework.annotations.Description;
+import org.culturegraph.mf.framework.annotations.In;
+import org.culturegraph.mf.framework.annotations.Out;
 import org.culturegraph.mf.stream.converter.IllegalEncodingException;
 
 
@@ -31,6 +34,9 @@
  * 
  * @author Markus Michael Geipel, Christoph Böhme
  */
+@Description("Parses a raw Marc string (UTF-8 encoding expected).")
+@In(String.class)
+@Out(StreamReceiver.class)
 public final class MarcDecoder 
 		extends DefaultObjectPipe<String, StreamReceiver> {
 

src/main/java/org/culturegraph/mf/stream/pipe/ObjectTee.java

@@ -18,6 +18,9 @@
 import org.culturegraph.mf.framework.DefaultTee;
 import org.culturegraph.mf.framework.ObjectPipe;
 import org.culturegraph.mf.framework.ObjectReceiver;
+import org.culturegraph.mf.framework.annotations.Description;
+import org.culturegraph.mf.framework.annotations.In;
+import org.culturegraph.mf.framework.annotations.Out;
 
 /**
  * Sends an object to more than one receiver.
@@ -27,6 +30,9 @@
  * @author Christoph Böhme
  *
  */
+@Description("Sends an object to more than one receiver.")
+@In(Object.class)
+@Out(Object.class)
 public final class ObjectTee<T> extends DefaultTee<ObjectReceiver<T>>
 		implements ObjectPipe<T, ObjectReceiver<T>> {
 

src/main/java/org/culturegraph/mf/stream/pipe/StreamTee.java

@@ -18,13 +18,19 @@
 import org.culturegraph.mf.framework.DefaultTee;
 import org.culturegraph.mf.framework.StreamPipe;
 import org.culturegraph.mf.framework.StreamReceiver;
+import org.culturegraph.mf.framework.annotations.Description;
+import org.culturegraph.mf.framework.annotations.In;
+import org.culturegraph.mf.framework.annotations.Out;
 
 /**
  * Replicates an event stream to an arbitrary number of {@link StreamReceiver}s. 
  * 
  * @author Christoph Böhme, Markus Michael Geipel
  *
  */
+@Description("Replicates an event stream to an arbitrary number of stream receivers.")
+@In(StreamReceiver.class)
+@Out(StreamReceiver.class)
 public final class StreamTee extends DefaultTee<StreamReceiver>
 		implements StreamPipe<StreamReceiver> {
 

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

@@ -28,8 +28,8 @@
  *
  */
 @Description("Counts triples")
-@In(NamedValue.class)
-@Out(NamedValue.class)
+@In(Triple.class)
+@Out(Triple.class)
 public final class TripleCount extends AbstractTripleSort {
 
 	public static final String DEFAULT_COUNTP_REDICATE = "count";