#region License Information /* HeuristicLab * Copyright (C) 2002-2015 Heuristic and Evolutionary Algorithms Laboratory (HEAL) * * This file is part of HeuristicLab. * * HeuristicLab is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * HeuristicLab is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with HeuristicLab. If not, see . */ #endregion using System; using System.Collections.Generic; using System.Linq; using HeuristicLab.Common; using HeuristicLab.Core; using HeuristicLab.Data; using HeuristicLab.Parameters; using HeuristicLab.Persistence.Default.CompositeSerializers.Storable; namespace HeuristicLab.Operators { [Item("DataReducer", "An operator to reduce values of sub scopes.")] [StorableType("D7991E17-265C-4FAA-8531-C6A936EC22DE")] public sealed class DataReducer : SingleSuccessorOperator { #region Parameter Properties public ScopeTreeLookupParameter ParameterToReduce { get { return (ScopeTreeLookupParameter)Parameters["ParameterToReduce"]; } } public LookupParameter TargetParameter { get { return (LookupParameter)Parameters["TargetParameter"]; } } public ValueLookupParameter ReductionOperation { get { return (ValueLookupParameter)Parameters["ReductionOperation"]; } } public ValueLookupParameter TargetOperation { get { return (ValueLookupParameter)Parameters["TargetOperation"]; } } #endregion [StorableConstructor] private DataReducer(bool deserializing) : base(deserializing) { } private DataReducer(DataReducer original, Cloner cloner) : base(original, cloner) { } public DataReducer() : base() { #region Create parameters Parameters.Add(new ScopeTreeLookupParameter("ParameterToReduce", "The parameter on which the reduction operation should be applied.")); Parameters.Add(new LookupParameter("TargetParameter", "The target variable in which the reduced value should be stored.")); Parameters.Add(new ValueLookupParameter("ReductionOperation", "The operation which is applied on the parameters to reduce.", new ReductionOperation())); Parameters.Add(new ValueLookupParameter("TargetOperation", "The operation used to apply the reduced value to the target variable.", new ReductionOperation())); #endregion } public override IDeepCloneable Clone(Cloner cloner) { return new DataReducer(this, cloner); } [StorableHook(HookType.AfterDeserialization)] private void AfterDeserialization() { // BackwardsCompatibility3.3 var oldReductionOperation = Parameters["ReductionOperation"] as ValueParameter; if (oldReductionOperation != null) { Parameters.Remove("ReductionOperation"); Parameters.Add(new ValueLookupParameter("ReductionOperation", "The operation which is applied on the parameters to reduce.", oldReductionOperation.Value)); } var oldTargetOperation = Parameters["TargetOperation"] as ValueParameter; if (oldTargetOperation != null) { Parameters.Remove("TargetOperation"); Parameters.Add(new ValueLookupParameter("TargetOperation", "The operation used to apply the reduced value to the target variable.", oldTargetOperation.Value)); } } public override IOperation Apply() { var values = ParameterToReduce.ActualValue; if (!values.Any()) return base.Apply(); if (values.All(x => x is IntValue)) { CalculateResult(values.OfType().Select(x => x.Value), values.First().GetType()); } else if (values.All(x => x is DoubleValue)) { CalculateResult(values.OfType().Select(x => x.Value), values.First().GetType()); } else if (values.All(x => x is TimeSpanValue)) { CalculateResult(values.OfType().Select(x => x.Value), values.First().GetType()); } else if (values.All(x => x is BoolValue)) { CalculateResult(values.OfType().Select(x => x.Value), values.First().GetType()); } else { throw new ArgumentException(string.Format("MemberSelection {0} is not supported by the DataReducer.", values.First().GetType())); } return base.Apply(); } #region integer reduction private void CalculateResult(IEnumerable values, Type targetType) { int result; switch (ReductionOperation.ActualValue.Value) { case ReductionOperations.Sum: result = values.Sum(); break; case ReductionOperations.Product: result = values.Aggregate(1, (x, y) => x * y); break; case ReductionOperations.Count: result = values.Count(); break; case ReductionOperations.Min: result = values.Min(); break; case ReductionOperations.Max: result = values.Max(); break; case ReductionOperations.Avg: result = (int)Math.Round(values.Average()); break; case ReductionOperations.Assign: result = values.Last(); break; default: throw new InvalidOperationException(string.Format("Operation {0} is not supported as ReductionOperation for type: {1}.", ReductionOperation.ActualValue.Value, targetType)); } IntValue target; switch (TargetOperation.ActualValue.Value) { case ReductionOperations.Sum: target = InitializeTarget(targetType, 0); target.Value += result; break; case ReductionOperations.Product: target = InitializeTarget(targetType, 1); target.Value = target.Value * result; break; case ReductionOperations.Min: target = InitializeTarget(targetType, int.MaxValue); target.Value = Math.Min(target.Value, result); break; case ReductionOperations.Max: target = InitializeTarget(targetType, int.MinValue); target.Value = Math.Max(target.Value, result); break; case ReductionOperations.Avg: target = InitializeTarget(targetType, result); target.Value = (int)Math.Round((target.Value + result) / 2.0); break; case ReductionOperations.Assign: target = InitializeTarget(targetType, 0); target.Value = result; break; default: throw new InvalidOperationException(string.Format("Operation {0} is not supported as TargetOperation for type: {1}.", TargetOperation.ActualValue.Value, targetType)); } } #endregion #region double reduction private void CalculateResult(IEnumerable values, Type targetType) { double result; switch (ReductionOperation.ActualValue.Value) { case ReductionOperations.Sum: result = values.Sum(); break; case ReductionOperations.Product: result = values.Aggregate(1.0, (x, y) => x * y); break; case ReductionOperations.Count: result = values.Count(); break; case ReductionOperations.Min: result = values.Min(); break; case ReductionOperations.Max: result = values.Max(); break; case ReductionOperations.Avg: result = values.Average(); break; case ReductionOperations.Assign: result = values.Last(); break; default: throw new InvalidOperationException(string.Format("Operation {0} is not supported as ReductionOperation for type: {1}.", ReductionOperation.ActualValue.Value, targetType)); } DoubleValue target; switch (TargetOperation.ActualValue.Value) { case ReductionOperations.Sum: target = InitializeTarget(targetType, 0.0); target.Value += result; break; case ReductionOperations.Product: target = InitializeTarget(targetType, 1.0); target.Value = target.Value * result; break; case ReductionOperations.Min: target = InitializeTarget(targetType, double.MaxValue); target.Value = Math.Min(target.Value, result); break; case ReductionOperations.Max: target = InitializeTarget(targetType, double.MinValue); target.Value = Math.Max(target.Value, result); break; case ReductionOperations.Avg: target = InitializeTarget(targetType, result); target.Value = (target.Value + result) / 2.0; break; case ReductionOperations.Assign: target = InitializeTarget(targetType, 0.0); target.Value = result; break; default: throw new InvalidOperationException(string.Format("Operation {0} is not supported as TargetOperation for type: {1}.", TargetOperation.ActualValue.Value, targetType)); } } #endregion #region TimeSpan reduction private void CalculateResult(IEnumerable values, Type targetType) { TimeSpan result; switch (ReductionOperation.ActualValue.Value) { case ReductionOperations.Sum: result = values.Aggregate(new TimeSpan(), (x, y) => x + y); break; case ReductionOperations.Min: result = values.Min(); break; case ReductionOperations.Max: result = values.Max(); break; case ReductionOperations.Avg: result = TimeSpan.FromMilliseconds(values.Average(x => x.TotalMilliseconds)); break; case ReductionOperations.Assign: result = values.Last(); break; default: throw new InvalidOperationException(string.Format("Operation {0} is not supported as ReductionOperation for type: {1}.", ReductionOperation.ActualValue.Value, targetType)); } TimeSpanValue target; switch (TargetOperation.ActualValue.Value) { case ReductionOperations.Sum: target = InitializeTarget(targetType, new TimeSpan()); target.Value += result; break; case ReductionOperations.Min: target = InitializeTarget(targetType, TimeSpan.MaxValue); target.Value = target.Value < result ? target.Value : result; break; case ReductionOperations.Max: target = InitializeTarget(targetType, TimeSpan.MinValue); target.Value = target.Value > result ? target.Value : result; break; case ReductionOperations.Avg: target = InitializeTarget(targetType, result); target.Value = TimeSpan.FromMilliseconds((target.Value.TotalMilliseconds + result.TotalMilliseconds) / 2); break; case ReductionOperations.Assign: target = InitializeTarget(targetType, new TimeSpan()); target.Value = result; break; default: throw new InvalidOperationException(string.Format("Operation {0} is not supported as TargetOperation for type: {1}.", TargetOperation.ActualValue.Value, targetType)); } } #endregion #region bool reduction private void CalculateResult(IEnumerable values, Type targetType) { bool result; switch (ReductionOperation.ActualValue.Value) { case ReductionOperations.All: result = values.All(x => x); break; case ReductionOperations.Any: result = values.Any(x => x); break; default: throw new InvalidOperationException(string.Format("Operation {0} is not supported as ReductionOperation for type: {1}.", ReductionOperation.ActualValue.Value, targetType)); } BoolValue target; switch (TargetOperation.ActualValue.Value) { case ReductionOperations.Assign: target = InitializeTarget(targetType, true); target.Value = result; break; default: throw new InvalidOperationException(string.Format("Operation {0} is not supported as TargetOperation for type: {1}.", TargetOperation.ActualValue.Value, targetType)); } } #endregion #region helpers private T1 InitializeTarget(Type targetType, T2 initialValue) where T1 : ValueTypeValue where T2 : struct { T1 target = (T1)TargetParameter.ActualValue; if (target == null) { target = (T1)Activator.CreateInstance(targetType); TargetParameter.ActualValue = target; target.Value = initialValue; } return target; } #endregion } }