15 секунд Средняя скорость и ускорение и замена значений в следующих потоках

Question

 KTable<Windowed<String>,Demo1> windowstream = dummy1
                .groupByKey(Serialized.with(Serializer.getSerde(String.class), Serializer.getSerde(Demo1.class)))
                .windowedBy(TimeWindows.of(TimeUnit.SECONDS.toMillis(15))).aggregate(new Initializer<Demo1>() {
                    @Override
                    public Demo1 apply() {

                        return new Demo1();
                    }
                }, new Aggregator<String, Demo1, Demo1>() {
                    @Override
                    public Demo1 apply(String key, Demo1 value, Demo1 aggregate) {

                        double u=  value.getspeed();
                        double v= value.getaccelraton();
                        System.out.println("Speed====" + value.getspeed() + "Accelration===" + value.getaccelraton());
                        return aggregate;
                    }
                });

Этот код выполняется, но я хочу взять среднее значение скорости и ускорения и заменить значения обоих объектов в данных предстоящего потока.