diff --git a/src/main/scala/com/github/mrpowers/spark/daria/delta/DeltaLogHelpers.scala b/src/main/scala/com/github/mrpowers/spark/daria/delta/DeltaLogHelpers.scala
index 7f664e90..ecb9b57b 100644
--- a/src/main/scala/com/github/mrpowers/spark/daria/delta/DeltaLogHelpers.scala
+++ b/src/main/scala/com/github/mrpowers/spark/daria/delta/DeltaLogHelpers.scala
@@ -5,6 +5,11 @@ import org.apache.spark.sql.functions._
 
 object DeltaLogHelpers {
 
+  // get the deltaLogDF with this code
+  // DeltaLog
+  //   .forTable(spark, path)
+  //   .snapshot
+  //   .allFiles
   def num1GbPartitions(deltaLogDF: DataFrame, minNumPartitions: Int = 1): Int = {
 
     val numBytes = deltaLogDF