File tree 1 file changed +2
-3
lines changed
spark/src/main/scala/ai/chronon/spark 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -19,7 +19,6 @@ package ai.chronon.spark
19
19
import ai .chronon .aggregator .windowing .TsUtils
20
20
import ai .chronon .api .ColorPrinter .ColorString
21
21
import ai .chronon .api .Constants
22
- import ai .chronon .api .DataPointer
23
22
import ai .chronon .api .Extensions ._
24
23
import ai .chronon .api .PartitionSpec
25
24
import ai .chronon .api .Query
@@ -747,13 +746,13 @@ class TableUtils(@transient val sparkSession: SparkSession) extends Serializable
747
746
wheres : Seq [String ],
748
747
rangeWheres : Seq [String ],
749
748
fallbackSelects : Option [Map [String , String ]] = None ): DataFrame = {
750
- val dp = DataPointer (table)
749
+ val dp = ai.chronon.api. DataPointer .apply (table)
751
750
var df = dp.toDf(sparkSession)
752
751
val selects = QueryUtils .buildSelects(selectMap, fallbackSelects)
753
752
logger.info(s """ Scanning data:
754
753
| table: ${dp.tableOrPath.green}
755
754
| options: ${dp.options}
756
- | format: ${dp.format }
755
+ | format: ${dp.readFormat }
757
756
| selects:
758
757
| ${selects.mkString(" \n " ).green}
759
758
| wheres:
You can’t perform that action at this time.
0 commit comments