Package | Description |
---|---|
com.pervasive.datarush.graphs |
Provides classes and interfaces for the construction of executable
dataflow graphs.
|
com.pervasive.datarush.monitoring |
Provides classes and interfaces for reporting on commonly monitored
resources such as memory, threads, and I/O.
|
Modifier and Type | Method and Description |
---|---|
<T extends StatisticSupplier> |
LogicalStatistic.Builder.define(StatisticDefinition<T> definition,
T supplier)
Sets the values for
LogicalStatistic.definition() and LogicalStatistic.supplier()
based on those specified. |
static <T extends StatisticSupplier> |
LogicalStatistics.filterSuppliers(List<LogicalStatistic> stats,
StatisticDefinition<T> definition)
Utility method to select all statistics suppliers that match the given definition.
|
<T extends StatisticSupplier> |
StatisticsRegistry.register(StatisticDefinition<T> definition,
T supplier)
Registers the given statistics object.
|
Modifier and Type | Method and Description |
---|---|
StatisticSupplier |
LogicalStatistic.supplier()
Returns the supplier associated with this statistic.
|
StatisticSupplier |
LogicalStatistic.Builder.supplier()
Returns the value for
LogicalStatistic.supplier() . |
Modifier and Type | Class and Description |
---|---|
class |
RuntimeStatistic<T extends StatisticSupplier>
Pairing of a
StatisticDefinition and its StatisticSupplier . |
class |
StatisticDefinition<T extends StatisticSupplier>
Provides metadata for a statistic including including display name controls how the statistic
is to be aggregated across partitions.
|
Modifier and Type | Interface and Description |
---|---|
interface |
AccumulatedTimerSupplier
Abstract statistic that represents "wall-clock" time of
some runtime activity.
|
interface |
CounterSupplier
Abstract statistic that represents a count of
some runtime activity.
|
interface |
GaugeSupplier
Abstract statistic that represents a measure
of some runtime activity whose value may fluctuate over time.
|
interface |
IntervalTimerSupplier
Abstract statistic that represents "wall-clock" time of
some runtime activity.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractIntervalTimerSupplier
Convenient base class that should be extended by all implementations of
IntervalTimerSupplier |
class |
AccumulatedTimer
Basic mutable implementation of
AccumulatedTimerSupplier . |
class |
AccumulatedTimerSnapshot
A snapshot that reflects a point-in-time of a
IntervalTimerSupplier . |
class |
BasicCounter
Basic mutable implementation of
CounterSupplier . |
class |
CounterSnapshot
A snapshot that reflects a point-in-time of a
CounterSupplier . |
class |
GaugeSnapshot
A snapshot that reflects a point-in-time of a
GaugeSupplier . |
class |
IntervalTimer
Basic mutable implementation of
AccumulatedTimerSupplier . |
class |
IntervalTimerSnapshot
A snapshot that reflects a point-in-time of a
IntervalTimerSupplier . |
Modifier and Type | Method and Description |
---|---|
<T extends StatisticSupplier> |
StatisticsMap.get(StatisticDefinition<T> definition)
Returns the value corresponding to the given definition
|
<T extends StatisticSupplier> |
StatisticsMap.put(RuntimeStatistic<T> statistic)
Type-safe put that adds a pair of statistic and definition
|
Modifier and Type | Method and Description |
---|---|
static StatisticSupplier |
StatisticSuppliers.combine(StatisticDefinition<?> definition,
List<? extends StatisticSupplier> suppliers)
Creates a statistics supplier that combines the given set of suppliers.
|
StatisticSupplier |
StatisticSupplier.snapshot()
Returns a snapshot of this statistic.
|
Modifier and Type | Method and Description |
---|---|
abstract T |
StatisticDefinition.cast(StatisticSupplier value)
Casts the
StatisticSupplier to this definition, substituting
a default value for null. |
IntervalTimerSupplier |
IntervalTimerDefinition.cast(StatisticSupplier value) |
GaugeSupplier |
GaugeDefinition.cast(StatisticSupplier value) |
CounterSupplier |
CounterDefinition.cast(StatisticSupplier value) |
AccumulatedTimerSupplier |
AccumulatedTimerDefinition.cast(StatisticSupplier value) |
GaugeSupplier |
GaugeDefinition.doFinalSnapshot(StatisticSupplier supplier) |
CounterSupplier |
CounterDefinition.doFinalSnapshot(StatisticSupplier supplier) |
T |
StatisticDefinition.finalSnapshot(StatisticSupplier supplier)
Returns a snapshot view of the given statistics with all statistics appropriate for a graph
that is in a terminated state.
|
void |
StatisticsMap.put(StatisticDefinition<?> definition,
StatisticSupplier supplier)
Adds a value to the map.
|
Modifier and Type | Method and Description |
---|---|
abstract T |
StatisticDefinition.aggregate(List<? extends StatisticSupplier> values)
Performs aggregation across statistics.
|
IntervalTimerSupplier |
IntervalTimerDefinition.aggregate(List<? extends StatisticSupplier> values)
Performs timer aggregation per the aggregation rules specified on
IntervalTimerSupplier . |
GaugeSupplier |
GaugeDefinition.aggregate(List<? extends StatisticSupplier> values) |
CounterSupplier |
CounterDefinition.aggregate(List<? extends StatisticSupplier> values) |
AccumulatedTimerSupplier |
AccumulatedTimerDefinition.aggregate(List<? extends StatisticSupplier> values)
Performs timer aggregation per the aggregation rules specified on
IntervalTimerSupplier . |
static StatisticSupplier |
StatisticSuppliers.combine(StatisticDefinition<?> definition,
List<? extends StatisticSupplier> suppliers)
Creates a statistics supplier that combines the given set of suppliers.
|
Copyright © 2021 Actian Corporation. All rights reserved.