You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ca...@apache.org on 2020/06/15 22:40:21 UTC
[samza] branch master updated (0b65dbf -> a5f7a66)
This is an automated email from the ASF dual-hosted git repository.
cameronlee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.
from 0b65dbf [Minor test fix] Enabled and fixed a TestKafkaCheckpointManager test (#1382)
add a5f7a66 SAMZA-2516: Migrate BaseKeyValueStorageEngineFactory to be an abstract class instead of trait (#1352)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 +
.../kv/BaseKeyValueStorageEngineFactory.java | 262 ++++++++++++++++++
.../samza/storage/kv/LargeMessageSafeStore.java | 6 +
.../samza/storage/kv/RecordTooLargeException.java | 0
.../samza/storage/kv/AccessLoggedStore.scala | 6 +
.../kv/BaseKeyValueStorageEngineFactory.scala | 200 --------------
.../org/apache/samza/storage/kv/CachedStore.scala | 6 +
.../samza/storage/kv/KeyValueStorageEngine.scala | 11 +
.../org/apache/samza/storage/kv/LoggedStore.scala | 6 +
.../samza/storage/kv/NullSafeKeyValueStore.scala | 6 +
.../samza/storage/kv/SerializedKeyValueStore.scala | 6 +
.../kv/MockKeyValueStorageEngineFactory.java | 33 +--
.../kv/TestBaseKeyValueStorageEngineFactory.java | 295 +++++++++++++++++++++
13 files changed, 622 insertions(+), 216 deletions(-)
create mode 100644 samza-kv/src/main/java/org/apache/samza/storage/kv/BaseKeyValueStorageEngineFactory.java
rename samza-kv/src/main/{scala => java}/org/apache/samza/storage/kv/RecordTooLargeException.java (100%)
delete mode 100644 samza-kv/src/main/scala/org/apache/samza/storage/kv/BaseKeyValueStorageEngineFactory.scala
copy samza-core/src/test/java/org/apache/samza/storage/MockStorageEngineFactory.java => samza-kv/src/test/java/org/apache/samza/storage/kv/MockKeyValueStorageEngineFactory.java (56%)
create mode 100644 samza-kv/src/test/java/org/apache/samza/storage/kv/TestBaseKeyValueStorageEngineFactory.java