From 0a67fd7abe32aacb4e9afc93543a4f7e7e36cd0e Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <stu103017@mail.uni-kiel.de>
Date: Thu, 18 Jun 2015 12:56:23 +0200
Subject: [PATCH] Renamed AnalysisConfiguration to AnalysisContext
---
.../java/teetime/framework/AbstractCompositeStage.java | 8 +++-----
src/main/java/teetime/framework/Analysis.java | 6 +++---
.../{AnalysisConfiguration.java => AnalysisContext.java} | 2 +-
.../java/teetime/framework/AnalysisInstantiation.java | 6 +++---
src/main/java/teetime/framework/test/StageTester.java | 8 ++++----
src/main/java/teetime/stage/io/EveryXthPrinter.java | 5 ++---
src/main/java/teetime/stage/string/WordCounter.java | 5 ++---
.../java/teetime/examples/cipher/CipherConfiguration.java | 4 ++--
src/test/java/teetime/examples/cipher/CipherTest.java | 4 ++--
.../examples/tokenizer/TokenizerConfiguration.java | 4 ++--
src/test/java/teetime/framework/AnalysisTest.java | 6 +++---
.../framework/RunnableConsumerStageTestConfiguration.java | 2 +-
src/test/java/teetime/framework/StageTest.java | 2 +-
src/test/java/teetime/framework/TraversorTest.java | 2 +-
.../java/teetime/framework/WaitStrategyConfiguration.java | 2 +-
.../teetime/framework/YieldStrategyConfiguration.java | 2 +-
.../exceptionHandling/ExceptionTestConfiguration.java | 4 ++--
src/test/java/teetime/stage/InstanceOfFilterTest.java | 4 ++--
18 files changed, 36 insertions(+), 40 deletions(-)
rename src/main/java/teetime/framework/{AnalysisConfiguration.java => AnalysisContext.java} (99%)
diff --git a/src/main/java/teetime/framework/AbstractCompositeStage.java b/src/main/java/teetime/framework/AbstractCompositeStage.java
index 582ef9b0..e0d86063 100644
--- a/src/main/java/teetime/framework/AbstractCompositeStage.java
+++ b/src/main/java/teetime/framework/AbstractCompositeStage.java
@@ -25,11 +25,9 @@ package teetime.framework;
*/
public abstract class AbstractCompositeStage extends Network {
- private final AnalysisConfiguration context;
+ private final AnalysisContext context;
- public abstract Stage getFirstStage();
-
- public AbstractCompositeStage(final AnalysisConfiguration context) {
+ public AbstractCompositeStage(final AnalysisContext context) {
this.context = context;
}
@@ -48,7 +46,7 @@ public abstract class AbstractCompositeStage extends Network {
context.addThreadableStage(stage);
}
- AnalysisConfiguration getContext() {
+ protected AnalysisContext getContext() {
return context;
}
diff --git a/src/main/java/teetime/framework/Analysis.java b/src/main/java/teetime/framework/Analysis.java
index a8fc0514..0b376d32 100644
--- a/src/main/java/teetime/framework/Analysis.java
+++ b/src/main/java/teetime/framework/Analysis.java
@@ -35,7 +35,7 @@ import teetime.util.Pair;
/**
* Represents an Analysis to which stages can be added and executed later.
- * This needs a {@link AnalysisConfiguration},
+ * This needs a {@link AnalysisContext},
* in which the adding and configuring of stages takes place.
* To start the analysis {@link #executeBlocking()} needs to be executed.
* This class will automatically create threads and join them without any further commitment.
@@ -43,9 +43,9 @@ import teetime.util.Pair;
* @author Christian Wulf, Nelson Tavares de Sousa
*
* @param <T>
- * the type of the {@link AnalysisConfiguration}
+ * the type of the {@link AnalysisContext}
*/
-public final class Analysis<T extends AnalysisConfiguration> implements UncaughtExceptionHandler {
+public final class Analysis<T extends AnalysisContext> implements UncaughtExceptionHandler {
private static final Logger LOGGER = LoggerFactory.getLogger(Analysis.class);
diff --git a/src/main/java/teetime/framework/AnalysisConfiguration.java b/src/main/java/teetime/framework/AnalysisContext.java
similarity index 99%
rename from src/main/java/teetime/framework/AnalysisConfiguration.java
rename to src/main/java/teetime/framework/AnalysisContext.java
index 7b285bcd..67348213 100644
--- a/src/main/java/teetime/framework/AnalysisConfiguration.java
+++ b/src/main/java/teetime/framework/AnalysisContext.java
@@ -29,7 +29,7 @@ import teetime.framework.pipe.PipeFactoryRegistry.ThreadCommunication;
* Represents a configuration of connected stages, which is needed to run a analysis.
* Stages can be added by executing {@link #addThreadableStage(Stage)}.
*/
-public abstract class AnalysisConfiguration extends Network {
+public abstract class AnalysisContext extends Network {
private final Set<Stage> threadableStages = new HashSet<Stage>();
diff --git a/src/main/java/teetime/framework/AnalysisInstantiation.java b/src/main/java/teetime/framework/AnalysisInstantiation.java
index 2eba9e4c..aa4217b8 100644
--- a/src/main/java/teetime/framework/AnalysisInstantiation.java
+++ b/src/main/java/teetime/framework/AnalysisInstantiation.java
@@ -36,14 +36,14 @@ class AnalysisInstantiation {
private final IPipeFactory interUnboundedThreadPipeFactory = new UnboundedSpScPipeFactory();
private final IPipeFactory intraThreadPipeFactory = new SingleElementPipeFactory();
- private final AnalysisConfiguration configuration;
+ private final AnalysisContext configuration;
- public AnalysisInstantiation(final AnalysisConfiguration configuration) {
+ public AnalysisInstantiation(final AnalysisContext configuration) {
this.configuration = configuration;
}
@SuppressWarnings("rawtypes")
- Integer colorAndConnectStages(final Integer i, final Map<Stage, Integer> colors, final Stage threadableStage, final AnalysisConfiguration configuration) {
+ Integer colorAndConnectStages(final Integer i, final Map<Stage, Integer> colors, final Stage threadableStage, final AnalysisContext configuration) {
Integer createdConnections = new Integer(0);
Set<Stage> threadableStageJobs = configuration.getThreadableStages();
for (OutputPort outputPort : threadableStage.getOutputPorts()) {
diff --git a/src/main/java/teetime/framework/test/StageTester.java b/src/main/java/teetime/framework/test/StageTester.java
index 59092010..e40c4d91 100644
--- a/src/main/java/teetime/framework/test/StageTester.java
+++ b/src/main/java/teetime/framework/test/StageTester.java
@@ -20,7 +20,7 @@ import java.util.Arrays;
import java.util.List;
import teetime.framework.Analysis;
-import teetime.framework.AnalysisConfiguration;
+import teetime.framework.AnalysisContext;
import teetime.framework.AnalysisException;
import teetime.framework.Stage;
import teetime.framework.StageState;
@@ -78,12 +78,12 @@ public final class StageTester {
*
*/
public void start() {
- final AnalysisConfiguration configuration = new Configuration(inputHolders, stage, outputHolders);
- final Analysis<AnalysisConfiguration> analysis = new Analysis<AnalysisConfiguration>(configuration);
+ final AnalysisContext configuration = new Configuration(inputHolders, stage, outputHolders);
+ final Analysis<AnalysisContext> analysis = new Analysis<AnalysisContext>(configuration);
analysis.executeBlocking();
}
- private final class Configuration extends AnalysisConfiguration {
+ private final class Configuration extends AnalysisContext {
public Configuration(final List<InputHolder<?>> inputHolders, final Stage stage, final List<OutputHolder<?>> outputHolders) {
for (InputHolder<?> inputHolder : inputHolders) {
diff --git a/src/main/java/teetime/stage/io/EveryXthPrinter.java b/src/main/java/teetime/stage/io/EveryXthPrinter.java
index 3b57c7df..2641bb72 100644
--- a/src/main/java/teetime/stage/io/EveryXthPrinter.java
+++ b/src/main/java/teetime/stage/io/EveryXthPrinter.java
@@ -19,7 +19,7 @@ import java.util.ArrayList;
import java.util.List;
import teetime.framework.AbstractCompositeStage;
-import teetime.framework.AnalysisConfiguration;
+import teetime.framework.AnalysisContext;
import teetime.framework.InputPort;
import teetime.framework.OutputPort;
import teetime.framework.Stage;
@@ -32,7 +32,7 @@ public final class EveryXthPrinter<T> extends AbstractCompositeStage {
private final Distributor<T> distributor;
private final List<Stage> lastStages = new ArrayList<Stage>();
- public EveryXthPrinter(final int threshold, final AnalysisConfiguration context) {
+ public EveryXthPrinter(final int threshold, final AnalysisContext context) {
super(context);
distributor = new Distributor<T>(new CopyByReferenceStrategy());
EveryXthStage<T> everyXthStage = new EveryXthStage<T>(threshold);
@@ -52,7 +52,6 @@ public final class EveryXthPrinter<T> extends AbstractCompositeStage {
return distributor.getNewOutputPort();
}
- @Override
public Stage getFirstStage() {
return distributor;
}
diff --git a/src/main/java/teetime/stage/string/WordCounter.java b/src/main/java/teetime/stage/string/WordCounter.java
index fad4c110..4ca80c65 100644
--- a/src/main/java/teetime/stage/string/WordCounter.java
+++ b/src/main/java/teetime/stage/string/WordCounter.java
@@ -18,7 +18,7 @@ package teetime.stage.string;
import java.util.ArrayList;
import teetime.framework.AbstractCompositeStage;
-import teetime.framework.AnalysisConfiguration;
+import teetime.framework.AnalysisContext;
import teetime.framework.InputPort;
import teetime.framework.OutputPort;
import teetime.framework.Stage;
@@ -42,7 +42,7 @@ public final class WordCounter extends AbstractCompositeStage {
private final ArrayList<Stage> lastStages = new ArrayList<Stage>();
// The connection of the different stages is realized within the construction of a instance of this class.
- public WordCounter(final AnalysisConfiguration context) {
+ public WordCounter(final AnalysisContext context) {
super(context);
this.lastStages.add(this.mapCounter);
final ToLowerCase toLowerCase = new ToLowerCase();
@@ -52,7 +52,6 @@ public final class WordCounter extends AbstractCompositeStage {
// connectStages(wordcharacterFilter.getOutputPort(), this.mapCounter.getInputPort());
}
- @Override
public Stage getFirstStage() {
return this.tokenizer;
}
diff --git a/src/test/java/teetime/examples/cipher/CipherConfiguration.java b/src/test/java/teetime/examples/cipher/CipherConfiguration.java
index 95ba33f4..11861a87 100644
--- a/src/test/java/teetime/examples/cipher/CipherConfiguration.java
+++ b/src/test/java/teetime/examples/cipher/CipherConfiguration.java
@@ -17,7 +17,7 @@ package teetime.examples.cipher;
import java.io.File;
-import teetime.framework.AnalysisConfiguration;
+import teetime.framework.AnalysisContext;
import teetime.stage.CipherStage;
import teetime.stage.CipherStage.CipherMode;
import teetime.stage.InitialElementProducer;
@@ -26,7 +26,7 @@ import teetime.stage.ZipByteArray.ZipMode;
import teetime.stage.io.ByteArrayFileWriter;
import teetime.stage.io.File2ByteArray;
-public class CipherConfiguration extends AnalysisConfiguration {
+public class CipherConfiguration extends AnalysisContext {
public CipherConfiguration(final String inputFile, final String outputFile, final String password) {
final File input = new File(inputFile);
diff --git a/src/test/java/teetime/examples/cipher/CipherTest.java b/src/test/java/teetime/examples/cipher/CipherTest.java
index ac03de78..38a8d1f6 100644
--- a/src/test/java/teetime/examples/cipher/CipherTest.java
+++ b/src/test/java/teetime/examples/cipher/CipherTest.java
@@ -22,7 +22,7 @@ import org.junit.Assert;
import org.junit.Test;
import teetime.framework.Analysis;
-import teetime.framework.AnalysisConfiguration;
+import teetime.framework.AnalysisContext;
import com.google.common.io.Files;
@@ -43,7 +43,7 @@ public class CipherTest {
final String outputFile = "src/test/resources/data/output.txt";
final String password = "Password";
- final AnalysisConfiguration configuration = new CipherConfiguration(inputFile, outputFile, password);
+ final AnalysisContext configuration = new CipherConfiguration(inputFile, outputFile, password);
final Analysis analysis = new Analysis(configuration);
analysis.executeBlocking();
diff --git a/src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java b/src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java
index 15c325da..90dea5d2 100644
--- a/src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java
+++ b/src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java
@@ -17,7 +17,7 @@ package teetime.examples.tokenizer;
import java.io.File;
-import teetime.framework.AnalysisConfiguration;
+import teetime.framework.AnalysisContext;
import teetime.stage.ByteArray2String;
import teetime.stage.CipherStage;
import teetime.stage.CipherStage.CipherMode;
@@ -28,7 +28,7 @@ import teetime.stage.ZipByteArray.ZipMode;
import teetime.stage.io.File2ByteArray;
import teetime.stage.string.Tokenizer;
-public class TokenizerConfiguration extends AnalysisConfiguration {
+public class TokenizerConfiguration extends AnalysisContext {
private final Counter<String> counter;
diff --git a/src/test/java/teetime/framework/AnalysisTest.java b/src/test/java/teetime/framework/AnalysisTest.java
index 5c347dfe..fd15835d 100644
--- a/src/test/java/teetime/framework/AnalysisTest.java
+++ b/src/test/java/teetime/framework/AnalysisTest.java
@@ -70,7 +70,7 @@ public class AnalysisTest {
assertThat(watch.getDurationInMs() + ABSOLUTE_MAX_ERROR_IN_MS, is(greaterThanOrEqualTo(DELAY_IN_MS)));
}
- private static class TestConfig extends AnalysisConfiguration {
+ private static class TestConfig extends AnalysisContext {
public final DelayAndTerminate delay;
public TestConfig() {
@@ -112,7 +112,7 @@ public class AnalysisTest {
assertThat(intraAnalysis.getConfiguration().init.getOwningThread(), is(intraAnalysis.getConfiguration().sink.getOwningThread()));
}
- private class AnalysisTestConfig extends AnalysisConfiguration {
+ private class AnalysisTestConfig extends AnalysisContext {
public InitialElementProducer<Object> init = new InitialElementProducer<Object>();
public Sink<Object> sink = new Sink<Object>();
@@ -136,7 +136,7 @@ public class AnalysisTest {
new Analysis<InvalidTestConfig>(configuration);
}
- private class InvalidTestConfig extends AnalysisConfiguration {
+ private class InvalidTestConfig extends AnalysisContext {
public InitialElementProducer<Object> init = new InitialElementProducer<Object>();
public InstanceOfFilter<Object, Object> iof = new InstanceOfFilter<Object, Object>(Object.class);
public Sink<Object> sink = new Sink<Object>();
diff --git a/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java b/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java
index 74d0cd73..89be4761 100644
--- a/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java
+++ b/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java
@@ -21,7 +21,7 @@ import java.util.List;
import teetime.stage.CollectorSink;
import teetime.stage.InitialElementProducer;
-public class RunnableConsumerStageTestConfiguration extends AnalysisConfiguration {
+public class RunnableConsumerStageTestConfiguration extends AnalysisContext {
private final List<Integer> collectedElements = new ArrayList<Integer>();
private final CollectorSink<Integer> collectorSink;
diff --git a/src/test/java/teetime/framework/StageTest.java b/src/test/java/teetime/framework/StageTest.java
index 19580dcb..5531fb48 100644
--- a/src/test/java/teetime/framework/StageTest.java
+++ b/src/test/java/teetime/framework/StageTest.java
@@ -53,7 +53,7 @@ public class StageTest {
assertEquals(tc.init.exceptionHandler, tc.delay.exceptionHandler);
}
- private static class TestConfig extends AnalysisConfiguration {
+ private static class TestConfig extends AnalysisContext {
public final DelayAndTerminate delay;
public InitialElementProducer<String> init;
diff --git a/src/test/java/teetime/framework/TraversorTest.java b/src/test/java/teetime/framework/TraversorTest.java
index 6c092ac9..7244e13a 100644
--- a/src/test/java/teetime/framework/TraversorTest.java
+++ b/src/test/java/teetime/framework/TraversorTest.java
@@ -53,7 +53,7 @@ public class TraversorTest {
}
// WordCounterConfiguration
- private class TestConfiguration extends AnalysisConfiguration {
+ private class TestConfiguration extends AnalysisContext {
public final CountingMapMerger<String> result = new CountingMapMerger<String>();
public final InitialElementProducer<File> init;
diff --git a/src/test/java/teetime/framework/WaitStrategyConfiguration.java b/src/test/java/teetime/framework/WaitStrategyConfiguration.java
index 191f8460..2e7cb2ff 100644
--- a/src/test/java/teetime/framework/WaitStrategyConfiguration.java
+++ b/src/test/java/teetime/framework/WaitStrategyConfiguration.java
@@ -21,7 +21,7 @@ import teetime.stage.InitialElementProducer;
import teetime.stage.Relay;
import teetime.stage.basic.Delay;
-class WaitStrategyConfiguration extends AnalysisConfiguration {
+class WaitStrategyConfiguration extends AnalysisContext {
private Delay<Object> delay;
private CollectorSink<Object> collectorSink;
diff --git a/src/test/java/teetime/framework/YieldStrategyConfiguration.java b/src/test/java/teetime/framework/YieldStrategyConfiguration.java
index a6302594..41edee01 100644
--- a/src/test/java/teetime/framework/YieldStrategyConfiguration.java
+++ b/src/test/java/teetime/framework/YieldStrategyConfiguration.java
@@ -19,7 +19,7 @@ import teetime.stage.CollectorSink;
import teetime.stage.InitialElementProducer;
import teetime.stage.Relay;
-class YieldStrategyConfiguration extends AnalysisConfiguration {
+class YieldStrategyConfiguration extends AnalysisContext {
private CollectorSink<Object> collectorSink;
diff --git a/src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java b/src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java
index d985faf2..8dd38b07 100644
--- a/src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java
+++ b/src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java
@@ -15,9 +15,9 @@
*/
package teetime.framework.exceptionHandling;
-import teetime.framework.AnalysisConfiguration;
+import teetime.framework.AnalysisContext;
-public class ExceptionTestConfiguration extends AnalysisConfiguration {
+public class ExceptionTestConfiguration extends AnalysisContext {
ExceptionTestProducerStage first;
ExceptionTestConsumerStage second;
diff --git a/src/test/java/teetime/stage/InstanceOfFilterTest.java b/src/test/java/teetime/stage/InstanceOfFilterTest.java
index b87d2ec3..d3382247 100644
--- a/src/test/java/teetime/stage/InstanceOfFilterTest.java
+++ b/src/test/java/teetime/stage/InstanceOfFilterTest.java
@@ -30,7 +30,7 @@ import org.junit.Before;
import org.junit.Test;
import teetime.framework.Analysis;
-import teetime.framework.AnalysisConfiguration;
+import teetime.framework.AnalysisContext;
import teetime.framework.AnalysisException;
import teetime.util.Pair;
@@ -122,7 +122,7 @@ public class InstanceOfFilterTest {
}
}
- private static class InstanceOfFilterTestConfig extends AnalysisConfiguration {
+ private static class InstanceOfFilterTestConfig extends AnalysisContext {
public InstanceOfFilterTestConfig() {
InitialElementProducer<Object> elementProducer = new InitialElementProducer<Object>();
--
GitLab