public TurbineSensorMessageModel reduce()

in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics/TurbineSpeedAggregator.java [96:105]

• 10 lines of code
• 3 McCabe index (conditional complexity)

        public TurbineSensorMessageModel reduce(TurbineSensorMessageModel value1, TurbineSensorMessageModel value2) {
            TurbineSensorMessageModel reducedSensorMessageModel = new TurbineSensorMessageModel();
            reducedSensorMessageModel.turbineId = value2.turbineId;
            reducedSensorMessageModel.speed = value2.speed;
            reducedSensorMessageModel.messageCount = value1.messageCount + value2.messageCount;
            reducedSensorMessageModel.sumSpeed = value1.sumSpeed + value2.sumSpeed;
            reducedSensorMessageModel.minSpeed = value1.minSpeed < value2.sumSpeed ? value1.minSpeed : value2.minSpeed;
            reducedSensorMessageModel.maxSpeed = value1.maxSpeed > value2.maxSpeed ? value1.maxSpeed : value2.maxSpeed;
            return reducedSensorMessageModel;
        }