org.apache.iceberg.hadoop

Class HadoopStreams

java.lang.Object

org.apache.iceberg.hadoop.HadoopStreams

public class HadoopStreams
extends java.lang.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 and 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 Detail

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