docs: public static List<List<Writable>> execute(List<List<Writable>> inputWritables,
                                                 TransformProcess transformProcess) {
          if (transformProcess.getFinalSchema() instanceof SequenceSchema) {
              throw new IllegalStateException("Cannot return sequence data with this method");
  
          }
  
          List<List<Writable>> filteredSequence = inputWritables.parallelStream()
                  .filter(input -> input.size() == transformProcess.getInitialSchema().numColumns()).collect(toList());
          if(filteredSequence.size() != inputWritables.size()) {
              log.warn("Filtered out " + (inputWritables.size() - filteredSequence.size()) + " values");
          }
          return execute(filteredSequence, null, transformProcess).getFirst();
      }