code: public static <T> void printResults(Stream<Stream<T>> resultPartitionsStream, boolean printPartitionSeparator){
  		AtomicInteger partitionCounter = new AtomicInteger();
  		resultPartitionsStream.forEach(resultPartition -> {
  			if (printPartitionSeparator){
  				System.out.println("\n=> PARTITION:" + partitionCounter.getAndIncrement());
  			}
  			
  			resultPartition.forEach(System.out::println);
  		});
  	}
docs: Prints the resultPartitionsStream to the standard out, also printing partition separator at the
  start of each result partition if 'printPartitionSeparator' is set to <i>true</i>.
  
  @param resultPartitionsStream
  @param printPartitionSeparator