@Override
  protected String getPartitionedFileName(State properties, String originalFileName) {
    Schema schema = this.getSchema();
    if (schema != null) {
      return new Path(schema.getName(), originalFileName).toString();
    } else {
      return originalFileName;
    }
  }
@ Override protected String getPartitionedFileName ( State properties , String originalFileName ) { Schema schema = this . getSchema ( ) ; if ( schema != null ) { return new Path ( schema . getName ( ) , originalFileName ) . toString ( ) ; } else { return originalFileName ; } }
Use the name field of {@link #schema} to partition path