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

Align package structure uc2 hzj

parent 57e61d7a
No related branches found
No related tags found
1 merge request!208Add benchmark implementations for Hazelcast Jet
Showing
with 10 additions and 9 deletions
...@@ -2,4 +2,4 @@ plugins { ...@@ -2,4 +2,4 @@ plugins {
id 'theodolite.hazelcastjet' id 'theodolite.hazelcastjet'
} }
mainClassName = "theodolite.uc2.application.HistoryService" mainClassName = "rocks.theodolite.benchmarks.uc2.hazelcastjet.HistoryService"
package theodolite.uc2.application; package rocks.theodolite.benchmarks.uc2.hazelcastjet;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
......
package theodolite.uc2.application; package rocks.theodolite.benchmarks.uc2.hazelcastjet;
import com.google.common.math.StatsAccumulator; import com.google.common.math.StatsAccumulator;
import com.hazelcast.jet.JetInstance; import com.hazelcast.jet.JetInstance;
...@@ -9,7 +9,7 @@ import java.util.Properties; ...@@ -9,7 +9,7 @@ import java.util.Properties;
import org.slf4j.Logger; import org.slf4j.Logger;
import rocks.theodolite.benchmarks.commons.hazelcastjet.ConfigurationKeys; import rocks.theodolite.benchmarks.commons.hazelcastjet.ConfigurationKeys;
import rocks.theodolite.benchmarks.commons.hazelcastjet.JetInstanceBuilder; import rocks.theodolite.benchmarks.commons.hazelcastjet.JetInstanceBuilder;
import theodolite.uc2.application.uc2specifics.StatsAccumulatorSerializer; import rocks.theodolite.benchmarks.uc2.hazelcastjet.uc2specifics.StatsAccumulatorSerializer;
/** /**
* A Hazelcast Jet factory which can build a Hazelcast Jet Instance and Pipeline for the UC2 * A Hazelcast Jet factory which can build a Hazelcast Jet Instance and Pipeline for the UC2
......
package theodolite.uc2.application; package rocks.theodolite.benchmarks.uc2.hazelcastjet;
import io.confluent.kafka.serializers.KafkaAvroDeserializer; import io.confluent.kafka.serializers.KafkaAvroDeserializer;
import java.util.Objects; import java.util.Objects;
......
package theodolite.uc2.application; package rocks.theodolite.benchmarks.uc2.hazelcastjet;
import com.google.common.math.Stats; import com.google.common.math.Stats;
import com.google.common.math.StatsAccumulator; import com.google.common.math.StatsAccumulator;
...@@ -14,7 +14,7 @@ import com.hazelcast.jet.pipeline.WindowDefinition; ...@@ -14,7 +14,7 @@ import com.hazelcast.jet.pipeline.WindowDefinition;
import java.util.Map; import java.util.Map;
import java.util.Map.Entry; import java.util.Map.Entry;
import java.util.Properties; import java.util.Properties;
import theodolite.uc2.application.uc2specifics.StatsAccumulatorSupplier; import rocks.theodolite.benchmarks.uc2.hazelcastjet.uc2specifics.StatsAccumulatorSupplier;
import titan.ccp.model.records.ActivePowerRecord; import titan.ccp.model.records.ActivePowerRecord;
/** /**
......
package theodolite.uc2.application.uc2specifics; package rocks.theodolite.benchmarks.uc2.hazelcastjet.uc2specifics;
import com.google.common.math.Stats; import com.google.common.math.Stats;
import com.google.common.math.StatsAccumulator; import com.google.common.math.StatsAccumulator;
......
package theodolite.uc2.application.uc2specifics; package rocks.theodolite.benchmarks.uc2.hazelcastjet.uc2specifics;
import com.google.common.math.StatsAccumulator; import com.google.common.math.StatsAccumulator;
import com.hazelcast.function.SupplierEx; import com.hazelcast.function.SupplierEx;
......
...@@ -20,6 +20,7 @@ import org.junit.Assert; ...@@ -20,6 +20,7 @@ import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
import org.junit.experimental.categories.Category; import org.junit.experimental.categories.Category;
import rocks.theodolite.benchmarks.uc2.hazelcastjet.Uc2PipelineBuilder;
import titan.ccp.model.records.ActivePowerRecord; 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