Skip to content
Snippets Groups Projects
Commit 3f97eaa1 authored by Lars Erik Blümke's avatar Lars Erik Blümke
Browse files

renamed stages

parent 248039e3
No related branches found
No related tags found
No related merge requests found
package kieker.analysis.plugin.filter.select.timestamp;
import kieker.analysis.plugin.filter.select.timestamp.components.EventRecordTimestampStage;
import kieker.analysis.plugin.filter.select.timestamp.components.MonitioringRecordTimestampStage;
import kieker.analysis.plugin.filter.select.timestamp.components.OperationExecutionRecordTimestampStage;
import kieker.analysis.plugin.filter.select.timestamp.components.TraceMetadataTimestampStage;
import kieker.analysis.plugin.filter.select.timestamp.components.EventRecordTimestampFilter;
import kieker.analysis.plugin.filter.select.timestamp.components.MonitioringRecordTimestampFilter;
import kieker.analysis.plugin.filter.select.timestamp.components.OperationExecutionRecordTimestampFilter;
import kieker.analysis.plugin.filter.select.timestamp.components.TraceMetadataTimestampFilter;
import kieker.common.record.IMonitoringRecord;
import kieker.common.record.controlflow.OperationExecutionRecord;
import kieker.common.record.flow.IEventRecord;
......@@ -15,16 +15,16 @@ import teetime.framework.OutputPort;
import teetime.stage.MultipleInstanceOfFilter;
import teetime.stage.basic.merger.Merger;
public class TimestampStage extends CompositeStage {
public class TimestampFilterComposite extends CompositeStage {
private final InputPort<IMonitoringRecord> monitoringRecordsCombinedInputPort;
private final MultipleInstanceOfFilter<IMonitoringRecord> recordTypeFilter;
private final EventRecordTimestampStage eventRecordTimestampStage;
private final OperationExecutionRecordTimestampStage operationExecutionRecordTimestampStage;
private final TraceMetadataTimestampStage traceMetadataTimestampStage;
private final MonitioringRecordTimestampStage monitoringRecordTimestampStage;
private final EventRecordTimestampFilter eventRecordTimestampStage;
private final OperationExecutionRecordTimestampFilter operationExecutionRecordTimestampStage;
private final TraceMetadataTimestampFilter traceMetadataTimestampStage;
private final MonitioringRecordTimestampFilter monitoringRecordTimestampStage;
private final Merger<IMonitoringRecord> recordsWithinTimePeriodMerger;
private final Merger<IMonitoringRecord> recordsOutsideTimePeriodMerger;
......@@ -40,14 +40,14 @@ public class TimestampStage extends CompositeStage {
* @param ignoreAfterTimestamp
* The upper limit for the time stamps of the records.
*/
public TimestampStage(final long ignoreBeforeTimestamp, final long ignoreAfterTimestamp) {
public TimestampFilterComposite(final long ignoreBeforeTimestamp, final long ignoreAfterTimestamp) {
this.recordTypeFilter = new MultipleInstanceOfFilter<>();
this.eventRecordTimestampStage = new EventRecordTimestampStage(ignoreBeforeTimestamp, ignoreAfterTimestamp);
this.operationExecutionRecordTimestampStage = new OperationExecutionRecordTimestampStage(ignoreBeforeTimestamp, ignoreAfterTimestamp);
this.traceMetadataTimestampStage = new TraceMetadataTimestampStage(ignoreBeforeTimestamp, ignoreAfterTimestamp);
this.monitoringRecordTimestampStage = new MonitioringRecordTimestampStage(ignoreBeforeTimestamp, ignoreAfterTimestamp);
this.eventRecordTimestampStage = new EventRecordTimestampFilter(ignoreBeforeTimestamp, ignoreAfterTimestamp);
this.operationExecutionRecordTimestampStage = new OperationExecutionRecordTimestampFilter(ignoreBeforeTimestamp, ignoreAfterTimestamp);
this.traceMetadataTimestampStage = new TraceMetadataTimestampFilter(ignoreBeforeTimestamp, ignoreAfterTimestamp);
this.monitoringRecordTimestampStage = new MonitioringRecordTimestampFilter(ignoreBeforeTimestamp, ignoreAfterTimestamp);
this.recordsWithinTimePeriodMerger = new Merger<>();
this.recordsOutsideTimePeriodMerger = new Merger<>();
......@@ -76,7 +76,7 @@ public class TimestampStage extends CompositeStage {
/**
* Returns the input port for the records.
*
*
* @return The input port.
*/
public InputPort<IMonitoringRecord> getMonitoringRecordsCombinedInputPort() {
......@@ -85,7 +85,7 @@ public class TimestampStage extends CompositeStage {
/**
* Returns the output port for the records whose timestamps are within the defined time period.
*
*
* @return The recordsWithinTimePeriod output port.
*/
public OutputPort<IMonitoringRecord> getRecordsWithinTimePeriodOutputPort() {
......@@ -94,7 +94,7 @@ public class TimestampStage extends CompositeStage {
/**
* Returns the output port for the records whose timestamps are outside the defined time period.
*
*
* @return The recordsOutsideTimePeriod output port.
*/
public OutputPort<IMonitoringRecord> getRecordsOutsideTimePeriodOutputPort() {
......
......@@ -13,8 +13,8 @@ import teetime.stage.InstanceOfFilter;
* nameOutsidePeriodOutputPort.
*
* In a concrete P&F architecture this stage should be used behind TeeTime's {@link InstanceOfFilter} to forward records to either
* {@link TraceMetadataTimestampStage},
* {@link OperationExecutionRecordTimestampStage} or {@link MonitioringRecordTimestampStage}.
* {@link TraceMetadataTimestampFilter},
* {@link OperationExecutionRecordTimestampFilter} or {@link MonitioringRecordTimestampFilter}.
*
* @author Andre van Hoorn, Jan Waller, Lars Erik Bluemke
*
......@@ -23,7 +23,7 @@ import teetime.stage.InstanceOfFilter;
* @param <T>
* Generic type of incoming records. Subclasses use concrete types.
*/
public abstract class AbstractTimestampStage<T> extends AbstractConsumerStage<T> {
public abstract class AbstractTimestampFilter<T> extends AbstractConsumerStage<T> {
private final long ignoreBeforeTimestamp;
private final long ignoreAfterTimestamp;
......@@ -39,7 +39,7 @@ public abstract class AbstractTimestampStage<T> extends AbstractConsumerStage<T>
* @param ignoreAfterTimestamp
* The upper limit for the time stamps of the records.
*/
public AbstractTimestampStage(final long ignoreBeforeTimestamp, final long ignoreAfterTimestamp) {
public AbstractTimestampFilter(final long ignoreBeforeTimestamp, final long ignoreAfterTimestamp) {
this.ignoreBeforeTimestamp = ignoreBeforeTimestamp;
this.ignoreAfterTimestamp = ignoreAfterTimestamp;
}
......
......@@ -3,13 +3,13 @@ package kieker.analysis.plugin.filter.select.timestamp.components;
import kieker.common.record.flow.IEventRecord;
/**
* Concrete implementation of {@link AbstractTimestampStage}. Allows to filter {@link IEventRecord} objects based on their given timestamps.
* Concrete implementation of {@link AbstractTimestampFilter}. Allows to filter {@link IEventRecord} objects based on their given timestamps.
*
* @author Andre van Hoorn, Jan Waller, Lars Erik Bluemke
*/
public class EventRecordTimestampStage extends AbstractTimestampStage<IEventRecord> {
public class EventRecordTimestampFilter extends AbstractTimestampFilter<IEventRecord> {
public EventRecordTimestampStage(final long ignoreBeforeTimestamp, final long ignoreAfterTimestamp) {
public EventRecordTimestampFilter(final long ignoreBeforeTimestamp, final long ignoreAfterTimestamp) {
super(ignoreBeforeTimestamp, ignoreAfterTimestamp);
}
......
......@@ -3,13 +3,13 @@ package kieker.analysis.plugin.filter.select.timestamp.components;
import kieker.common.record.IMonitoringRecord;
/**
* Concrete implementation of {@link AbstractTimestampStage}. Allows to filter {@link IMonitoringRecord} objects based on their given timestamps.
* Concrete implementation of {@link AbstractTimestampFilter}. Allows to filter {@link IMonitoringRecord} objects based on their given timestamps.
*
* @author Andre van Hoorn, Jan Waller, Lars Erik Bluemke
*/
public class MonitioringRecordTimestampStage extends AbstractTimestampStage<IMonitoringRecord> {
public class MonitioringRecordTimestampFilter extends AbstractTimestampFilter<IMonitoringRecord> {
public MonitioringRecordTimestampStage(final long ignoreBeforeTimestamp, final long ignoreAfterTimestamp) {
public MonitioringRecordTimestampFilter(final long ignoreBeforeTimestamp, final long ignoreAfterTimestamp) {
super(ignoreBeforeTimestamp, ignoreAfterTimestamp);
}
......
......@@ -3,14 +3,14 @@ package kieker.analysis.plugin.filter.select.timestamp.components;
import kieker.common.record.controlflow.OperationExecutionRecord;
/**
* Concrete implementation of {@link AbstractTimestampStage}. Allows to filter {@link OperationExecutionRecord} objects based on their given timestamps.
* Concrete implementation of {@link AbstractTimestampFilter}. Allows to filter {@link OperationExecutionRecord} objects based on their given timestamps.
* This stage receives trace events to be selected by a specific timestamp selector (based on tin and tout).
*
* @author Andre van Hoorn, Jan Waller, Lars Erik Bluemke
*/
public class OperationExecutionRecordTimestampStage extends AbstractTimestampStage<OperationExecutionRecord> {
public class OperationExecutionRecordTimestampFilter extends AbstractTimestampFilter<OperationExecutionRecord> {
public OperationExecutionRecordTimestampStage(final long ignoreBeforeTimestamp, final long ignoreAfterTimestamp) {
public OperationExecutionRecordTimestampFilter(final long ignoreBeforeTimestamp, final long ignoreAfterTimestamp) {
super(ignoreBeforeTimestamp, ignoreAfterTimestamp);
}
......
......@@ -3,13 +3,13 @@ package kieker.analysis.plugin.filter.select.timestamp.components;
import kieker.common.record.flow.trace.TraceMetadata;
/**
* Concrete implementation of {@link AbstractTimestampStage}. Allows to filter {@link TraceMetadata} objects based on their given timestamps.
* Concrete implementation of {@link AbstractTimestampFilter}. Allows to filter {@link TraceMetadata} objects based on their given timestamps.
*
* @author Andre van Hoorn, Jan Waller, Lars Erik Bluemke
*/
public class TraceMetadataTimestampStage extends AbstractTimestampStage<TraceMetadata> {
public class TraceMetadataTimestampFilter extends AbstractTimestampFilter<TraceMetadata> {
public TraceMetadataTimestampStage(final long ignoreBeforeTimestamp, final long ignoreAfterTimestamp) {
public TraceMetadataTimestampFilter(final long ignoreBeforeTimestamp, final long ignoreAfterTimestamp) {
super(ignoreBeforeTimestamp, ignoreAfterTimestamp);
}
......
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