Skip to content
Snippets Groups Projects
Commit 7839543d authored by Lorenz Boguhn's avatar Lorenz Boguhn
Browse files

Align package structure uc3 hzj

parent 8a79f9c8
No related branches found
No related tags found
1 merge request!208Add benchmark implementations for Hazelcast Jet
Showing
with 17 additions and 16 deletions
......@@ -2,4 +2,4 @@ plugins {
id 'theodolite.hazelcastjet'
}
mainClassName = "theodolite.uc3.application.HistoryService"
mainClassName = "rocks.theodolite.benchmarks.uc3.hazelcastjet.HistoryService"
package theodolite.uc3.application;
package rocks.theodolite.benchmarks.uc3.hazelcastjet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
......
package theodolite.uc3.application;
package rocks.theodolite.benchmarks.uc3.hazelcastjet;
import com.hazelcast.jet.JetInstance;
import com.hazelcast.jet.config.JobConfig;
......@@ -8,8 +8,8 @@ import java.util.Properties;
import org.slf4j.Logger;
import rocks.theodolite.benchmarks.commons.hazelcastjet.ConfigurationKeys;
import rocks.theodolite.benchmarks.commons.hazelcastjet.JetInstanceBuilder;
import theodolite.uc3.application.uc3specifics.HourOfDayKey;
import theodolite.uc3.application.uc3specifics.HourOfDayKeySerializer;
import rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics.HourOfDayKey;
import rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics.HourOfDayKeySerializer;
/**
* A Hazelcast Jet factory which can build a Hazelcast Jet Instance and Pipeline for the UC3
......
package theodolite.uc3.application;
package rocks.theodolite.benchmarks.uc3.hazelcastjet;
import io.confluent.kafka.serializers.KafkaAvroDeserializer;
import java.util.Objects;
......
package theodolite.uc3.application;
package rocks.theodolite.benchmarks.uc3.hazelcastjet;
import com.hazelcast.jet.aggregate.AggregateOperations;
import com.hazelcast.jet.kafka.KafkaSinks;
......@@ -15,9 +15,9 @@ import java.util.Map.Entry;
import java.util.Properties;
import java.util.TimeZone;
import java.util.concurrent.TimeUnit;
import theodolite.uc3.application.uc3specifics.HourOfDayKey;
import theodolite.uc3.application.uc3specifics.HoursOfDayKeyFactory;
import theodolite.uc3.application.uc3specifics.StatsKeyFactory;
import rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics.HourOfDayKey;
import rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics.HoursOfDayKeyFactory;
import rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics.StatsKeyFactory;
import titan.ccp.model.records.ActivePowerRecord;
/**
......
package theodolite.uc3.application.uc3specifics;
package rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics;
import java.util.Objects;
......
package theodolite.uc3.application.uc3specifics;
package rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics;
import com.hazelcast.nio.ObjectDataInput;
import com.hazelcast.nio.ObjectDataOutput;
......
package theodolite.uc3.application.uc3specifics;
package rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics;
import java.time.LocalDateTime;
......
package theodolite.uc3.application.uc3specifics;
package rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics;
import java.time.LocalDateTime;
......
......@@ -24,8 +24,9 @@ import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import theodolite.uc3.application.uc3specifics.HourOfDayKey;
import theodolite.uc3.application.uc3specifics.HourOfDayKeySerializer;
import rocks.theodolite.benchmarks.uc3.hazelcastjet.Uc3PipelineBuilder;
import rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics.HourOfDayKey;
import rocks.theodolite.benchmarks.uc3.hazelcastjet.uc3specifics.HourOfDayKeySerializer;
import titan.ccp.model.records.ActivePowerRecord;
/**
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment