java.lang.Object
- org.opennms.netmgt.flows.elastic.ElasticFlowQueryService
- - org.opennms.netmgt.flows.elastic.agg.AggregatedFlowQueryService

All Implemented Interfaces:

FlowQueryService
```
public class AggregatedFlowQueryService
extends ElasticFlowQueryService
```
Reads out from aggregated flows.

Field Summary

Fields
Modifier and Type Field Description

static java.lang.String INDEX_NAME

static java.lang.String OTHER_NAME

Constructor Summary

Constructors
Constructor Description

AggregatedFlowQueryService(io.searchbox.client.JestClient client, IndexSelector indexSelector)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>>`	`getApplications(java.lang.String matchingPrefix, long limit, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<java.lang.String>,java.lang.Long,java.lang.Double>>`	`getApplicationSeries(java.util.Set<java.lang.String> applications, long step, boolean includeOther, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>>`	`getApplicationSummaries(java.util.Set<java.lang.String> applications, boolean includeOther, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>>`	`getConversations(java.lang.String locationPattern, java.lang.String protocolPattern, java.lang.String lowerIPPattern, java.lang.String upperIPPattern, java.lang.String applicationPattern, long limit, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,java.lang.Long,java.lang.Double>>`	`getConversationSeries(java.util.Set<java.lang.String> conversations, long step, boolean includeOther, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Conversation>>>`	`getConversationSummaries(java.util.Set<java.lang.String> conversations, boolean includeOther, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<java.lang.Long>`	`getFlowCount(java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>>`	`getHosts(java.lang.String regex, long limit, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<Host>,java.lang.Long,java.lang.Double>>`	`getHostSeries(java.util.Set<java.lang.String> hosts, long step, boolean includeOther, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Host>>>`	`getHostSummaries(java.util.Set<java.lang.String> hosts, boolean includeOther, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<java.lang.String>,java.lang.Long,java.lang.Double>>`	`getTopNApplicationSeries(int N, long step, boolean includeOther, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>>`	`getTopNApplicationSummaries(int N, boolean includeOther, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,java.lang.Long,java.lang.Double>>`	`getTopNConversationSeries(int N, long step, boolean includeOther, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Conversation>>>`	`getTopNConversationSummaries(int N, boolean includeOther, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<Host>,java.lang.Long,java.lang.Double>>`	`getTopNHostSeries(int N, long step, boolean includeOther, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Host>>>`	`getTopNHostSummaries(int N, boolean includeOther, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<Conversation>`	`resolveHostnameForConversation(Conversation convo, java.util.List<Filter> filters)`
`java.util.concurrent.CompletableFuture<Host>`	`resolveHostnameForHost(Host host, java.util.List<Filter> filters)`

Methods inherited from class org.opennms.netmgt.flows.elastic.ElasticFlowQueryService
executeAsync, mapTable, searchAsync, transpose

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INDEX_NAME

public static final java.lang.String INDEX_NAME

See Also:: Constant Field Values

OTHER_NAME

public static final java.lang.String OTHER_NAME

See Also:: Constant Field Values

Constructor Detail

AggregatedFlowQueryService

public AggregatedFlowQueryService(io.searchbox.client.JestClient client,
                                  IndexSelector indexSelector)

Method Detail

getTopNApplicationSummaries

public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>> getTopNApplicationSummaries(int N,
                                                                                                                            boolean includeOther,
                                                                                                                            java.util.List<Filter> filters)

getTopNApplicationSeries

public java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<java.lang.String>,java.lang.Long,java.lang.Double>> getTopNApplicationSeries(int N,
                                                                                                                                                                                   long step,
                                                                                                                                                                                   boolean includeOther,
                                                                                                                                                                                   java.util.List<Filter> filters)

getTopNConversationSummaries

public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Conversation>>> getTopNConversationSummaries(int N,
                                                                                                                         boolean includeOther,
                                                                                                                         java.util.List<Filter> filters)

getTopNConversationSeries

public java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,java.lang.Long,java.lang.Double>> getTopNConversationSeries(int N,
                                                                                                                                                                                long step,
                                                                                                                                                                                boolean includeOther,
                                                                                                                                                                                java.util.List<Filter> filters)

getTopNHostSummaries

public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Host>>> getTopNHostSummaries(int N,
                                                                                                         boolean includeOther,
                                                                                                         java.util.List<Filter> filters)

getTopNHostSeries

public java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<Host>,java.lang.Long,java.lang.Double>> getTopNHostSeries(int N,
                                                                                                                                                                long step,
                                                                                                                                                                boolean includeOther,
                                                                                                                                                                java.util.List<Filter> filters)

getFlowCount

public java.util.concurrent.CompletableFuture<java.lang.Long> getFlowCount(java.util.List<Filter> filters)

getApplications

public java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getApplications(java.lang.String matchingPrefix,
                                                                                                long limit,
                                                                                                java.util.List<Filter> filters)

getConversations

public java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getConversations(java.lang.String locationPattern,
                                                                                                 java.lang.String protocolPattern,
                                                                                                 java.lang.String lowerIPPattern,
                                                                                                 java.lang.String upperIPPattern,
                                                                                                 java.lang.String applicationPattern,
                                                                                                 long limit,
                                                                                                 java.util.List<Filter> filters)

getHosts

public java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getHosts(java.lang.String regex,
                                                                                         long limit,
                                                                                         java.util.List<Filter> filters)

getApplicationSummaries

public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>> getApplicationSummaries(java.util.Set<java.lang.String> applications,
                                                                                                                        boolean includeOther,
                                                                                                                        java.util.List<Filter> filters)

getApplicationSeries

public java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<java.lang.String>,java.lang.Long,java.lang.Double>> getApplicationSeries(java.util.Set<java.lang.String> applications,
                                                                                                                                                                               long step,
                                                                                                                                                                               boolean includeOther,
                                                                                                                                                                               java.util.List<Filter> filters)

getConversationSummaries

public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Conversation>>> getConversationSummaries(java.util.Set<java.lang.String> conversations,
                                                                                                                     boolean includeOther,
                                                                                                                     java.util.List<Filter> filters)

getConversationSeries

public java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,java.lang.Long,java.lang.Double>> getConversationSeries(java.util.Set<java.lang.String> conversations,
                                                                                                                                                                            long step,
                                                                                                                                                                            boolean includeOther,
                                                                                                                                                                            java.util.List<Filter> filters)

getHostSummaries

public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Host>>> getHostSummaries(java.util.Set<java.lang.String> hosts,
                                                                                                     boolean includeOther,
                                                                                                     java.util.List<Filter> filters)

getHostSeries

public java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<Host>,java.lang.Long,java.lang.Double>> getHostSeries(java.util.Set<java.lang.String> hosts,
                                                                                                                                                            long step,
                                                                                                                                                            boolean includeOther,
                                                                                                                                                            java.util.List<Filter> filters)

resolveHostnameForConversation

public java.util.concurrent.CompletableFuture<Conversation> resolveHostnameForConversation(Conversation convo,
                                                                                           java.util.List<Filter> filters)

resolveHostnameForHost

public java.util.concurrent.CompletableFuture<Host> resolveHostnameForHost(Host host,
                                                                           java.util.List<Filter> filters)

Modifier and Type	Field	Description
`static java.lang.String`	`INDEX_NAME`
`static java.lang.String`	`OTHER_NAME`

Class AggregatedFlowQueryService

Field Summary

Constructor Summary

Method Summary

Methods inherited from class org.opennms.netmgt.flows.elastic.ElasticFlowQueryService

Methods inherited from class java.lang.Object

Field Detail

INDEX_NAME

OTHER_NAME

Constructor Detail

AggregatedFlowQueryService

Method Detail

getTopNApplicationSummaries

getTopNApplicationSeries

getTopNConversationSummaries

getTopNConversationSeries

getTopNHostSummaries

getTopNHostSeries

getFlowCount

getApplications

getConversations

getHosts

getApplicationSummaries

getApplicationSeries

getConversationSummaries

getConversationSeries

getHostSummaries

getHostSeries

resolveHostnameForConversation

resolveHostnameForHost