Skip to content

Commit 00ee4b2

Browse files
forgot the filters
Co-authored-by: Thomas Chow <[email protected]>
1 parent 87f2f73 commit 00ee4b2

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spark/src/main/scala/ai/chronon/spark/TableUtils.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -580,7 +580,7 @@ class TableUtils(@transient val sparkSession: SparkSession) extends Serializable
580580
rangeWheres: Seq[String],
581581
fallbackSelects: Option[Map[String, String]] = None): DataFrame = {
582582

583-
var df = loadTable(table)
583+
var df = loadTable(table, rangeWheres)
584584

585585
val selects = QueryUtils.buildSelects(selectMap, fallbackSelects)
586586

0 commit comments

Comments
 (0)