Skip to content
Snippets Groups Projects
Commit 599efba5 authored by Björn Vonheiden's avatar Björn Vonheiden
Browse files

Replace spesb with theodolite at all places

The Project is renamed to theodolite and therefore all packages
should be renamed likewise.
parent c9a56f5b
No related branches found
No related tags found
No related merge requests found
Showing
with 24 additions and 24 deletions
mainClassName = "spesb.uc3.workloadgenerator.LoadGenerator"
mainClassName = "theodolite.uc3.workloadgenerator.LoadGenerator"
package spesb.kafkasender;
package theodolite.kafkasender;
import java.util.Properties;
import java.util.function.Function;
......
......
package spesb.uc3.workloadgenerator;
package theodolite.uc3.workloadgenerator;
import java.io.IOException;
import java.util.List;
......@@ -14,7 +14,7 @@ import java.util.stream.IntStream;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import spesb.kafkasender.KafkaRecordSender;
import theodolite.kafkasender.KafkaRecordSender;
import titan.ccp.models.records.ActivePowerRecord;
public class LoadGenerator {
......
......
......@@ -10,4 +10,4 @@ dependencies {
compile('org.industrial-devops:titan-ccp-common-kafka:0.1.0-SNAPSHOT')
}
mainClassName = "spesb.uc4.application.HistoryService"
mainClassName = "theodolite.uc4.application.HistoryService"
package spesb.uc4.application;
package theodolite.uc4.application;
/**
* Keys to access configuration parameters.
......
......
package spesb.uc4.application;
package theodolite.uc4.application;
import java.time.Duration;
import java.util.concurrent.CompletableFuture;
import org.apache.commons.configuration2.Configuration;
import org.apache.kafka.streams.KafkaStreams;
import spesb.uc4.streamprocessing.Uc4KafkaStreamsBuilder;
import theodolite.uc4.streamprocessing.Uc4KafkaStreamsBuilder;
import titan.ccp.common.configuration.Configurations;
/**
......
......
package spesb.uc4.streamprocessing;
package theodolite.uc4.streamprocessing;
/**
* Composed key of an hour of the day and a sensor id.
......
......
package spesb.uc4.streamprocessing;
package theodolite.uc4.streamprocessing;
import java.time.LocalDateTime;
......
......
package spesb.uc4.streamprocessing;
package theodolite.uc4.streamprocessing;
import org.apache.kafka.common.serialization.Serde;
import titan.ccp.common.kafka.simpleserdes.BufferSerde;
......
......
package spesb.uc4.streamprocessing;
package theodolite.uc4.streamprocessing;
import com.google.common.math.Stats;
import org.apache.kafka.streams.kstream.Windowed;
......
......
package spesb.uc4.streamprocessing;
package theodolite.uc4.streamprocessing;
import java.util.Collection;
import java.util.List;
......
......
package spesb.uc4.streamprocessing;
package theodolite.uc4.streamprocessing;
import java.time.LocalDateTime;
......
......
package spesb.uc4.streamprocessing;
package theodolite.uc4.streamprocessing;
import com.google.common.math.Stats;
import org.apache.avro.specific.SpecificRecord;
......
......
package spesb.uc4.streamprocessing;
package theodolite.uc4.streamprocessing;
import com.google.common.math.Stats;
import java.time.Duration;
......@@ -15,7 +15,7 @@ import org.apache.kafka.streams.kstream.Grouped;
import org.apache.kafka.streams.kstream.Materialized;
import org.apache.kafka.streams.kstream.Produced;
import org.apache.kafka.streams.kstream.TimeWindows;
import spesb.uc4.streamprocessing.util.StatsFactory;
import theodolite.uc4.streamprocessing.util.StatsFactory;
import titan.ccp.common.kafka.GenericSerde;
import titan.ccp.common.kieker.kafka.IMonitoringRecordSerde;
import titan.ccp.models.records.ActivePowerRecordFactory;
......
......
package spesb.uc4.streamprocessing;
package theodolite.uc4.streamprocessing;
import java.time.Duration;
import java.util.Objects;
import org.apache.kafka.streams.Topology;
import spesb.commons.kafkastreams.KafkaStreamsBuilder;
import theodolite.commons.kafkastreams.KafkaStreamsBuilder;
/**
* Builder for the Kafka Streams configuration.
......
......
package spesb.uc3.streamprocessing.util;
package theodolite.uc4.streamprocessing.util;
import com.google.common.math.Stats;
import com.google.common.math.StatsAccumulator;
......
......
mainClassName = "spesb.uc4.workloadgenerator.LoadGenerator"
mainClassName = "theodolite.uc4.workloadgenerator.LoadGenerator"
package spesb.kafkasender;
package theodolite.kafkasender;
import java.util.Properties;
import java.util.function.Function;
......
......
package spesb.uc4.workloadgenerator;
package theodolite.uc4.workloadgenerator;
import java.io.IOException;
import java.util.List;
......@@ -13,7 +13,7 @@ import java.util.stream.IntStream;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import spesb.kafkasender.KafkaRecordSender;
import theodolite.kafkasender.KafkaRecordSender;
import titan.ccp.models.records.ActivePowerRecord;
public class LoadGenerator {
......
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please to comment