Skip to content

Commit

Permalink
address comments
Browse files Browse the repository at this point in the history
  • Loading branch information
huaxingao committed Sep 23, 2021
1 parent 1014995 commit 3a0052f
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,26 +22,26 @@

/**
* A mix-in interface for {@link ScanBuilder}. Data sources can implement this interface to
* push down data source V2 filters {@link Filter} to the data source and reduce the size of
* the data to be read.
* push down V2 {@link Filter} to the data source and reduce the size of the data to be read.
* Please Note that this interface is preferred over {@link SupportsPushDownFilters}, which uses
* V1 {@link org.apache.spark.sql.sources.Filter} and is less efficient due to the
* internal -> external data conversion.
*
* @since 3.3.0
*/
@Evolving
public interface SupportsPushDownV2Filters extends ScanBuilder {

/**
* Pushes down data source V2 filters, and returns V2 filters that need to be evaluated after
* scanning.
* Pushes down filters, and returns filters that need to be evaluated after scanning.
* <p>
* Rows should be returned from the data source if and only if all of the filters match. That is,
* filters must be interpreted as ANDed together.
*/
Filter[] pushFilters(Filter[] filters);

/**
* Returns the V2 filters that are pushed to the data source via
* {@link #pushFilters(Filter[])}.
* Returns the filters that are pushed to the data source via {@link #pushFilters(Filter[])}.
* <p>
* There are 3 kinds of filters:
* <ol>
Expand Down

0 comments on commit 3a0052f

Please sign in to comment.