Package | Description |
---|---|
org.opennms.netmgt.flows.api | |
org.opennms.netmgt.flows.elastic | |
org.opennms.netmgt.flows.elastic.agg |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> |
FlowQueryService.getApplicationSeries(Set<String> applications,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> |
FlowQueryService.getConversationSeries(Set<String> conversations,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> |
FlowQueryService.getHostSeries(Set<String> hosts,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> |
FlowQueryService.getTopNApplicationSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> |
FlowQueryService.getTopNConversationSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> |
FlowQueryService.getTopNHostSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
Modifier and Type | Method and Description |
---|---|
static <T> BytesInOut |
BytesInOut.sum(com.google.common.collect.ImmutableSet<Map.Entry<Directional<T>,Double>> entrySet) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> |
InitializingFlowRepository.getApplicationSeries(Set<String> applications,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> |
ElasticFlowRepository.getApplicationSeries(Set<String> applications,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> |
SmartQueryService.getApplicationSeries(Set<String> applications,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> |
RawFlowQueryService.getApplicationSeries(Set<String> applications,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> |
InitializingFlowRepository.getConversationSeries(Set<String> conversations,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> |
ElasticFlowRepository.getConversationSeries(Set<String> conversations,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> |
SmartQueryService.getConversationSeries(Set<String> conversations,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> |
RawFlowQueryService.getConversationSeries(Set<String> conversations,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> |
InitializingFlowRepository.getHostSeries(Set<String> hosts,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> |
ElasticFlowRepository.getHostSeries(Set<String> hosts,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> |
SmartQueryService.getHostSeries(Set<String> hosts,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> |
RawFlowQueryService.getHostSeries(Set<String> hosts,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> |
InitializingFlowRepository.getTopNApplicationSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> |
ElasticFlowRepository.getTopNApplicationSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> |
SmartQueryService.getTopNApplicationSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> |
RawFlowQueryService.getTopNApplicationSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> |
InitializingFlowRepository.getTopNConversationSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> |
ElasticFlowRepository.getTopNConversationSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> |
SmartQueryService.getTopNConversationSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> |
RawFlowQueryService.getTopNConversationSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> |
InitializingFlowRepository.getTopNHostSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> |
ElasticFlowRepository.getTopNHostSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> |
SmartQueryService.getTopNHostSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> |
RawFlowQueryService.getTopNHostSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
protected static <T> CompletableFuture<com.google.common.collect.Table<Directional<T>,Long,Double>> |
ElasticFlowQueryService.mapTable(com.google.common.collect.Table<Directional<String>,Long,Double> source,
java.util.function.Function<String,CompletableFuture<T>> fn)
Rebuilds the table, mapping the row keys using the given function and fills
in missing cells with NaN values.
|
static <C,V> com.google.common.collect.Table<Directional<String>,C,V> |
TableUtils.sortTableByRowKeys(com.google.common.collect.Table<Directional<String>,C,V> table,
List<String> rowKeys)
Given a table, sort the rows such that the row keys appear in the same order
as the given list.
|
Modifier and Type | Method and Description |
---|---|
protected static <T> CompletableFuture<com.google.common.collect.Table<Directional<T>,Long,Double>> |
ElasticFlowQueryService.mapTable(com.google.common.collect.Table<Directional<String>,Long,Double> source,
java.util.function.Function<String,CompletableFuture<T>> fn)
Rebuilds the table, mapping the row keys using the given function and fills
in missing cells with NaN values.
|
static <C,V> com.google.common.collect.Table<Directional<String>,C,V> |
TableUtils.sortTableByRowKeys(com.google.common.collect.Table<Directional<String>,C,V> table,
List<String> rowKeys)
Given a table, sort the rows such that the row keys appear in the same order
as the given list.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> |
AggregatedFlowQueryService.getApplicationSeries(Set<String> applications,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> |
AggregatedFlowQueryService.getConversationSeries(Set<String> conversations,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> |
AggregatedFlowQueryService.getHostSeries(Set<String> hosts,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> |
AggregatedFlowQueryService.getTopNApplicationSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> |
AggregatedFlowQueryService.getTopNConversationSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> |
AggregatedFlowQueryService.getTopNHostSeries(int N,
long step,
boolean includeOther,
List<Filter> filters) |
Copyright © 2021. All rights reserved.