File tree Expand file tree Collapse file tree 1 file changed +8
-4
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming Expand file tree Collapse file tree 1 file changed +8
-4
lines changed Original file line number Diff line number Diff line change @@ -273,15 +273,19 @@ class StateStoreColumnFamilySchemaUtils(initializeAvroSerde: Boolean)
273273 ))
274274 }
275275
276- /** Creates a StateStoreColFamilySchema for Timers' secondary index with proper encoding configuration.
276+ /** Creates a StateStoreColFamilySchema for Timers' secondary index with proper encoding
277+ * configuration.
277278 *
278- * When using Avro encoding, fixed-length types need to be converted to binary types to support range scan operations.
279- * This function handles the necessary schema conversion to ensure range scan functionality works correctly.
279+ * When using Avro encoding, fixed-length types need to be converted to binary types to
280+ * support range scan operations.
281+ * This function handles the necessary schema conversion to ensure range scan functionality
282+ * works correctly.
280283 *
281284 * @param stateName The name of the state store
282285 * @param keySchema The schema defining the structure of the key
283286 * @param valSchema The schema defining the structure of the value
284- * @return A StateStoreColFamilySchema configured for Timer secondary indexing with appropriate encoding
287+ * @return A StateStoreColFamilySchema configured for Timer secondary indexing with
288+ * appropriate encoding
285289 */
286290 def getTimerStateSchemaForSecIndex (
287291 stateName : String ,
You can’t perform that action at this time.
0 commit comments