F
- The Java class of files returned by this reader.public class ManifestReader<F extends ContentFile<F>> extends CloseableGroup implements CloseableIterable<F>
Modifier and Type | Class and Description |
---|---|
protected static class |
ManifestReader.FileType |
CloseableIterable.ConcatCloseableIterable<E>
Modifier | Constructor and Description |
---|---|
protected |
ManifestReader(InputFile file,
int specId,
java.util.Map<java.lang.Integer,PartitionSpec> specsById,
org.apache.iceberg.InheritableMetadata inheritableMetadata,
ManifestReader.FileType content) |
Modifier and Type | Method and 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 type
T . |
ManifestReader<F> |
project(Schema newFileProjection) |
Schema |
schema() |
ManifestReader<F> |
select(java.util.Collection<java.lang.String> newColumns) |
PartitionSpec |
spec() |
addCloseable, addCloseable, close, setSuppressCloseFailure
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
combine, concat, count, empty, filter, filter, transform, whenComplete, withNoopClose, withNoopClose
protected ManifestReader(InputFile file, int specId, java.util.Map<java.lang.Integer,PartitionSpec> specsById, org.apache.iceberg.InheritableMetadata inheritableMetadata, ManifestReader.FileType content)
public boolean isDeleteManifestReader()
public InputFile file()
public Schema schema()
public PartitionSpec spec()
public ManifestReader<F> select(java.util.Collection<java.lang.String> newColumns)
public ManifestReader<F> project(Schema newFileProjection)
public ManifestReader<F> filterPartitions(Expression expr)
public ManifestReader<F> filterPartitions(PartitionSet partitions)
public ManifestReader<F> filterRows(Expression expr)
public ManifestReader<F> caseSensitive(boolean isCaseSensitive)
public CloseableIterator<F> iterator()
CloseableIterable
T
.iterator
in interface java.lang.Iterable<F extends ContentFile<F>>
iterator
in interface CloseableIterable<F extends ContentFile<F>>