Package org.processmining.specpp.supervision.piping

Class PipeWorks

java.lang.Object

org.processmining.specpp.supervision.piping.PipeWorks

public class PipeWorks
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
static <O extends Observation & Mergeable<? super O>> TypeIdentTransformingPipe<O>	accumulatingPipe(java.util.function.Supplier<O> initial)
static <O extends Observation> ActionPipe<O>	actionPipe(java.util.function.Consumer<O> action)
static <O extends Observation> AsyncBufferPipe<O>	asyncBuffer()
static <O extends Observation> AsyncIdentityPipe<O>	asynchronizer()
static <O extends Observation> AsyncIdentityPipe<O>	asyncIdentityPipe()
static <I extends Observation,O extends Observation> AsyncSummarizingBufferPipe<I,O>	asyncSummarizingBuffer(ObservationSummarizer<I,O> summarizer)
static <I extends Observation,O extends Observation> AsyncTransformingPipe<I,O>	asyncTransformingPipe(ObservationTransformer<? super I,? extends O> transformer)
static <O extends Observation> BufferPipe<O>	buffer()
static <O extends Observation> ConcurrencyBridge<O>	concurrencyBridge()
static MessageLogger	consoleLogger()
static <O extends Observation> BufferPipe<O>	countingBuffer(int threshold)
static <E extends Event> EventSupervision<E>	eventSupervision()
static MessageLogger	fileLogger(java.lang.String loggerName, java.lang.String filePath)
static <O extends Observation> FilterPipe<O>	filterPipe(java.util.function.Predicate<? super O> predicate)
static <O extends Observation> IdentityPipe<O>	identityPipe()
static <O extends Observation> Observer<O>	loggingSink(java.lang.String source, java.util.function.Function<O,java.lang.String> mapper, Observer<? super LogMessage> ml)
static <O extends Observation> Observer<O>	loggingSink(java.lang.String source, Observer<? super LogMessage> ml)
static <O extends Observation> Observer<O>[]	loggingSinks(java.lang.String source, java.util.function.Function<O,java.lang.String> mapper, Observer<? super LogMessage>... mls)
static <O extends Observation> Observer<O>[]	loggingSinks(java.lang.String source, Observer<? super LogMessage>... mls)
static <O extends Observation & Mergeable<? super O>> MergingSummarizingPipe<O>	mergingSummarizingPipe()
static <O extends Observation> PackingPipe<O>	packingPipe()
static <O extends Observation> PredicatePipe<O>	predicatePipe(java.util.function.Predicate<? super O> predicate)
static <I extends Observation,O extends Observation> SummarizingBufferPipe<I,O>	selfEmptyingSummarizingBuffer(ObservationSummarizer<I,O> summarizer, int capacity)
static <O extends Observation> SkippingPipe<O>	skipper(int interval)
static <I extends Observation,O extends Observation> SummarizingBufferPipe<I,O>	summarizingBuffer(ObservationSummarizer<I,O> summarizer)
static <O extends Observation> TransformingPipe<O,TimedObservation<O>>	timer()
static <I extends Observation,O extends Observation> TransformingPipe<I,O>	transformingPipe(ObservationTransformer<? super I,? extends O> transformer)
static <O extends Observation> UnpackingPipe<O>	unpackingPipe()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

loggingSink

public static <O extends Observation> Observer<O> loggingSink(java.lang.String source,
                                                              Observer<? super LogMessage> ml)

loggingSink

public static <O extends Observation> Observer<O> loggingSink(java.lang.String source,
                                                              java.util.function.Function<O,java.lang.String> mapper,
                                                              Observer<? super LogMessage> ml)

loggingSinks

@SafeVarargs
public static <O extends Observation> Observer<O>[] loggingSinks(java.lang.String source,
                                                                 Observer<? super LogMessage>... mls)

loggingSinks

@SafeVarargs
public static <O extends Observation> Observer<O>[] loggingSinks(java.lang.String source,
                                                                 java.util.function.Function<O,java.lang.String> mapper,
                                                                 Observer<? super LogMessage>... mls)

identityPipe

public static <O extends Observation> IdentityPipe<O> identityPipe()

asynchronizer

public static <O extends Observation> AsyncIdentityPipe<O> asynchronizer()

asyncIdentityPipe

public static <O extends Observation> AsyncIdentityPipe<O> asyncIdentityPipe()

predicatePipe

public static <O extends Observation> PredicatePipe<O> predicatePipe(java.util.function.Predicate<? super O> predicate)

filterPipe

public static <O extends Observation> FilterPipe<O> filterPipe(java.util.function.Predicate<? super O> predicate)

mergingSummarizingPipe

public static <O extends Observation & Mergeable<? super O>> MergingSummarizingPipe<O> mergingSummarizingPipe()

accumulatingPipe

public static <O extends Observation & Mergeable<? super O>> TypeIdentTransformingPipe<O> accumulatingPipe(java.util.function.Supplier<O> initial)

eventSupervision

public static <E extends Event> EventSupervision<E> eventSupervision()

fileLogger

public static MessageLogger fileLogger(java.lang.String loggerName,
                                       java.lang.String filePath)

consoleLogger

public static MessageLogger consoleLogger()

buffer

public static <O extends Observation> BufferPipe<O> buffer()

concurrencyBridge

public static <O extends Observation> ConcurrencyBridge<O> concurrencyBridge()

countingBuffer

public static <O extends Observation> BufferPipe<O> countingBuffer(int threshold)

unpackingPipe

public static <O extends Observation> UnpackingPipe<O> unpackingPipe()

packingPipe

public static <O extends Observation> PackingPipe<O> packingPipe()

asyncBuffer

public static <O extends Observation> AsyncBufferPipe<O> asyncBuffer()

summarizingBuffer

public static <I extends Observation,O extends Observation> SummarizingBufferPipe<I,O> summarizingBuffer(ObservationSummarizer<I,O> summarizer)

selfEmptyingSummarizingBuffer

public static <I extends Observation,O extends Observation> SummarizingBufferPipe<I,O> selfEmptyingSummarizingBuffer(ObservationSummarizer<I,O> summarizer,
                                                                                                                                 int capacity)

asyncSummarizingBuffer

public static <I extends Observation,O extends Observation> AsyncSummarizingBufferPipe<I,O> asyncSummarizingBuffer(ObservationSummarizer<I,O> summarizer)

transformingPipe

public static <I extends Observation,O extends Observation> TransformingPipe<I,O> transformingPipe(ObservationTransformer<? super I,? extends O> transformer)

asyncTransformingPipe

public static <I extends Observation,O extends Observation> AsyncTransformingPipe<I,O> asyncTransformingPipe(ObservationTransformer<? super I,? extends O> transformer)

actionPipe

public static <O extends Observation> ActionPipe<O> actionPipe(java.util.function.Consumer<O> action)

skipper

public static <O extends Observation> SkippingPipe<O> skipper(int interval)

timer

public static <O extends Observation> TransformingPipe<O,TimedObservation<O>> timer()