Class ParquetInputFile

  • All Implemented Interfaces:
    org.apache.parquet.io.InputFile

    public class ParquetInputFile
    extends Object
    implements org.apache.parquet.io.InputFile
    Parquet InputFile implementation, newStream() call will delegate to Flink FSDataInputStream.
    • Constructor Detail

      • ParquetInputFile

        public ParquetInputFile​(org.apache.flink.core.fs.FSDataInputStream inputStream,
                                long length)
    • Method Detail

      • getLength

        public long getLength()
        Specified by:
        getLength in interface org.apache.parquet.io.InputFile
      • newStream

        public org.apache.parquet.io.SeekableInputStream newStream()
        Specified by:
        newStream in interface org.apache.parquet.io.InputFile