Class PipeWorks
- java.lang.Object
-
- org.processmining.specpp.supervision.piping.PipeWorks
-
public class PipeWorks extends java.lang.Object
-
-
Method Summary
All Methods Static Methods Concrete Methods 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 MessageLoggerconsoleLogger()static <O extends Observation>
BufferPipe<O>countingBuffer(int threshold)static <E extends Event>
EventSupervision<E>eventSupervision()static MessageLoggerfileLogger(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()
-
-
-
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()
-
-