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
