chermenin/
Custom state store providers for Apache Spark
USD raised
Recent activities
Build with scala 2.12
Revisit the implementation of helper methods.
Implement ProcessingTimeTimeout for RocksDBStateStore
Allow State timeouts on Query Level
Can't find the init method of org.apache.spark.sql.execution.streaming.state.StateStoreProvider.$init$
Spark 2.3 compatibility?
SIGSEGV occur during store.newIterator
[question] Accessing StateStore content for inspection
Event time timeout with flatMapGroupsWithState
Rocks DB with spark 3.2
© 2019 BoostIO, Inc.