...

src/test/java/cn/com/qmth/examcloud/test/pipeline/FileReaderExecuter.java

@@ -7,23 +7,29 @@ import java.util.Objects;
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang3.RandomUtils;
 
+import com.google.common.collect.Lists;
+
+import cn.com.qmth.examcloud.commons.helpers.KeyValuePair;
 import cn.com.qmth.examcloud.commons.helpers.pipeline.NodeExecuter;
-import cn.com.qmth.examcloud.commons.helpers.pipeline.Storer;
 import cn.com.qmth.examcloud.commons.helpers.pipeline.TaskContext;
 
 public class FileReaderExecuter implements NodeExecuter<String, String, String, String> {
 
 	@Override
-	public void execute(String key, String value, Storer<String, String> storer,
-			TaskContext context) throws Exception {
+	public List<KeyValuePair<String, String>> execute(String key, String value, TaskContext context)
+			throws Exception {
 
 		String path = (String) context.get("path");
 
 		List<String> readLines = FileUtils.readLines(new File(path), "UTF-8");
 
+		List<KeyValuePair<String, String>> list = Lists.newArrayList();
 		readLines.forEach(e -> {
-			storer.putElement(Objects.toString(RandomUtils.nextLong()), e);
+			list.add(new KeyValuePair<String, String>(Objects.toString((RandomUtils.nextLong())),
+					e));
 		});
+
+		return list;
 	}
 
 }

src/test/java/cn/com/qmth/examcloud/test/pipeline/PrintExecuter.java

@@ -1,15 +1,18 @@
 package cn.com.qmth.examcloud.test.pipeline;
 
+import java.util.List;
+
+import cn.com.qmth.examcloud.commons.helpers.KeyValuePair;
 import cn.com.qmth.examcloud.commons.helpers.pipeline.NodeExecuter;
-import cn.com.qmth.examcloud.commons.helpers.pipeline.Storer;
 import cn.com.qmth.examcloud.commons.helpers.pipeline.TaskContext;
 
 public class PrintExecuter implements NodeExecuter<String, String, String, String> {
 
 	@Override
-	public void execute(String key, String value, Storer<String, String> storer,
-			TaskContext context) throws Exception {
+	public List<KeyValuePair<String, String>> execute(String key, String value, TaskContext context)
+			throws Exception {
 		System.out.println("Print: " + key + " -> " + value);
+		return null;
 	}
 
 }