diff --git a/theodolite-benchmarks/beam-commons/build.gradle b/theodolite-benchmarks/beam-commons/build.gradle index 64ac2bb51ae1e6d741749a81e5c6c9e296d14d68..34a98212cdca9b347027c8e1c915044d55514b9c 100644 --- a/theodolite-benchmarks/beam-commons/build.gradle +++ b/theodolite-benchmarks/beam-commons/build.gradle @@ -13,8 +13,7 @@ repositories { } dependencies { - implementation('org.industrial-devops:titan-ccp-common:0.1.0-SNAPSHOT') { changing = true } - implementation('org.industrial-devops:titan-ccp-common-kafka:0.1.0-SNAPSHOT') { changing = true } + implementation project(':commons') implementation group: 'org.apache.beam', name: 'beam-sdks-java-core', version: '2.35.0' implementation('org.apache.beam:beam-sdks-java-io-kafka:2.35.0'){ diff --git a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/ActivePowerRecord.java b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/ActivePowerRecord.java index 3754b314b7a81dc1f0e219c3d0bee70549e452e4..f5df311856c711f17372b3e5ca9da2b6b224f86d 100644 --- a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/ActivePowerRecord.java +++ b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/ActivePowerRecord.java @@ -131,6 +131,14 @@ public class ActivePowerRecord extends org.apache.avro.specific.SpecificRecordBa } + /** + * Sets the value of the 'identifier' field. + * * + * @param value the value to set. + */ + public void setIdentifier(java.lang.String value) { + this.identifier = value; + } /** * Gets the value of the 'timestamp' field. @@ -141,6 +149,14 @@ public class ActivePowerRecord extends org.apache.avro.specific.SpecificRecordBa } + /** + * Sets the value of the 'timestamp' field. + * * + * @param value the value to set. + */ + public void setTimestamp(long value) { + this.timestamp = value; + } /** * Gets the value of the 'valueInW' field. @@ -151,6 +167,14 @@ public class ActivePowerRecord extends org.apache.avro.specific.SpecificRecordBa } + /** + * Sets the value of the 'valueInW' field. + * * + * @param value the value to set. + */ + public void setValueInW(double value) { + this.valueInW = value; + } /** * Creates a new ActivePowerRecord RecordBuilder. diff --git a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/AggregatedActivePowerRecord.java b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/AggregatedActivePowerRecord.java index af52ecff4f702e887bf6e6112ddea952983a90ef..ab7d4d143a594097094c28f05922163412888c4a 100644 --- a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/AggregatedActivePowerRecord.java +++ b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/AggregatedActivePowerRecord.java @@ -143,6 +143,14 @@ public class AggregatedActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'identifier' field. + * * + * @param value the value to set. + */ + public void setIdentifier(java.lang.String value) { + this.identifier = value; + } /** * Gets the value of the 'timestamp' field. @@ -153,6 +161,14 @@ public class AggregatedActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'timestamp' field. + * * + * @param value the value to set. + */ + public void setTimestamp(long value) { + this.timestamp = value; + } /** * Gets the value of the 'count' field. @@ -163,6 +179,14 @@ public class AggregatedActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'count' field. + * * + * @param value the value to set. + */ + public void setCount(long value) { + this.count = value; + } /** * Gets the value of the 'sumInW' field. @@ -173,6 +197,14 @@ public class AggregatedActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'sumInW' field. + * * + * @param value the value to set. + */ + public void setSumInW(double value) { + this.sumInW = value; + } /** * Gets the value of the 'averageInW' field. @@ -183,6 +215,14 @@ public class AggregatedActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'averageInW' field. + * * + * @param value the value to set. + */ + public void setAverageInW(double value) { + this.averageInW = value; + } /** * Creates a new AggregatedActivePowerRecord RecordBuilder. diff --git a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/DayOfWeekActivePowerRecord.java b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/DayOfWeekActivePowerRecord.java index bc7659649d3832d86f3893b162675d4096177de0..c53c3192f1438db21edb7a40585a202df8bc7296 100644 --- a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/DayOfWeekActivePowerRecord.java +++ b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/DayOfWeekActivePowerRecord.java @@ -158,6 +158,13 @@ public class DayOfWeekActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'identifier' field. + * @param value the value to set. + */ + public void setIdentifier(java.lang.String value) { + this.identifier = value; + } /** * Gets the value of the 'dayOfWeek' field. @@ -168,6 +175,13 @@ public class DayOfWeekActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'dayOfWeek' field. + * @param value the value to set. + */ + public void setDayOfWeek(int value) { + this.dayOfWeek = value; + } /** * Gets the value of the 'periodStart' field. @@ -178,6 +192,13 @@ public class DayOfWeekActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'periodStart' field. + * @param value the value to set. + */ + public void setPeriodStart(long value) { + this.periodStart = value; + } /** * Gets the value of the 'periodEnd' field. @@ -188,6 +209,13 @@ public class DayOfWeekActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'periodEnd' field. + * @param value the value to set. + */ + public void setPeriodEnd(long value) { + this.periodEnd = value; + } /** * Gets the value of the 'count' field. @@ -198,6 +226,13 @@ public class DayOfWeekActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'count' field. + * @param value the value to set. + */ + public void setCount(long value) { + this.count = value; + } /** * Gets the value of the 'mean' field. @@ -208,6 +243,13 @@ public class DayOfWeekActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'mean' field. + * @param value the value to set. + */ + public void setMean(double value) { + this.mean = value; + } /** * Gets the value of the 'populationVariance' field. @@ -218,6 +260,13 @@ public class DayOfWeekActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'populationVariance' field. + * @param value the value to set. + */ + public void setPopulationVariance(double value) { + this.populationVariance = value; + } /** * Gets the value of the 'min' field. @@ -228,6 +277,13 @@ public class DayOfWeekActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'min' field. + * @param value the value to set. + */ + public void setMin(double value) { + this.min = value; + } /** * Gets the value of the 'max' field. @@ -238,6 +294,13 @@ public class DayOfWeekActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'max' field. + * @param value the value to set. + */ + public void setMax(double value) { + this.max = value; + } /** * Creates a new DayOfWeekActivePowerRecord RecordBuilder. diff --git a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/HourOfDayActivePowerRecord.java b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/HourOfDayActivePowerRecord.java index 2ab363dffe03d4d5fa97610d56478eadd42d5a06..154109665c779b1a1181887fc6fa3ac07677fb01 100644 --- a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/HourOfDayActivePowerRecord.java +++ b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/HourOfDayActivePowerRecord.java @@ -158,6 +158,13 @@ public class HourOfDayActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'identifier' field. + * @param value the value to set. + */ + public void setIdentifier(java.lang.String value) { + this.identifier = value; + } /** * Gets the value of the 'hourOfDay' field. @@ -168,6 +175,13 @@ public class HourOfDayActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'hourOfDay' field. + * @param value the value to set. + */ + public void setHourOfDay(int value) { + this.hourOfDay = value; + } /** * Gets the value of the 'periodStart' field. @@ -178,6 +192,13 @@ public class HourOfDayActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'periodStart' field. + * @param value the value to set. + */ + public void setPeriodStart(long value) { + this.periodStart = value; + } /** * Gets the value of the 'periodEnd' field. @@ -188,6 +209,13 @@ public class HourOfDayActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'periodEnd' field. + * @param value the value to set. + */ + public void setPeriodEnd(long value) { + this.periodEnd = value; + } /** * Gets the value of the 'count' field. @@ -198,6 +226,13 @@ public class HourOfDayActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'count' field. + * @param value the value to set. + */ + public void setCount(long value) { + this.count = value; + } /** * Gets the value of the 'mean' field. @@ -208,6 +243,13 @@ public class HourOfDayActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'mean' field. + * @param value the value to set. + */ + public void setMean(double value) { + this.mean = value; + } /** * Gets the value of the 'populationVariance' field. @@ -218,6 +260,13 @@ public class HourOfDayActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'populationVariance' field. + * @param value the value to set. + */ + public void setPopulationVariance(double value) { + this.populationVariance = value; + } /** * Gets the value of the 'min' field. @@ -228,6 +277,13 @@ public class HourOfDayActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'min' field. + * @param value the value to set. + */ + public void setMin(double value) { + this.min = value; + } /** * Gets the value of the 'max' field. @@ -238,6 +294,13 @@ public class HourOfDayActivePowerRecord extends org.apache.avro.specific.Specifi } + /** + * Sets the value of the 'max' field. + * @param value the value to set. + */ + public void setMax(double value) { + this.max = value; + } /** * Creates a new HourOfDayActivePowerRecord RecordBuilder. diff --git a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/HourOfWeekActivePowerRecord.java b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/HourOfWeekActivePowerRecord.java index 818c5558a247c4c9014898cf1f9106bcfee25304..6bb063d21f620b5d5ad2073be3ea5756e835223b 100644 --- a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/HourOfWeekActivePowerRecord.java +++ b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/HourOfWeekActivePowerRecord.java @@ -163,6 +163,13 @@ public class HourOfWeekActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'identifier' field. + * @param value the value to set. + */ + public void setIdentifier(java.lang.String value) { + this.identifier = value; + } /** * Gets the value of the 'dayOfWeek' field. @@ -173,6 +180,13 @@ public class HourOfWeekActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'dayOfWeek' field. + * @param value the value to set. + */ + public void setDayOfWeek(int value) { + this.dayOfWeek = value; + } /** * Gets the value of the 'hourOfDay' field. @@ -183,6 +197,13 @@ public class HourOfWeekActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'hourOfDay' field. + * @param value the value to set. + */ + public void setHourOfDay(int value) { + this.hourOfDay = value; + } /** * Gets the value of the 'periodStart' field. @@ -193,6 +214,13 @@ public class HourOfWeekActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'periodStart' field. + * @param value the value to set. + */ + public void setPeriodStart(long value) { + this.periodStart = value; + } /** * Gets the value of the 'periodEnd' field. @@ -203,6 +231,13 @@ public class HourOfWeekActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'periodEnd' field. + * @param value the value to set. + */ + public void setPeriodEnd(long value) { + this.periodEnd = value; + } /** * Gets the value of the 'count' field. @@ -213,6 +248,13 @@ public class HourOfWeekActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'count' field. + * @param value the value to set. + */ + public void setCount(long value) { + this.count = value; + } /** * Gets the value of the 'mean' field. @@ -223,6 +265,13 @@ public class HourOfWeekActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'mean' field. + * @param value the value to set. + */ + public void setMean(double value) { + this.mean = value; + } /** * Gets the value of the 'populationVariance' field. @@ -233,6 +282,13 @@ public class HourOfWeekActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'populationVariance' field. + * @param value the value to set. + */ + public void setPopulationVariance(double value) { + this.populationVariance = value; + } /** * Gets the value of the 'min' field. @@ -243,6 +299,13 @@ public class HourOfWeekActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'min' field. + * @param value the value to set. + */ + public void setMin(double value) { + this.min = value; + } /** * Gets the value of the 'max' field. @@ -253,6 +316,13 @@ public class HourOfWeekActivePowerRecord extends org.apache.avro.specific.Specif } + /** + * Sets the value of the 'max' field. + * @param value the value to set. + */ + public void setMax(double value) { + this.max = value; + } /** * Creates a new HourOfWeekActivePowerRecord RecordBuilder. diff --git a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/MonthOfYearActivePowerRecord.java b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/MonthOfYearActivePowerRecord.java index 07e7415aacf83a8b82ad32945d9bc7547d4bf6c5..a76f31c0d88bd798b2c1936c294201bad5d0683e 100644 --- a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/MonthOfYearActivePowerRecord.java +++ b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/MonthOfYearActivePowerRecord.java @@ -158,6 +158,13 @@ public class MonthOfYearActivePowerRecord extends org.apache.avro.specific.Speci } + /** + * Sets the value of the 'identifier' field. + * @param value the value to set. + */ + public void setIdentifier(java.lang.String value) { + this.identifier = value; + } /** * Gets the value of the 'monthOfYear' field. @@ -168,6 +175,13 @@ public class MonthOfYearActivePowerRecord extends org.apache.avro.specific.Speci } + /** + * Sets the value of the 'monthOfYear' field. + * @param value the value to set. + */ + public void setMonthOfYear(int value) { + this.monthOfYear = value; + } /** * Gets the value of the 'periodStart' field. @@ -178,6 +192,13 @@ public class MonthOfYearActivePowerRecord extends org.apache.avro.specific.Speci } + /** + * Sets the value of the 'periodStart' field. + * @param value the value to set. + */ + public void setPeriodStart(long value) { + this.periodStart = value; + } /** * Gets the value of the 'periodEnd' field. @@ -188,6 +209,13 @@ public class MonthOfYearActivePowerRecord extends org.apache.avro.specific.Speci } + /** + * Sets the value of the 'periodEnd' field. + * @param value the value to set. + */ + public void setPeriodEnd(long value) { + this.periodEnd = value; + } /** * Gets the value of the 'count' field. @@ -198,6 +226,13 @@ public class MonthOfYearActivePowerRecord extends org.apache.avro.specific.Speci } + /** + * Sets the value of the 'count' field. + * @param value the value to set. + */ + public void setCount(long value) { + this.count = value; + } /** * Gets the value of the 'mean' field. @@ -208,6 +243,13 @@ public class MonthOfYearActivePowerRecord extends org.apache.avro.specific.Speci } + /** + * Sets the value of the 'mean' field. + * @param value the value to set. + */ + public void setMean(double value) { + this.mean = value; + } /** * Gets the value of the 'populationVariance' field. @@ -218,6 +260,13 @@ public class MonthOfYearActivePowerRecord extends org.apache.avro.specific.Speci } + /** + * Sets the value of the 'populationVariance' field. + * @param value the value to set. + */ + public void setPopulationVariance(double value) { + this.populationVariance = value; + } /** * Gets the value of the 'min' field. @@ -228,6 +277,13 @@ public class MonthOfYearActivePowerRecord extends org.apache.avro.specific.Speci } + /** + * Sets the value of the 'min' field. + * @param value the value to set. + */ + public void setMin(double value) { + this.min = value; + } /** * Gets the value of the 'max' field. @@ -238,6 +294,13 @@ public class MonthOfYearActivePowerRecord extends org.apache.avro.specific.Speci } + /** + * Sets the value of the 'max' field. + * @param value the value to set. + */ + public void setMax(double value) { + this.max = value; + } /** * Creates a new MonthOfYearActivePowerRecord RecordBuilder. diff --git a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/YearActivePowerRecord.java b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/YearActivePowerRecord.java index 189cb8cf61b9f66c48e43ecc59fecd31d048a3c5..448d1ba5a885a4ad590794e56dddb400ac0991bd 100644 --- a/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/YearActivePowerRecord.java +++ b/theodolite-benchmarks/commons/src-gen/main/java/rocks/theodolite/commons/model/records/YearActivePowerRecord.java @@ -158,6 +158,13 @@ public class YearActivePowerRecord extends org.apache.avro.specific.SpecificReco } + /** + * Sets the value of the 'identifier' field. + * @param value the value to set. + */ + public void setIdentifier(java.lang.String value) { + this.identifier = value; + } /** * Gets the value of the 'year' field. @@ -168,6 +175,13 @@ public class YearActivePowerRecord extends org.apache.avro.specific.SpecificReco } + /** + * Sets the value of the 'year' field. + * @param value the value to set. + */ + public void setYear(int value) { + this.year = value; + } /** * Gets the value of the 'periodStart' field. @@ -178,6 +192,13 @@ public class YearActivePowerRecord extends org.apache.avro.specific.SpecificReco } + /** + * Sets the value of the 'periodStart' field. + * @param value the value to set. + */ + public void setPeriodStart(long value) { + this.periodStart = value; + } /** * Gets the value of the 'periodEnd' field. @@ -188,6 +209,13 @@ public class YearActivePowerRecord extends org.apache.avro.specific.SpecificReco } + /** + * Sets the value of the 'periodEnd' field. + * @param value the value to set. + */ + public void setPeriodEnd(long value) { + this.periodEnd = value; + } /** * Gets the value of the 'count' field. @@ -198,6 +226,13 @@ public class YearActivePowerRecord extends org.apache.avro.specific.SpecificReco } + /** + * Sets the value of the 'count' field. + * @param value the value to set. + */ + public void setCount(long value) { + this.count = value; + } /** * Gets the value of the 'mean' field. @@ -208,6 +243,13 @@ public class YearActivePowerRecord extends org.apache.avro.specific.SpecificReco } + /** + * Sets the value of the 'mean' field. + * @param value the value to set. + */ + public void setMean(double value) { + this.mean = value; + } /** * Gets the value of the 'populationVariance' field. @@ -218,6 +260,13 @@ public class YearActivePowerRecord extends org.apache.avro.specific.SpecificReco } + /** + * Sets the value of the 'populationVariance' field. + * @param value the value to set. + */ + public void setPopulationVariance(double value) { + this.populationVariance = value; + } /** * Gets the value of the 'min' field. @@ -228,6 +277,13 @@ public class YearActivePowerRecord extends org.apache.avro.specific.SpecificReco } + /** + * Sets the value of the 'min' field. + * @param value the value to set. + */ + public void setMin(double value) { + this.min = value; + } /** * Gets the value of the 'max' field. @@ -238,6 +294,13 @@ public class YearActivePowerRecord extends org.apache.avro.specific.SpecificReco } + /** + * Sets the value of the 'max' field. + * @param value the value to set. + */ + public void setMax(double value) { + this.max = value; + } /** * Creates a new YearActivePowerRecord RecordBuilder.