Package | Description |
---|---|
teetime.framework |
Contains the implementation of the TeeTime framework.
|
teetime.framework.pipe |
Contains all pipes related classes, such as factories and pre-defined pipes.
|
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.framework.validation | |
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.distributor.strategy | |
teetime.stage.basic.merger | |
teetime.stage.basic.merger.dynamic | |
teetime.stage.io | |
teetime.stage.quicksort | |
teetime.stage.string | |
teetime.stage.taskfarm |
Modifier and Type | Class and Description |
---|---|
class |
DynamicOutputPort<T> |
Modifier and Type | Field and Description |
---|---|
protected OutputPort<O> |
AbstractProducerStage.outputPort |
Modifier and Type | Method and Description |
---|---|
protected <T> OutputPort<T> |
AbstractStage.createOutputPort()
Creates and adds an OutputPort to the stage
|
protected <T> OutputPort<T> |
AbstractStage.createOutputPort(Class<T> type)
Creates and adds an OutputPort to the stage
|
protected <T> OutputPort<T> |
AbstractStage.createOutputPort(Class<T> type,
String name)
Creates and adds an OutputPort to the stage
|
protected <T> OutputPort<T> |
CompositeStage.createOutputPort(OutputPort<T> subStageOutputPort) |
protected <T> OutputPort<T> |
AbstractStage.createOutputPort(String name)
Creates and adds an OutputPort to the stage
|
OutputPort<I> |
ConfigurationBuilder.Connection.getOutputPort() |
OutputPort<S> |
DivideAndConquerStage.getOutputPort() |
OutputPort<O> |
AbstractProducerStage.getOutputPort() |
OutputPort<? extends T> |
AbstractPipe.getSourcePort() |
OutputPort<? extends T> |
InstantiationPipe.getSourcePort() |
Modifier and Type | Method and Description |
---|---|
protected List<OutputPort<?>> |
AbstractStage.getOutputPorts() |
List<OutputPort<?>> |
StageFacade.getOutputPorts(AbstractStage stage) |
List<OutputPort<?>> |
StageFacade.getOutputPorts(CompositeStage stage) |
Modifier and Type | Method and Description |
---|---|
protected <T> void |
CompositeStage.connectPorts(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort)
Connects two ports with a pipe with a default capacity of currently 512.
|
<T> void |
RuntimeServiceFacade.connectPorts(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort)
Connects two ports with a pipe with an unlimited capacity.
|
protected <T> void |
CompositeStage.connectPorts(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort,
int capacity)
Connects to ports with a pipe of a certain capacity
|
<T> void |
RuntimeServiceFacade.connectPorts(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort,
int capacity)
Connects to ports with a pipe of a certain capacity
|
<T> void |
Configuration.connectPorts(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort,
int capacity) |
<T> void |
Configuration.connectPorts(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort,
int capacity,
IPipeFactory pipeFactory) |
<T> void |
Configuration.connectPorts(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort,
IPipeFactory pipeFactory) |
protected <T> OutputPort<T> |
CompositeStage.createOutputPort(OutputPort<T> subStageOutputPort) |
void |
OutputPortRemovedListener.onOutputPortRemoved(AbstractStage stage,
OutputPort<?> removedOutputPort) |
protected void |
AbstractStage.removeDynamicPort(OutputPort<?> outputPort) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractStage.addOutputPortRemovedListener(PortRemovedListener<OutputPort<?>> outputPortRemovedListener) |
<S extends AbstractStage,O> |
ConfigurationBuilder.Connection.to(S stage,
Function<S,InputPort<I>> inputPort,
Function<S,OutputPort<O>> outputPort) |
Constructor and Description |
---|
AbstractPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort) |
AbstractSynchedPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort)
Deprecated.
|
AbstractUnsynchedPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort)
Deprecated.
|
InstantiationPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort,
int capacity) |
Modifier and Type | Method and Description |
---|---|
OutputPort<? extends T> |
IPipe.getSourcePort() |
OutputPort<? extends Object> |
DummyPipe.getSourcePort() |
Modifier and Type | Method and Description |
---|---|
<T> IPipe<T> |
IPipeFactory.newPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort) |
<T> IPipe<T> |
BoundedSynchedPipeFactory.newPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort)
Uses a default capacity of .
|
<T> IPipe<T> |
IPipeFactory.newPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort,
int capacity) |
<T> IPipe<T> |
BoundedSynchedPipeFactory.newPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort,
int capacity) |
Constructor and Description |
---|
AbstractSynchedPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort) |
AbstractUnsynchedPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort) |
BoundedSynchedPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort,
int capacity) |
ReflexivePipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort) |
UnboundedSynchedPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort) |
UnsynchedPipe(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort) |
Modifier and Type | Method and Description |
---|---|
List<OutputPort<?>> |
StageUnderTest.getOutputPorts() |
static <T> org.hamcrest.Matcher<OutputPort<T>> |
StageTester.produces(T... values) |
static <T> org.hamcrest.Matcher<OutputPort<T>> |
StageTester.producesNothing() |
Modifier and Type | Method and Description |
---|---|
StageTester |
OutputHolder.from(OutputPort<O> outputPort) |
Modifier and Type | Method and Description |
---|---|
OutputPort<?> |
InvalidPortConnection.getSourcePort() |
Constructor and Description |
---|
InvalidPortConnection(OutputPort<?> sourcePort,
InputPort<?> targetPort) |
Modifier and Type | Method and Description |
---|---|
OutputPort<File> |
FileExtensionSwitch.addFileExtension(String fileExtension) |
OutputPort<O> |
InstanceOfFilter.getMatchedOutputPort() |
OutputPort<I> |
InstanceOfFilter.getMismatchedOutputPort() |
OutputPort<O> |
InstanceOfFilter.getOutputPort()
Deprecated.
Since 1.1. Use
InstanceOfFilter.getMatchedOutputPort() instead. |
OutputPort<T> |
StatelessCounter.getOutputPort() |
<T extends I> |
MultipleInstanceOfFilter.getOutputPortForType(Class<T> clazz) |
Modifier and Type | Field and Description |
---|---|
protected OutputPort<O> |
AbstractTransformation.outputPort |
Modifier and Type | Method and Description |
---|---|
OutputPort<O> |
ITransformation.getOutputPort() |
OutputPort<O> |
AbstractTransformation.getOutputPort() |
OutputPort<T> |
Delay.getOutputPort() |
Modifier and Type | Method and Description |
---|---|
OutputPort<T> |
Distributor.getNewOutputPort() |
Modifier and Type | Method and Description |
---|---|
List<OutputPort<?>> |
Distributor.getOutputPorts() |
Modifier and Type | Method and Description |
---|---|
void |
PortActionListener.onOutputPortCreated(DynamicDistributor<T> distributor,
OutputPort<T> port) |
void |
DynamicDistributor.onPortRemoved(OutputPort<?> removedOutputPort) |
void |
DynamicDistributor.removeDynamicPort(OutputPort<?> outputPort) |
Constructor and Description |
---|
RemovePortAction(OutputPort<T> outputPort) |
RemovePortActionDistributor(OutputPort<? extends T> outputPort) |
Modifier and Type | Method and Description |
---|---|
<T> OutputPort<T> |
NonBlockingRoundRobinStrategy.distribute(List<OutputPort<?>> outputPorts,
T element) |
<T> OutputPort<?> |
IDistributorStrategy.distribute(List<OutputPort<?>> outputPorts,
T element) |
<T> OutputPort<?> |
CopyByReferenceStrategy.distribute(List<OutputPort<?>> outputPorts,
T element) |
<T> OutputPort<?> |
CloneStrategy.distribute(List<OutputPort<?>> outputPorts,
T element) |
<T> OutputPort<?> |
BlockingRoundRobinStrategy.distribute(List<OutputPort<?>> outputPorts,
T element)
Deprecated.
|
<T> OutputPort<?> |
BlockingBusyWaitingRoundRobinDistributorStrategy.distribute(List<OutputPort<?>> outputPorts,
T element) |
Modifier and Type | Method and Description |
---|---|
void |
NonBlockingRoundRobinStrategy.onPortRemoved(OutputPort<?> removedOutputPort) |
void |
CopyByReferenceStrategy.onPortRemoved(OutputPort<?> removedOutputPort) |
void |
CloneStrategy.onPortRemoved(OutputPort<?> removedOutputPort) |
void |
BlockingRoundRobinStrategy.onPortRemoved(OutputPort<?> removedOutputPort)
Deprecated.
|
void |
BlockingBusyWaitingRoundRobinDistributorStrategy.onPortRemoved(OutputPort<?> removedOutputPort) |
Modifier and Type | Method and Description |
---|---|
<T> OutputPort<T> |
NonBlockingRoundRobinStrategy.distribute(List<OutputPort<?>> outputPorts,
T element) |
<T> OutputPort<?> |
IDistributorStrategy.distribute(List<OutputPort<?>> outputPorts,
T element) |
<T> OutputPort<?> |
CopyByReferenceStrategy.distribute(List<OutputPort<?>> outputPorts,
T element) |
<T> OutputPort<?> |
CloneStrategy.distribute(List<OutputPort<?>> outputPorts,
T element) |
<T> OutputPort<?> |
BlockingRoundRobinStrategy.distribute(List<OutputPort<?>> outputPorts,
T element)
Deprecated.
|
<T> OutputPort<?> |
BlockingBusyWaitingRoundRobinDistributorStrategy.distribute(List<OutputPort<?>> outputPorts,
T element) |
Modifier and Type | Method and Description |
---|---|
OutputPort<T> |
Merger.getOutputPort() |
Constructor and Description |
---|
CreatePortAction(OutputPort<T> outputPort,
int capacity)
Deprecated.
|
CreatePortActionMerger(OutputPort<T> outputPort,
int capacity) |
Modifier and Type | Method and Description |
---|---|
OutputPort<T> |
EveryXthPrinter.getNewOutputPort() |
Modifier and Type | Method and Description |
---|---|
OutputPort<int[]> |
QuicksortStage.getOutputPort() |
Modifier and Type | Method and Description |
---|---|
OutputPort<CountingMap<String>> |
WordCounter.getOutputPort() |
Modifier and Type | Method and Description |
---|---|
OutputPort<O> |
StaticTaskFarmStage.getOutputPort()
Returns the output port of the task farm/merger of the task farm.
|
OutputPort<O> |
ITaskFarmDuplicable.getOutputPort() |
OutputPort<O> |
TaskFarmStage.getOutputPort()
Deprecated.
Returns the output port of the task farm/merger of the task farm.
|
Copyright © 2015–2020. All rights reserved.