Package org.apache.iceberg
Class ManifestReader<F extends ContentFile<F>>
- java.lang.Object
-
- org.apache.iceberg.io.CloseableGroup
-
- org.apache.iceberg.ManifestReader<F>
-
- Type Parameters:
F
- The Java class of files returned by this reader.
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,java.lang.Iterable<F>
,CloseableIterable<F>
public class ManifestReader<F extends ContentFile<F>> extends CloseableGroup implements CloseableIterable<F>
Base reader for data and delete manifest files.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected static class
ManifestReader.FileType
-
Nested classes/interfaces inherited from interface org.apache.iceberg.io.CloseableIterable
CloseableIterable.ConcatCloseableIterable<E>
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
ManifestReader(InputFile file, int specId, java.util.Map<java.lang.Integer,PartitionSpec> specsById, org.apache.iceberg.InheritableMetadata inheritableMetadata, ManifestReader.FileType content)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ManifestReader<F>
caseSensitive(boolean isCaseSensitive)
InputFile
file()
ManifestReader<F>
filterPartitions(Expression expr)
ManifestReader<F>
filterPartitions(PartitionSet partitions)
ManifestReader<F>
filterRows(Expression expr)
boolean
isDeleteManifestReader()
CloseableIterator<F>
iterator()
Returns a closeable iterator over elements of typeT
.ManifestReader<F>
project(Schema newFileProjection)
Schema
schema()
ManifestReader<F>
select(java.util.Collection<java.lang.String> newColumns)
PartitionSpec
spec()
-
Methods inherited from class org.apache.iceberg.io.CloseableGroup
addCloseable, addCloseable, close, setSuppressCloseFailure
-
-
-
-
Constructor Detail
-
ManifestReader
protected ManifestReader(InputFile file, int specId, java.util.Map<java.lang.Integer,PartitionSpec> specsById, org.apache.iceberg.InheritableMetadata inheritableMetadata, ManifestReader.FileType content)
-
-
Method Detail
-
isDeleteManifestReader
public boolean isDeleteManifestReader()
-
file
public InputFile file()
-
schema
public Schema schema()
-
spec
public PartitionSpec spec()
-
select
public ManifestReader<F> select(java.util.Collection<java.lang.String> newColumns)
-
project
public ManifestReader<F> project(Schema newFileProjection)
-
filterPartitions
public ManifestReader<F> filterPartitions(Expression expr)
-
filterPartitions
public ManifestReader<F> filterPartitions(PartitionSet partitions)
-
filterRows
public ManifestReader<F> filterRows(Expression expr)
-
caseSensitive
public ManifestReader<F> caseSensitive(boolean isCaseSensitive)
-
iterator
public CloseableIterator<F> iterator()
Description copied from interface:CloseableIterable
Returns a closeable iterator over elements of typeT
.- Specified by:
iterator
in interfaceCloseableIterable<F extends ContentFile<F>>
- Specified by:
iterator
in interfacejava.lang.Iterable<F extends ContentFile<F>>
- Returns:
- an Iterator of DataFile. Makes defensive copies of files before returning
-
-