Package kieker.analysis.generic
package kieker.analysis.generic
Copyright 2026 Kieker Project (http://kieker-monitoring.net)
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
-
ClassDescriptionAn instance of this class computes the throughput in terms of the number of objects received per time unit.Stage that accepts an array of object of type
and sends them to its output port individually. Check whether a CallEvent can be released based on an OperationEvent.Stage that accepts a collection of object of typeand sends them to its output port individually. Send an incoming event of type Base to the output, if and only if a suitable Control event was received.Counts all events and hands them to the next filter unchanged.An instance of this class receives any objects, increments an intern thread-safe counter without printing any message and delivers the unchanged objects to the output.Reader for multiple CSV files, producing single records for each row.CsvTableReaderStage<R,T> Reader for multiple CSV files.The DynamicEventDispatcher allows to select specific events from the event stream and send them to a specific event stream.In Fortran the compiler might suffix function names in the object file with an _.Receive all events and filter out the metadata records and store its information in a metadata model.IControlEventMatcher<C,B> Matcher interface to control whether an event can pass or must be held.Interface for event matchers used in the dynamic event dispatcher.Match the events by implementing interface.Create an object from a given set of text input fields.MapFileReader<T,R> Read a 2+n column file into a map.An instance of this class computes the throughput in terms of the number of records logged within the monitoring instance per time unit.Receives records at the input port and stores them in a queue for theRealtimeRecordDelayProducer.Forwards incomingIMonitoringRecords with delays computed from theIMonitoringRecord.getLoggingTimestamp()value (assumed to be in the configured resolution).Gets records from a queue, calculates the delay for each records and forwards the records after the delay.Rewrite logging information collected by the kieker-lang-pack-c and resolve function pointer references to actual function calls and files.Select and convert a string for the @{link MapFileReader}.Table<R,T> This filter has exactly one input port and one output port.Predefined types of streams for theTeeFilter.
STDLOG = standard log
STDOUT = standard output
STDERR = standard error output
NULL = filter doesn't print anythingThis filter has exactly one input port and one output port.