Skip to content

Conversation

@fedimser
Copy link
Contributor

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?

Was this patch authored or co-authored using generative AI tooling?

- Add TwsTester.scala: Main testing framework for TransformWithState
- Add InMemoryStatefulProcessorHandleImpl.scala: In-memory implementation for testing
- Add TwsTesterSuite.scala: Test suite for TwsTester framework
- Add processors: EventTimeWindow, MultiTimer, RunningCount, SessionTimeout, TopK, WordFrequency
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant