Eric Marnadi
Eric Marnadi
### What changes were proposed in this pull request? ### Why are the changes needed? ### Does this PR introduce _any_ user-facing change? ### How was this patch tested? ###...
### What changes were proposed in this pull request? Setting the processorHandle as a part of the statefulProcessor, so that the user doesn't have to explicitly keep track of it,...
### What changes were proposed in this pull request? In this PR, we introduce the `StateSchemaV3` file that is used to keep track of a list of `ColumnFamilySchema` which we...
### What changes were proposed in this pull request? ### Why are the changes needed? ### Does this PR introduce _any_ user-facing change? ### How was this patch tested? ###...
### What changes were proposed in this pull request? Currently, OperatorStateMetadataV2 and StateSchemaV3 files are written for every new query run. This PR will implement purging files so we only...
### What changes were proposed in this pull request? Currently, we use UnsafeRow to store all state in the StateStores. This change will add StateStore APIs that support byte array...
### What changes were proposed in this pull request? This PR introduces state machine validation to RocksDBStateStore to enforce proper usage patterns. It adds: 1. Explicit state machine transitions between...
### What changes were proposed in this pull request? Adding a release() method to the ReadStateStore interface to properly close read stores without aborting them Implementing a getWriteStore() method that...
### What changes were proposed in this pull request? This PR decouples the versioning of OffsetSeqMetadata from OffsetLog, allowing them to evolve independently while maintaining backward compatibility with existing streaming...
### What changes were proposed in this pull request? We want to add `.name()` to the DataStreamReader to enable naming streaming sources, which will allow users to add, remove and...