code: @Override
      public Processor newProcessor(Processor sourceProcessor) {
          ClusteringDistributorProcessor newProcessor = new ClusteringDistributorProcessor();
          ClusteringDistributorProcessor originProcessor = (ClusteringDistributorProcessor) sourceProcessor;
          if (originProcessor.getOutputStream() != null)
              newProcessor.setOutputStream(originProcessor.getOutputStream());
          if (originProcessor.getEvaluationStream() != null)
              newProcessor.setEvaluationStream(originProcessor.getEvaluationStream());
          return newProcessor;
      }
docs: /*
  (non-Javadoc)
  
  @see samoa.core.Processor#newProcessor(samoa.core.Processor)