Class ValidateSchemaAndBuildDictMapperOutputReader

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable

    public class ValidateSchemaAndBuildDictMapperOutputReader
    extends java.lang.Object
    implements java.io.Closeable
    This class reads the data(total input size in bytes and zstd dictionary) persisted in HDFS by ValidateSchemaAndBuildDictMapper based on the schema ValidateSchemaAndBuildDictMapperOutput
    • Constructor Detail

      • ValidateSchemaAndBuildDictMapperOutputReader

        public ValidateSchemaAndBuildDictMapperOutputReader​(org.apache.hadoop.fs.Path outputDir,
                                                            java.lang.String fileName)
                                                     throws java.lang.Exception
        Throws:
        java.lang.Exception
    • Method Detail

      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable