fpompermaier

services:
  federate:
    image: "docker.elastic.co/elasticsearch/elasticsearch:8.11.3"
    user: elasticsearch
    ports:
      - "5005:5005"
      - "9200:9200"
    volumes:
#      - ./plugin.zip:/tmp/plugin.zip
#      - /home/flavio/git/siren-platform/core/target/releases/siren-federate-8.11.1-34.0-SNAPSHOT-plugin.zip:/tmp/plugin.zip

fpompermaier

private static class CustomTrigger extends Trigger {
    
    
    private final long maxCount;
    private final long maxTime;
    
    private final ReducingStateDescriptor stateDesc = new ReducingStateDescriptor<>("count", new Sum(), LongSerializer.INSTANCE);
    private final ReducingStateDescriptor stateDesc2 = new ReducingStateDescriptor<>("fire-time",  new Min(), LongSerializer.INSTANCE);

    private CustomTrigger(long maxTime, long maxCount) {