This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch kip-478-part-4
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 92ff47d javadoc fix
add 396e1ea propose StateStoreContext instead
No new revisions were added by this update.
Summary of changes:
.../examples/wordcount/WordCountProcessorTest.java | 2 +-
.../apache/kafka/streams/processor/StateStore.java | 15 +--
.../kafka/streams/processor/StateStoreContext.java | 112 +++++++++++++++++++++
.../internals/ProcessorToStoreContextAdapter.java | 85 ++++++++++++++++
...xt.java => StoreToProcessorContextAdapter.java} | 68 ++++++-------
.../processor/api/MockProcessorContext.java | 56 +++++++++++
6 files changed, 290 insertions(+), 48 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/StateStoreContext.java
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorToStoreContextAdapter.java
copy
streams/src/main/java/org/apache/kafka/streams/processor/internals/{ForwardingDisabledProcessorContext.java
=> StoreToProcessorContextAdapter.java} (61%)
