Skip to content

Instantly share code, notes, and snippets.

@dbtsai
Created August 6, 2019 21:30
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save dbtsai/01a779e95e54f66f9e5d3f042700b45f to your computer and use it in GitHub Desktop.
Save dbtsai/01a779e95e54f66f9e5d3f042700b45f to your computer and use it in GitHub Desktop.
package org.apache.spark.sql.sources.v2;
import org.apache.spark.annotation.Experimental;
import org.apache.spark.sql.catalog.v2.expressions.NamedReference;
@Experimental
public abstract class Filter {
/**
* Returns list of columns that are referenced by this filter.
*/
abstract NamedReference[] references();
protected NamedReference[] findReferences(Object valve) {
if (valve instanceof Filter) {
return ((Filter) valve).references();
} else {
return new NamedReference[0];
}
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment