Package org.apache.beam.sdk.io.parquet
Class ParquetIO.ReadFiles.BeamParquetInputFile
- java.lang.Object
-
- org.apache.beam.sdk.io.parquet.ParquetIO.ReadFiles.BeamParquetInputFile
-
- All Implemented Interfaces:
org.apache.parquet.io.InputFile
- Enclosing class:
- ParquetIO.ReadFiles
public static class ParquetIO.ReadFiles.BeamParquetInputFile extends java.lang.Object implements org.apache.parquet.io.InputFile
-
-
Constructor Summary
Constructors Constructor Description BeamParquetInputFile(java.nio.channels.SeekableByteChannel seekableByteChannel)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longgetLength()org.apache.parquet.io.SeekableInputStreamnewStream()
-
-
-
Method Detail
-
getLength
public long getLength() throws java.io.IOException- Specified by:
getLengthin interfaceorg.apache.parquet.io.InputFile- Throws:
java.io.IOException
-
newStream
public org.apache.parquet.io.SeekableInputStream newStream()
- Specified by:
newStreamin interfaceorg.apache.parquet.io.InputFile
-
-