org.apache.flink.formats.parquet

Class ParquetInputFile

java.lang.Object

org.apache.flink.formats.parquet.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 Summary

Constructors

Constructor and Description
ParquetInputFile(FSDataInputStream inputStream, long length)

Method Summary

Modifier and Type	Method and Description
long	getLength()
org.apache.parquet.io.SeekableInputStream	newStream()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ParquetInputFile

public ParquetInputFile(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