Skip to content

Commit

Permalink
Add more optimize APIs
Browse files Browse the repository at this point in the history
  • Loading branch information
osopardo1 committed Aug 2, 2024
1 parent e10f4b1 commit 13a2cd7
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions src/main/scala/io/qbeast/spark/QbeastTable.scala
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,10 @@ class QbeastTable private (
}
}

def optimize(revisionID: RevisionID): Unit = {
optimize(revisionID, Map.empty[String, String])
}

def optimize(options: Map[String, String]): Unit = {
optimize(latestRevisionAvailableID, options)
}
Expand All @@ -100,6 +104,9 @@ class QbeastTable private (
def optimize(files: Seq[String], options: Map[String, String]): Unit =
indexedTable.optimize(files, options)

def optimize(files: Seq[String]): Unit =
optimize(files, Map.empty[String, String])

/**
* The analyze operation should analyze the index structure and find the cubes that need
* optimization
Expand Down

0 comments on commit 13a2cd7

Please sign in to comment.