Add options with default method

Signed-off-by: Chen Dai <[email protected]>

flint-spark-integration/src/main/scala/org/opensearch/flint/spark/FlintSparkIndexOptions.scala

@@ -54,6 +54,20 @@ case class FlintSparkIndexOptions(options: Map[String, String]) {
    */
   def indexSettings(): Option[String] = getOptionValue(INDEX_SETTINGS)
 
+  /**
+   * @return
+   *   all option values and fill default value if unspecified
+   */
+  def optionsWithDefault: Map[String, String] = {
+    val map = Map.newBuilder[String, String]
+    map ++= options
+
+    if (!options.contains(AUTO_REFRESH.toString)) {
+      map += (AUTO_REFRESH.toString -> autoRefresh().toString)
+    }
+    map.result()
+  }
+
   private def getOptionValue(name: OptionName): Option[String] = {
     options.get(name.toString)
   }
@@ -76,6 +90,10 @@ object FlintSparkIndexOptions {
     val CHECKPOINT_LOCATION: OptionName.Value = Value("checkpoint_location")
     val INDEX_SETTINGS: OptionName.Value = Value("index_settings")
 
+    /**
+     * @return
+     *   convert enum name to lowercase as public option name
+     */
     override def toString(): String = {
       super.toString().toLowerCase(Locale.ROOT)
     }

flint-spark-integration/src/test/scala/org/opensearch/flint/spark/FlintSparkIndexOptionsSuite.scala

@@ -32,17 +32,23 @@ class FlintSparkIndexOptionsSuite extends FlintSuite with Matchers {
     options.refreshInterval() shouldBe empty
     options.checkpointLocation() shouldBe empty
     options.indexSettings() shouldBe empty
+    options.optionsWithDefault should contain("auto_refresh" -> "false")
+  }
+
+  test("should return default option value if unspecified with specified value") {
+    val options = FlintSparkIndexOptions(Map("refresh_interval" -> "1 Minute"))
+
+    options.optionsWithDefault shouldBe Map(
+      "auto_refresh" -> "false",
+      "refresh_interval" -> "1 Minute")
   }
 
   test("should report error if any unknown option name") {
-    the [IllegalArgumentException] thrownBy
+    the[IllegalArgumentException] thrownBy
       FlintSparkIndexOptions(Map("autoRefresh" -> "true"))
 
-    the [IllegalArgumentException] thrownBy {
-      FlintSparkIndexOptions(Map(
-        "auto_refresh" -> "true",
-        "indexSetting" -> "test"
-      ))
+    the[IllegalArgumentException] thrownBy {
+      FlintSparkIndexOptions(Map("auto_refresh" -> "true", "indexSetting" -> "test"))
     } should have message "requirement failed: option name indexSetting is invalid"
   }
 }