activity.process();
TupleClassifier classifier = (TupleClassifier)output.getActualBlocks().get(0);
System.out.println(classifier);
ClassifyActivity classify = new ClassifyActivity();
MockInputPipe inputClassifier = new MockInputPipe(classifier);
classify.addInput(ClassifyActivity.INPUT_CLASSIFIER, inputClassifier);
MockInputPipe inputData = new MockInputPipe(buildInputTable().toArray());
classify.addInput(ClassifyActivity.INPUT_DATA, inputData);
MockOutputPipe outputClassify = new MockOutputPipe(new Object[] {});
classify.addOutput(ClassifyActivity.OUTPUT, outputClassify);
classify.process();
List actualBlocks = outputClassify.getActualBlocks();
assertEquals(input.size(), actualBlocks.size());
assertEquals(ControlBlock.LIST_BEGIN, actualBlocks.get(0));
for (int i=2; i<actualBlocks.size()-1; i++)