Package org.opennms.netmgt.flows.elastic.agg

Class AggregatedFlowQueryService

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 String	INDEX_NAME
static String	OTHER_NAME

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
CompletableFuture<List<String>>	getApplications(String matchingPrefix, long limit, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>>	getApplicationSeries(Set<String> applications, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<String>>>	getApplicationSummaries(Set<String> applications, boolean includeOther, List<Filter> filters)
CompletableFuture<List<String>>	getConversations(String locationPattern, String protocolPattern, String lowerIPPattern, String upperIPPattern, String applicationPattern, long limit, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>>	getConversationSeries(Set<String> conversations, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<Conversation>>>	getConversationSummaries(Set<String> conversations, boolean includeOther, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>>	getFieldSeries(LimitedCardinalityField field, long step, List<Filter> filters)
CompletableFuture<List<TrafficSummary<String>>>	getFieldSummaries(LimitedCardinalityField field, List<Filter> filters)
CompletableFuture<List<String>>	getFieldValues(LimitedCardinalityField field, List<Filter> filters)
CompletableFuture<Long>	getFlowCount(List<Filter> filters)
CompletableFuture<List<String>>	getHosts(String regex, long limit, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>>	getHostSeries(Set<String> hosts, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<Host>>>	getHostSummaries(Set<String> hosts, boolean includeOther, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>>	getTopNApplicationSeries(int N, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<String>>>	getTopNApplicationSummaries(int N, boolean includeOther, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>>	getTopNConversationSeries(int N, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<Conversation>>>	getTopNConversationSummaries(int N, boolean includeOther, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>>	getTopNHostSeries(int N, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<Host>>>	getTopNHostSummaries(int N, boolean includeOther, List<Filter> filters)
CompletableFuture<Conversation>	resolveHostnameForConversation(Conversation convo, List<Filter> filters)
CompletableFuture<Host>	resolveHostnameForHost(Host host, 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 String INDEX_NAME

See Also:

Constant Field Values

OTHER_NAME

public static final String OTHER_NAME

See Also:

Constant Field Values

Constructor Detail

AggregatedFlowQueryService

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

Method Detail

getTopNApplicationSummaries

public CompletableFuture<List<TrafficSummary<String>>> getTopNApplicationSummaries(int N,
                                                                                   boolean includeOther,
                                                                                   List<Filter> filters)

getTopNApplicationSeries

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

getTopNConversationSummaries

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

getTopNConversationSeries

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

getTopNHostSummaries

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

getTopNHostSeries

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

getFieldValues

public CompletableFuture<List<String>> getFieldValues(LimitedCardinalityField field,
                                                      List<Filter> filters)

getFieldSummaries

public CompletableFuture<List<TrafficSummary<String>>> getFieldSummaries(LimitedCardinalityField field,
                                                                         List<Filter> filters)

getFieldSeries

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

getFlowCount

public CompletableFuture<Long> getFlowCount(List<Filter> filters)

getApplications

public CompletableFuture<List<String>> getApplications(String matchingPrefix,
                                                       long limit,
                                                       List<Filter> filters)

getConversations

public CompletableFuture<List<String>> getConversations(String locationPattern,
                                                        String protocolPattern,
                                                        String lowerIPPattern,
                                                        String upperIPPattern,
                                                        String applicationPattern,
                                                        long limit,
                                                        List<Filter> filters)

getHosts

public CompletableFuture<List<String>> getHosts(String regex,
                                                long limit,
                                                List<Filter> filters)

getApplicationSummaries

public CompletableFuture<List<TrafficSummary<String>>> getApplicationSummaries(Set<String> applications,
                                                                               boolean includeOther,
                                                                               List<Filter> filters)

getApplicationSeries

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

getConversationSummaries

public CompletableFuture<List<TrafficSummary<Conversation>>> getConversationSummaries(Set<String> conversations,
                                                                                      boolean includeOther,
                                                                                      List<Filter> filters)

getConversationSeries

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

getHostSummaries

public CompletableFuture<List<TrafficSummary<Host>>> getHostSummaries(Set<String> hosts,
                                                                      boolean includeOther,
                                                                      List<Filter> filters)

getHostSeries

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

resolveHostnameForConversation

public CompletableFuture<Conversation> resolveHostnameForConversation(Conversation convo,
                                                                      List<Filter> filters)

resolveHostnameForHost

public CompletableFuture<Host> resolveHostnameForHost(Host host,
                                                      List<Filter> filters)