fhussonnois

[
  {
    "name": "Count",
    "partition_restore_infos": [
      {
        "starting_offset": 0,
        "ending_offset": 0,
        "total_restored": 0,
        "duration": "PT0.102756S",
        "partition": 0,

fhussonnois

group 'org.example'
version '1.0'

buildscript {
    repositories {
        jcenter()
    }
    dependencies {
        classpath 'com.github.jengelman.gradle.plugins:shadow:6.1.0'
    }

fhussonnois

public class DeduplicationTransformer<K, V, E> implements ValueTransformerWithKey<K, V, V> {

    private ProcessorContext context;

    private WindowStore<E, Long> eventIdStore;

    private final String storeName;

    private final KeyValueMapper<K, V, E> idExtractor;