Package org.opennms.netmgt.flows.api

Interface FlowQueryService

All Known Implementing Classes:

AggregatedFlowQueryService, ElasticFlowQueryService, RawFlowQueryService, SmartQueryService

public interface FlowQueryService

Used to query statistics and time series derived from flow data.

Method Summary

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<com.google.common.collect.Table<Directional<java.lang.String>,java.lang.Long,java.lang.Double>>	getFieldSeries(LimitedCardinalityField field, long step, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>>	getFieldSummaries(LimitedCardinalityField field, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>>	getFieldValues(LimitedCardinalityField field, 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)

Method Detail

getFlowCount

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

getApplications

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

getTopNApplicationSummaries

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

getApplicationSummaries

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

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)

getTopNApplicationSeries

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)

getConversations

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)

getTopNConversationSummaries

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

getConversationSummaries

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

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)

getTopNConversationSeries

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)

getHosts

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

getTopNHostSummaries

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

getHostSummaries

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

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)

getTopNHostSeries

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)

getFieldValues

java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getFieldValues(LimitedCardinalityField field,
                                                                                        java.util.List<Filter> filters)

getFieldSummaries

java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>> getFieldSummaries(LimitedCardinalityField field,
                                                                                                           java.util.List<Filter> filters)

getFieldSeries

java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<java.lang.String>,java.lang.Long,java.lang.Double>> getFieldSeries(LimitedCardinalityField field,
                                                                                                                                                                  long step,
                                                                                                                                                                  java.util.List<Filter> filters)