Skip to content

Commit 5904a8a

Browse files
committed
Adding fast refresh setting during index creation
1 parent b9a0dc5 commit 5904a8a

File tree

1 file changed

+9
-0
lines changed
  • spark-sql-application/src/main/scala/org/apache/spark/sql

1 file changed

+9
-0
lines changed

spark-sql-application/src/main/scala/org/apache/spark/sql/OSClient.scala

+9
Original file line numberDiff line numberDiff line change
@@ -71,6 +71,15 @@ class OSClient(val flintOptions: FlintOptions) extends Logging {
7171
using(flintClient.createClient()) { client =>
7272
val request = new CreateIndexRequest(osIndexName)
7373
request.mapping(mapping, XContentType.JSON)
74+
.settings(
75+
"""
76+
| {
77+
| "auto_refresh": "true",
78+
| "refresh_interval": "1 Second",
79+
| }
80+
|""".stripMargin,
81+
XContentType.JSON
82+
)
7483

7584
try {
7685
client.createIndex(request, RequestOptions.DEFAULT)

0 commit comments

Comments
 (0)