org.apache.paimon.format.parquet.writer

Class StreamOutputFile

java.lang.Object

org.apache.paimon.format.parquet.writer.StreamOutputFile

All Implemented Interfaces:

org.apache.parquet.io.OutputFile

public class StreamOutputFile
extends Object
implements org.apache.parquet.io.OutputFile

An implementation of Parquet's OutputFile interface that goes against a Paimon PositionOutputStream.

Because the implementation goes against an open stream, rather than open its own streams against a file, instances can create one stream only.

Constructor Summary

Constructors

Constructor and Description
StreamOutputFile(PositionOutputStream stream) Creates a new StreamOutputFile.

Method Summary

Modifier and Type	Method and Description
org.apache.parquet.io.PositionOutputStream	create(long blockSizeHint)
org.apache.parquet.io.PositionOutputStream	createOrOverwrite(long blockSizeHint)
long	defaultBlockSize()
boolean	supportsBlockSize()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.parquet.io.OutputFile

getPath

Constructor Detail

StreamOutputFile

public StreamOutputFile(PositionOutputStream stream)

Creates a new StreamOutputFile. The first call to create(long) or createOrOverwrite(long) returns a stream that writes to the given stream.

Parameters:

stream - The stream to write to.

Method Detail

create

public org.apache.parquet.io.PositionOutputStream create(long blockSizeHint)

Specified by:

create in interface org.apache.parquet.io.OutputFile

createOrOverwrite

public org.apache.parquet.io.PositionOutputStream createOrOverwrite(long blockSizeHint)

Specified by:

createOrOverwrite in interface org.apache.parquet.io.OutputFile

supportsBlockSize

public boolean supportsBlockSize()

Specified by:

supportsBlockSize in interface org.apache.parquet.io.OutputFile

defaultBlockSize

public long defaultBlockSize()

Specified by:

defaultBlockSize in interface org.apache.parquet.io.OutputFile