diff --git a/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/RecordDatabaseAdapter.java b/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/RecordDatabaseAdapter.java deleted file mode 100644 index 111e262289ba25b6a41c65d0144119342efa2c52..0000000000000000000000000000000000000000 --- a/theodolite-benchmarks/uc3-kstreams/src/main/java/rocks/theodolite/benchmarks/uc3/kstreams/RecordDatabaseAdapter.java +++ /dev/null @@ -1,85 +0,0 @@ -package rocks.theodolite.benchmarks.uc3.kstreams; - -import java.util.Collection; -import java.util.List; -import org.apache.avro.specific.SpecificRecord; - -/** - * Holds the property names for a statistics record (which is an Avro record). - * - * @param <T> Record type this adapter is for. - */ -public class RecordDatabaseAdapter<T extends SpecificRecord> { - - private static final String DEFAULT_IDENTIFIER_FIELD = "identifier"; - private static final String DEFAULT_PERIOD_START_FIELD = "periodStart"; - private static final String DEFAULT_PERIOD_END_FIELD = "periodEnd"; - - private final Class<? extends T> clazz; - private final String identifierField; - private final Collection<String> timeUnitFields; - private final String periodStartField; - private final String periodEndField; - - /** - * Create a new {@link RecordDatabaseAdapter} for the given record type by setting its time unit - * property (e.g., day of week or hour of day) and default fields for the other properties. - */ - public RecordDatabaseAdapter(final Class<? extends T> clazz, final String timeUnitField) { - this(clazz, - DEFAULT_IDENTIFIER_FIELD, - List.of(timeUnitField), - DEFAULT_PERIOD_START_FIELD, - DEFAULT_PERIOD_END_FIELD); - } - - /** - * Create a new {@link RecordDatabaseAdapter} for the given record type by setting its time unit - * properties (e.g., day of week and hour of day) and default fields for the other properties. - */ - public RecordDatabaseAdapter(final Class<? extends T> clazz, - final Collection<String> timeUnitFields) { - this(clazz, - DEFAULT_IDENTIFIER_FIELD, - timeUnitFields, - DEFAULT_PERIOD_START_FIELD, - DEFAULT_PERIOD_END_FIELD); - } - - /** - * Create a new {@link RecordDatabaseAdapter} for the given record type by setting all its - * required properties. - */ - public RecordDatabaseAdapter(final Class<? extends T> clazz, - final String identifierField, - final Collection<String> timeUnitField, - final String periodStartField, - final String periodEndField) { - this.clazz = clazz; - this.identifierField = identifierField; - this.timeUnitFields = timeUnitField; - this.periodStartField = periodStartField; - this.periodEndField = periodEndField; - } - - public Class<? extends T> getClazz() { - return this.clazz; - } - - public String getIdentifierField() { - return this.identifierField; - } - - public Collection<String> getTimeUnitFields() { - return this.timeUnitFields; - } - - public String getPeriodStartField() { - return this.periodStartField; - } - - public String getPeriodEndField() { - return this.periodEndField; - } - -}