org.apache.spark.sql.connector.iceberg.read

Interface SupportsFileFilter

All Superinterfaces:

org.apache.spark.sql.connector.read.Scan

public interface SupportsFileFilter
extends org.apache.spark.sql.connector.read.Scan

A mix-in interface for Scan. Data sources can implement this interface if they support dynamic file filters.

Method Summary

Modifier and Type	Method and Description
void	filterFiles(java.util.Set<java.lang.String> locations) Filters this scan to query only selected files.

Methods inherited from interface org.apache.spark.sql.connector.read.Scan

description, readSchema, toBatch, toContinuousStream, toMicroBatchStream

Method Detail

filterFiles

void filterFiles(java.util.Set<java.lang.String> locations)

Filters this scan to query only selected files.

Parameters:

locations - file locations