public class FilteredManifest extends java.lang.Object implements Filterable<FilteredManifest>
CloseableIterable.ConcatCloseableIterable<E>
Modifier and Type | Method and Description |
---|---|
FilteredManifest |
caseSensitive(boolean isCaseSensitive)
Sets case sensitivity.
|
void |
close() |
FilteredManifest |
filterPartitions(Expression expr)
Adds a filter expression on partition data for matching files.
|
FilteredManifest |
filterRows(Expression expr)
Adds a filter expression on data rows for matching files.
|
java.util.Iterator<DataFile> |
iterator() |
FilteredManifest |
project(Schema fileProjection)
Set the projection from a schema.
|
FilteredManifest |
select(java.util.Collection<java.lang.String> selectedColumns)
Selects the columns of a file manifest to read.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
caseInsensitive, caseSensitive, select
combine, concat, empty, filter, transform, withNoopClose, withNoopClose
public FilteredManifest select(java.util.Collection<java.lang.String> selectedColumns)
Filterable
If columns are set multiple times, the last set of columns will be read.
If the Filterable object has partition filters, they will be added to the returned partial.
For a list of column names, see the table format specification.
select
in interface Filterable<FilteredManifest>
selectedColumns
- String column names to load from the manifest filepublic FilteredManifest project(Schema fileProjection)
Filterable
project
in interface Filterable<FilteredManifest>
fileProjection
- a projection of the DataFile schemapublic FilteredManifest filterPartitions(Expression expr)
Filterable
If the Filterable object already has partition filters, the new filter will be added as an additional requirement. The result filter expression will be the result of expr and any existing filters.
If the Filterable object has columns selected, they will be added to the returned partial.
filterPartitions
in interface Filterable<FilteredManifest>
expr
- An expression for filtering this Filterable using partition datapublic FilteredManifest filterRows(Expression expr)
Filterable
Expressions passed to this function will be converted to partition expressions before they are used to filter data files.
If the Filterable object already has partition filters, the new filter will be added as an additional requirement. The result filter expression will be the result of expr and any existing filters.
If the Filterable object has columns selected, they will be added to the returned partial.
filterRows
in interface Filterable<FilteredManifest>
expr
- An expression for filtering this Filterable using row datapublic FilteredManifest caseSensitive(boolean isCaseSensitive)
Filterable
caseSensitive
in interface Filterable<FilteredManifest>
isCaseSensitive
- true if expression binding and schema projection should be case sensitivepublic java.util.Iterator<DataFile> iterator()
iterator
in interface java.lang.Iterable<DataFile>
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException