Package | Description |
---|---|
teetime.framework |
Contains the implementation of the TeeTime framework.
|
teetime.framework.exceptionHandling |
Copyright © 2015 Christian Wulf, Nelson Tavares de Sousa (http://teetime-framework.github.io)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
teetime.framework.performancelogging | |
teetime.framework.performancelogging.formatstrategy | |
teetime.framework.scheduling.globaltaskpool | |
teetime.framework.scheduling.pushpullmodel | |
teetime.framework.signal |
Contains the signals that are used within the framework.
|
teetime.framework.termination | |
teetime.framework.test |
Copyright © 2015 Christian Wulf, Nelson Tavares de Sousa (http://teetime-framework.github.io)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
|
teetime.stage |
Contains a set of pre-defined stages, which are ready-to-go and can be used for analysis configuration.
|
teetime.stage.basic | |
teetime.stage.basic.distributor | |
teetime.stage.basic.distributor.dynamic | |
teetime.stage.basic.merger | |
teetime.stage.basic.merger.dynamic | |
teetime.stage.io | |
teetime.stage.string | |
teetime.stage.xml | |
teetime.util.framework.port |
Modifier and Type | Class and Description |
---|---|
class |
AbstractConsumerStage<I> |
class |
AbstractProducerStage<O>
The
ProducerStage produces at least one element at each execution. |
class |
DivideAndConquerStage<P extends AbstractDivideAndConquerProblem<P,S>,S extends AbstractDivideAndConquerSolution<S>>
A stage to solve divide and conquer problems
|
Modifier and Type | Field and Description |
---|---|
protected AbstractStage |
AbstractPipe.cachedTargetStage |
Modifier and Type | Method and Description |
---|---|
<S extends AbstractStage,O> |
ConfigurationBuilder.Connection.to(S stage,
Function<S,InputPort<I>> inputPort,
Function<S,OutputPort<O>> outputPort) |
Modifier and Type | Method and Description |
---|---|
AbstractStage |
AbstractPipe.getCachedTargetStage()
Performance cache: Avoids the following method chain
|
AbstractStage |
AbstractPort.getOwningStage() |
Modifier and Type | Method and Description |
---|---|
Collection<AbstractStage> |
ConfigurationFacade.getStartStages(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
StageFacade.abort(AbstractStage stage) |
static long |
StateStatistics.getActiveWaitingTime(AbstractStage stage) |
AbstractExceptionListener |
StageFacade.getExceptionListener(AbstractStage stage) |
List<InputPort<?>> |
StageFacade.getInputPorts(AbstractStage stage) |
int |
StageFacade.getLevelIndex(AbstractStage stage) |
List<OutputPort<?>> |
StageFacade.getOutputPorts(AbstractStage stage) |
Thread |
StageFacade.getOwningThread(AbstractStage stage) |
static List<StateChange> |
StateStatistics.getStates(AbstractStage stage)
This method is used to collect the List of States
|
TerminationStrategy |
StageFacade.getTerminationStrategy(AbstractStage stage)
Deprecated.
since 3.0. Will be removed.
|
boolean |
Traverser.EndOfTraverse.isMet(AbstractStage stage) |
boolean |
Traverser.AlreadyRunsEndOfTraverse.isMet(AbstractStage stage) |
void |
InputPortRemovedListener.onInputPortRemoved(AbstractStage stage,
InputPort<?> removedInputPort) |
void |
OutputPortRemovedListener.onOutputPortRemoved(AbstractStage stage,
OutputPort<?> removedOutputPort) |
void |
StageFacade.onStarting(AbstractStage stage) |
void |
StageFacade.onTerminating(AbstractStage stage) |
void |
StageFacade.runStage(AbstractStage stage) |
void |
StageFacade.runStage(AbstractStage stage,
int numOfExecutions) |
static void |
StateStatistics.sendingFailed(AbstractStage stage)
This method is called by Pipes if the sending of the next element needs to be delayed because of full Queue.
|
static void |
StateStatistics.sendingSucceeded(AbstractStage stage)
This method is called when the element is successfully added to the Pipe.
|
void |
StageFacade.setExceptionHandler(AbstractStage stage,
AbstractExceptionListener exceptionHandler) |
void |
StageFacade.setLevelIndex(AbstractStage stage,
int levelIndex) |
void |
StageFacade.setOwningThread(AbstractStage stage,
Thread newThread) |
void |
StageFacade.setScheduler(AbstractStage stage,
TeeTimeScheduler scheduler) |
boolean |
StageFacade.shouldBeTerminated(AbstractStage stage) |
void |
TeeTimeScheduler.startStageAtRuntime(AbstractStage stage) |
void |
RuntimeServiceFacade.startWithinNewThread(AbstractStage previousStage,
AbstractStage stage)
Does not send signals.
|
void |
Traverser.traverse(AbstractStage stage) |
void |
BreadthFirstTraverser.traverse(AbstractStage startStage,
ITraverserVisitor traverserVisitor) |
Traverser.VisitorBehavior |
ITraverserVisitor.visit(AbstractStage stage) |
Constructor and Description |
---|
AbstractPort(Class<T> type,
AbstractStage owningStage,
String name) |
Constructor and Description |
---|
A2InvalidThreadAssignmentCheck(Set<AbstractStage> threadableStages)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
abstract AbstractExceptionListener.FurtherExecution |
AbstractExceptionListener.onStageException(Exception exception,
AbstractStage throwingStage)
This method will be executed if an exception arises.
|
AbstractExceptionListener.FurtherExecution |
AbstractExceptionListener.reportException(Exception e,
AbstractStage stage) |
Modifier and Type | Method and Description |
---|---|
Set<AbstractStage> |
ActivationStateLogger.getStages() |
Modifier and Type | Method and Description |
---|---|
void |
ActivationStateLogger.register(AbstractStage stage)
Any stage can register itself here.
|
Constructor and Description |
---|
CumulativeActivePassivTime(Collection<AbstractStage> stages) |
PercentageOfActiveTime(Collection<AbstractStage> stages) |
RNTFormating(Collection<AbstractStage> stages) |
Modifier and Type | Method and Description |
---|---|
AbstractStage |
ITaskQueueDuplicable.duplicate() |
AbstractStage |
StageBuffer.getStage() |
AbstractStage |
ScheduleQueue.removeNextStage() |
Modifier and Type | Method and Description |
---|---|
List<AbstractStage> |
GlobalTaskPoolScheduling.getFiniteProducerStages() |
Set<AbstractStage> |
GlobalTaskPoolScheduling.getFrontStages() |
Modifier and Type | Method and Description |
---|---|
teetime.framework.scheduling.globaltaskpool.TeeTimeTaskQueueThreadChw |
GlobalTaskPoolScheduling.getOwningThreadSynched(AbstractStage stage) |
boolean |
GlobalTaskPoolScheduling.isBeingExecuted(AbstractStage stage) |
boolean |
GlobalTaskPoolScheduling.isPausedStage(AbstractStage stage) |
boolean |
ScheduleQueue.scheduleStage(AbstractStage stage) |
boolean |
GlobalTaskPoolScheduling.setIsBeingExecuted(AbstractStage stage,
boolean newValue) |
void |
GlobalTaskPoolScheduling.setOwningThreadSynced(AbstractStage stage,
teetime.framework.scheduling.globaltaskpool.TeeTimeTaskQueueThreadChw newThread) |
void |
GlobalTaskPoolScheduling.startStageAtRuntime(AbstractStage stage) |
Traverser.VisitorBehavior |
SignalVisitor.visit(AbstractStage stage) |
Modifier and Type | Method and Description |
---|---|
default boolean |
ScheduleQueue.scheduleStages(Collection<? extends AbstractStage> stages) |
Constructor and Description |
---|
StageBuffer(AbstractStage stage,
boolean done) |
Modifier and Type | Method and Description |
---|---|
void |
PushPullScheduling.onAfterTermination(AbstractStage stage) |
void |
PushPullScheduling.onBeforeStart(AbstractStage stage) |
void |
PushPullScheduling.startStageAtRuntime(AbstractStage newStage) |
Constructor and Description |
---|
A2InvalidThreadAssignmentCheck(Set<AbstractStage> threadableStages) |
Modifier and Type | Method and Description |
---|---|
void |
StartingSignal.trigger(AbstractStage stage) |
void |
ISignal.trigger(AbstractStage stage) |
void |
ValidatingSignal.trigger(AbstractStage stage) |
void |
TerminatingSignal.trigger(AbstractStage stage) |
Constructor and Description |
---|
NextActiveStageShouldTerminate(AbstractStage stage) |
StageHasTerminated(AbstractStage stage) |
Modifier and Type | Method and Description |
---|---|
static StageTester |
StageTester.test(AbstractStage stage)
Prepares to test the given stage.
|
Modifier and Type | Class and Description |
---|---|
class |
ByteArray2String |
class |
Cache<T> |
class |
CipherStage |
class |
Clock
This stage sends the current timestamp repeatedly with a given interval delay of
Clock.intervalDelayInMs . |
class |
CollectorSink<T> |
class |
Counter<T> |
class |
CountingMapMerger<T>
Receives different CountingMap instances and merges them into a single one.
|
class |
ElementDelayMeasuringStage<T> |
class |
ElementsToList<I> |
class |
ElementThroughputMeasuringStage<T> |
class |
EveryXthStage<T> |
class |
FileExtensionSwitch |
class |
InitialElementProducer<T>
Represents a producer stage which outputs all of its elements in the first and only execution.
|
class |
InputPortSizePrinter<T> |
class |
InstanceCounter<T,C extends T> |
class |
InstanceOfFilter<I,O extends I> |
class |
MappingCounter<T>
This counts how many of different elements are sent to this stage.
|
class |
MD5Stage |
class |
MultipleInstanceOfFilter<I> |
class |
NoopFilter<T> |
class |
ObjectProducer<T>
Deprecated.
since 3.0. Use
StreamProducer instead. |
class |
Ramp
Sends a sequence of numbers starting from 0 to the value 'n' (not included) received by the input port, i.e., (0,1,2,..,n-1).
|
class |
RandomIntegerGenerator |
class |
Relay<T> |
class |
ResponsiveProducer<T>
Represents a producer stage which outputs one element per execution.
|
class |
StartTimestampFilter |
class |
StatelessCounter<T> |
class |
StopTimestampFilter |
class |
StreamProducer<T> |
class |
ZipByteArray
A stage to compress and decompress byte arrays
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractFilter<E> |
class |
AbstractTransformation<I,O> |
class |
Delay<T> |
class |
Sink<T> |
Modifier and Type | Class and Description |
---|---|
class |
Distributor<T>
New output ports can be created by calling
Distributor.getNewOutputPort() . |
Modifier and Type | Class and Description |
---|---|
class |
DynamicDistributor<T> |
Modifier and Type | Class and Description |
---|---|
class |
Merger<T>
This stage merges data from the input ports, by taking elements according to the chosen merge strategy and by putting them to the output port.
|
Modifier and Type | Class and Description |
---|---|
class |
DynamicMerger<T> |
Modifier and Type | Class and Description |
---|---|
class |
AbstractTcpReaderStage<T> |
class |
ByteArrayFileWriter |
class |
Directory2FilesFilter |
class |
File2ByteArray |
class |
File2Lines |
class |
File2SeqOfWords |
class |
File2TextLinesFilter |
class |
Printer<T>
A filter to print objects to a configured stream
|
Modifier and Type | Method and Description |
---|---|
AbstractStage |
EveryXthPrinter.getFirstStage() |
Modifier and Type | Class and Description |
---|---|
class |
Tokenizer |
class |
ToLowerCase
Receives a string and passes it on to the next stage only with lower case letters.
|
class |
WordcharacterFilter
Receives a string and passes it with removed punctuation and similar characters on to the next stage.
|
Modifier and Type | Class and Description |
---|---|
class |
ApplyXSLTToDocumentStage
Represents a transformation stage.
|
class |
LoadXMLToDocumentStage
Represents a transformation stage.
|
Modifier and Type | Interface and Description |
---|---|
interface |
PortAction<T extends AbstractStage> |
Modifier and Type | Method and Description |
---|---|
static <T extends AbstractStage> |
PortActionHelper.checkBlockingForPendingPortActionRequest(T stage,
BlockingQueue<PortAction<T>> portActions) |
static <T extends AbstractStage> |
PortActionHelper.checkForPendingPortActionRequest(T stage,
BlockingQueue<PortAction<T>> portActions) |
Copyright © 2015–2020. All rights reserved.