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