Skip to content

Commit 0573381

Browse files
committed
chore: Remove some prints
1 parent 6edb34b commit 0573381

File tree

2 files changed

+2
-7
lines changed

2 files changed

+2
-7
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,18 +17,18 @@
1717
package ai.chronon.spark
1818

1919
import ai.chronon.api
20+
import ai.chronon.api.{Constants, PartitionRange, PartitionSpec, TimeRange, Window}
2021
import ai.chronon.api.Extensions.{SourceOps, WindowOps}
2122
import ai.chronon.api.ScalaJavaConversions._
22-
import ai.chronon.api.{Constants, PartitionRange, PartitionSpec, TimeRange, Window}
2323
import ai.chronon.online.serde.{AvroConversions, SparkConversions}
24+
import ai.chronon.spark.catalog.TableUtils
2425
import org.apache.avro.Schema
2526
import org.apache.spark.sql.DataFrame
2627
import org.apache.spark.sql.expressions.UserDefinedFunction
2728
import org.apache.spark.sql.functions._
2829
import org.apache.spark.sql.types.{LongType, StructType}
2930
import org.apache.spark.util.sketch.BloomFilter
3031
import org.slf4j.{Logger, LoggerFactory}
31-
import ai.chronon.spark.catalog.{TableCache, TableUtils}
3232

3333
import java.util
3434
import scala.collection.Seq

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

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -237,9 +237,6 @@ class TableUtils(@transient val sparkSession: SparkSession) extends Serializable
237237
expandTable(tableName, dfRearranged.schema)
238238
}
239239

240-
println(s"REARRANGED DF for ${tableName}::::::")
241-
dfRearranged.show()
242-
243240
// Run tableProperties
244241
Option(tableProperties).filter(_.nonEmpty).foreach { props =>
245242
sql(CreationUtils.alterTablePropertiesSql(tableName, props))
@@ -267,8 +264,6 @@ class TableUtils(@transient val sparkSession: SparkSession) extends Serializable
267264

268265
logger.info(s"Writing to $tableName ...")
269266

270-
finalizedDf.show()
271-
272267
finalizedDf.write
273268
.mode(saveMode)
274269
// Requires table to exist before inserting.

0 commit comments

Comments
 (0)