Package org.apache.iceberg.hadoop

Class HadoopStreams

java.lang.Object

org.apache.iceberg.hadoop.HadoopStreams

public class HadoopStreams
extends Object

Convenience methods to get Parquet abstractions for Hadoop data streams.

This class is based on Parquet's HadoopStreams.

Method Summary

Modifier and Type	Method	Description
static org.apache.hadoop.fs.FSInputStream	wrap(SeekableInputStream stream)	Wraps a SeekableInputStream in a FSDataOutputStream implementation for readers.

Methods inherited from class java.lang.Object

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

Method Details

wrap

public static org.apache.hadoop.fs.FSInputStream wrap(SeekableInputStream stream)

Wraps a SeekableInputStream in a FSDataOutputStream implementation for readers.

Parameters:

stream - a SeekableInputStream

Returns:

a FSDataOutputStream