MINOR: trivial cleanups, javadoc errors, omitted StateStore tests, etc. (#8130)
Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>, Guozhang Wang <guozhang@confluent.io>, Matthias J. Sax <matthias@confluent.io>
显示
- checkstyle/import-control.xml 0 个添加, 1 个删除checkstyle/import-control.xml
- connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java 1 个添加, 1 个删除...n/java/org/apache/kafka/connect/sink/SinkTaskContext.java
- connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java 1 个添加, 1 个删除...va/org/apache/kafka/connect/source/SourceTaskContext.java
- core/src/main/scala/kafka/log/Log.scala 1 个添加, 1 个删除core/src/main/scala/kafka/log/Log.scala
- streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java 0 个添加, 1 个删除...a/streams/processor/internals/ProcessorRecordContext.java
- streams/src/main/java/org/apache/kafka/streams/state/Stores.java 5 个添加, 1 个删除.../src/main/java/org/apache/kafka/streams/state/Stores.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilder.java 2 个添加, 1 个删除...e/kafka/streams/state/internals/KeyValueStoreBuilder.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStore.java 2 个添加, 1 个删除...treams/state/internals/MeteredTimestampedWindowStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/SessionStoreBuilder.java 2 个添加, 1 个删除...he/kafka/streams/state/internals/SessionStoreBuilder.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java 2 个添加, 1 个删除...eams/state/internals/TimestampedKeyValueStoreBuilder.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java 2 个添加, 1 个删除...treams/state/internals/TimestampedWindowStoreBuilder.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java 4 个添加, 0 个删除...che/kafka/streams/state/internals/WindowStoreBuilder.java
- streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java 1 个添加, 1 个删除...afka/streams/integration/AbstractJoinIntegrationTest.java
- streams/src/test/java/org/apache/kafka/streams/integration/SuppressionIntegrationTest.java 0 个添加, 1 个删除...kafka/streams/integration/SuppressionIntegrationTest.java
- streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressScenarioTest.java 1 个添加, 1 个删除...kafka/streams/kstream/internals/SuppressScenarioTest.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/TimestampedKeyValueStoreMaterializerTest.java 1 个添加, 0 个删除...r/internals/TimestampedKeyValueStoreMaterializerTest.java
- streams/src/test/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProviderTest.java 40 个添加, 0 个删除...streams/state/internals/GlobalStateStoreProviderTest.java
- streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilderTest.java 15 个添加, 2 个删除...fka/streams/state/internals/KeyValueStoreBuilderTest.java
- streams/src/test/java/org/apache/kafka/streams/state/internals/SessionStoreBuilderTest.java 18 个添加, 5 个删除...afka/streams/state/internals/SessionStoreBuilderTest.java
- streams/src/test/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProviderTest.java 27 个添加, 0 个删除...s/state/internals/StreamThreadStateStoreProviderTest.java
加载中
想要评论请 注册 或 登录