Skip to content
Snippets Groups Projects
Commit bbf0d3eb authored by Sören Henning's avatar Sören Henning
Browse files

Merge branch 'feature/renameToTheodolite' into 'master'

Rename Java Packages, Projects etc. to Theodolite

Closes #36

See merge request !8
parents 8aaea7bf 6f692bf6
No related branches found
No related tags found
1 merge request!8Rename Java Packages, Projects etc. to Theodolite
Pipeline #478 passed with warnings
Showing
with 28 additions and 28 deletions
package spesb.uc2.streamprocessing; package theodolite.uc2.streamprocessing;
import java.util.HashSet; import java.util.HashSet;
import java.util.Optional; import java.util.Optional;
......
package spesb.uc2.streamprocessing; package theodolite.uc2.streamprocessing;
import java.util.HashSet; import java.util.HashSet;
import java.util.Set; import java.util.Set;
......
package spesb.uc2.streamprocessing; package theodolite.uc2.streamprocessing;
import org.apache.kafka.streams.kstream.Windowed; import org.apache.kafka.streams.kstream.Windowed;
import titan.ccp.models.records.ActivePowerRecord; import titan.ccp.models.records.ActivePowerRecord;
......
package spesb.uc2.streamprocessing; package theodolite.uc2.streamprocessing;
/** /**
* A key consisting of the identifier of a sensor and an identifier of parent sensor. * A key consisting of the identifier of a sensor and an identifier of parent sensor.
......
package spesb.uc2.streamprocessing; package theodolite.uc2.streamprocessing;
import org.apache.kafka.common.serialization.Serde; import org.apache.kafka.common.serialization.Serde;
import titan.ccp.common.kafka.simpleserdes.BufferSerde; import titan.ccp.common.kafka.simpleserdes.BufferSerde;
......
package spesb.uc2.streamprocessing; package theodolite.uc2.streamprocessing;
import com.google.common.math.StatsAccumulator; import com.google.common.math.StatsAccumulator;
import java.time.Duration; import java.time.Duration;
......
package spesb.uc2.streamprocessing; package theodolite.uc2.streamprocessing;
import java.time.Duration; import java.time.Duration;
import java.util.Objects; import java.util.Objects;
import org.apache.kafka.streams.Topology; import org.apache.kafka.streams.Topology;
import spesb.commons.kafkastreams.KafkaStreamsBuilder; import theodolite.commons.kafkastreams.KafkaStreamsBuilder;
/** /**
* Builder for the Kafka Streams configuration. * Builder for the Kafka Streams configuration.
......
package spesb.uc2.streamprocessing; package theodolite.uc2.streamprocessing;
import java.util.Optional; import java.util.Optional;
import java.util.Set; import java.util.Set;
import org.junit.Test; import org.junit.Test;
import spesb.uc2.streamprocessing.OptionalParentsSerde; import theodolite.uc2.streamprocessing.OptionalParentsSerde;
public class OptionalParentsSerdeTest { public class OptionalParentsSerdeTest {
......
package spesb.uc2.streamprocessing; package theodolite.uc2.streamprocessing;
import java.util.Set; import java.util.Set;
import org.junit.Test; import org.junit.Test;
import spesb.uc2.streamprocessing.ParentsSerde; import theodolite.uc2.streamprocessing.ParentsSerde;
public class ParentsSerdeTest { public class ParentsSerdeTest {
......
package spesb.uc2.streamprocessing; package theodolite.uc2.streamprocessing;
import org.junit.Test; import org.junit.Test;
import spesb.uc2.streamprocessing.SensorParentKey; import theodolite.uc2.streamprocessing.SensorParentKey;
import spesb.uc2.streamprocessing.SensorParentKeySerde; import theodolite.uc2.streamprocessing.SensorParentKeySerde;
public class SensorParentKeySerdeTest { public class SensorParentKeySerdeTest {
......
package spesb.uc2.streamprocessing; package theodolite.uc2.streamprocessing;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import java.util.function.Function; import java.util.function.Function;
......
package spesb.uc2.streamprocessing; package theodolite.uc2.streamprocessing;
import org.apache.kafka.common.serialization.Serde; import org.apache.kafka.common.serialization.Serde;
......
mainClassName = "spesb.uc2.workloadgenerator.LoadGenerator" mainClassName = "theodolite.uc2.workloadgenerator.LoadGenerator"
package spesb.kafkasender; package theodolite.kafkasender;
import java.util.Properties; import java.util.Properties;
import java.util.function.Function; import java.util.function.Function;
......
package spesb.uc2.workloadgenerator; package theodolite.uc2.workloadgenerator;
import java.util.Properties; import java.util.Properties;
import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutionException;
......
package spesb.uc2.workloadgenerator; package theodolite.uc2.workloadgenerator;
import java.io.IOException; import java.io.IOException;
import java.util.List; import java.util.List;
...@@ -12,7 +12,7 @@ import java.util.stream.Collectors; ...@@ -12,7 +12,7 @@ import java.util.stream.Collectors;
import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.clients.producer.ProducerConfig;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import spesb.kafkasender.KafkaRecordSender; import theodolite.kafkasender.KafkaRecordSender;
import titan.ccp.configuration.events.Event; import titan.ccp.configuration.events.Event;
import titan.ccp.model.sensorregistry.MutableAggregatedSensor; import titan.ccp.model.sensorregistry.MutableAggregatedSensor;
import titan.ccp.model.sensorregistry.MutableSensorRegistry; import titan.ccp.model.sensorregistry.MutableSensorRegistry;
......
package spesb.uc2.workloadgenerator; package theodolite.uc2.workloadgenerator;
import java.io.IOException; import java.io.IOException;
import java.lang.management.ManagementFactory; import java.lang.management.ManagementFactory;
...@@ -10,7 +10,7 @@ import java.util.Properties; ...@@ -10,7 +10,7 @@ import java.util.Properties;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import java.util.stream.Stream; import java.util.stream.Stream;
import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.clients.producer.ProducerConfig;
import spesb.kafkasender.KafkaRecordSender; import theodolite.kafkasender.KafkaRecordSender;
import titan.ccp.configuration.events.Event; import titan.ccp.configuration.events.Event;
import titan.ccp.model.sensorregistry.MutableAggregatedSensor; import titan.ccp.model.sensorregistry.MutableAggregatedSensor;
import titan.ccp.model.sensorregistry.MutableSensorRegistry; import titan.ccp.model.sensorregistry.MutableSensorRegistry;
......
...@@ -10,4 +10,4 @@ dependencies { ...@@ -10,4 +10,4 @@ dependencies {
compile('org.industrial-devops:titan-ccp-common-kafka:0.1.0-SNAPSHOT') compile('org.industrial-devops:titan-ccp-common-kafka:0.1.0-SNAPSHOT')
} }
mainClassName = "spesb.uc3.application.HistoryService" mainClassName = "theodolite.uc3.application.HistoryService"
package spesb.uc3.application; package theodolite.uc3.application;
/** /**
* Keys to access configuration parameters. * Keys to access configuration parameters.
......
package spesb.uc3.application; package theodolite.uc3.application;
import java.time.Duration; import java.time.Duration;
import java.util.Objects; import java.util.Objects;
import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletableFuture;
import org.apache.commons.configuration2.Configuration; import org.apache.commons.configuration2.Configuration;
import org.apache.kafka.streams.KafkaStreams; import org.apache.kafka.streams.KafkaStreams;
import spesb.uc3.streamprocessing.Uc3KafkaStreamsBuilder; import theodolite.uc3.streamprocessing.Uc3KafkaStreamsBuilder;
import titan.ccp.common.configuration.Configurations; import titan.ccp.common.configuration.Configurations;
/** /**
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment