Skip to content
Snippets Groups Projects
Commit b3aa8de1 authored by Christian Wulf's avatar Christian Wulf
Browse files

Merge branch 'AbstractCompositeStage' into 'master'

Abstract composite stage

#115 Rename CompositeStage to AbstractCompositeStage

See merge request !31
parents e748af49 832fe8d7
No related branches found
No related tags found
No related merge requests found
......@@ -33,7 +33,7 @@ import teetime.framework.validation.InvalidPortConnection;
*
*/
@SuppressWarnings("PMD.AbstractNaming")
public abstract class CompositeStage extends Stage {
public abstract class AbstractCompositeStage extends Stage {
private static final IPipeFactory INTRA_PIPE_FACTORY = PipeFactoryRegistry.INSTANCE
.getPipeFactory(ThreadCommunication.INTRA, PipeOrdering.ARBITRARY, false);
......
......@@ -19,7 +19,7 @@ import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import teetime.framework.CompositeStage;
import teetime.framework.AbstractCompositeStage;
import teetime.framework.InputPort;
import teetime.framework.OutputPort;
import teetime.framework.Stage;
......@@ -27,7 +27,7 @@ import teetime.stage.EveryXthStage;
import teetime.stage.basic.distributor.CopyByReferenceStrategy;
import teetime.stage.basic.distributor.Distributor;
public final class EveryXthPrinter<T> extends CompositeStage {
public final class EveryXthPrinter<T> extends AbstractCompositeStage {
private final Distributor<T> distributor;
private final List<Stage> lastStages = new ArrayList<Stage>();
......
......@@ -18,7 +18,7 @@ package teetime.stage.string;
import java.util.ArrayList;
import java.util.Collection;
import teetime.framework.CompositeStage;
import teetime.framework.AbstractCompositeStage;
import teetime.framework.InputPort;
import teetime.framework.OutputPort;
import teetime.framework.Stage;
......@@ -34,7 +34,7 @@ import teetime.stage.util.CountingMap;
* @author Nelson Tavares de Sousa
*
*/
public final class WordCounter extends CompositeStage {
public final class WordCounter extends AbstractCompositeStage {
// This fields are needed for the methods to work.
private final Tokenizer tokenizer = new Tokenizer(" ");
......
......@@ -20,7 +20,7 @@ import java.util.Collection;
import java.util.List;
@Deprecated
public class OldPipeline<FirstStage extends Stage, LastStage extends Stage> extends CompositeStage {
public class OldPipeline<FirstStage extends Stage, LastStage extends Stage> extends AbstractCompositeStage {
protected FirstStage firstStage;
private final List<LastStage> lastStages = new ArrayList<LastStage>();
......
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