Package com.here.platform.data.client.flink.impl.decoders.parquet

Class ByteArrayInputFile

java.lang.Object

com.here.platform.data.client.flink.impl.decoders.parquet.ByteArrayInputFile

All Implemented Interfaces:

org.apache.parquet.io.InputFile

public class ByteArrayInputFile
extends Object
implements org.apache.parquet.io.InputFile

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ByteArrayInputFile.ByteArrayInputStreamWithPos
class	ByteArrayInputFile.ByteArraySeekableInputStream

Constructor Summary

Constructors

Constructor	Description
ByteArrayInputFile(byte[] bytes)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

ByteArrayInputFile

public ByteArrayInputFile(byte[] bytes)

Method Details

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