code: 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();
      }
docs: Execute the specified TransformProcess with the given input data<br>
  Note: this method can only be used if the TransformProcess returns non-sequence data. For TransformProcesses
  that return a sequence, use {@link #executeToSequence(List, TransformProcess)}
  
  @param inputWritables   Input data to process
  @param transformProcess TransformProcess to execute
  @return Processed data