org.opennms.netmgt.flows.elastic

Class ElasticFlowQueryService

java.lang.Object

org.opennms.netmgt.flows.elastic.ElasticFlowQueryService

All Implemented Interfaces:

FlowQueryService

Direct Known Subclasses:

AggregatedFlowQueryService, RawFlowQueryService

public abstract class ElasticFlowQueryService
extends Object
implements FlowQueryService

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
<T extends io.searchbox.client.JestResult> CompletableFuture<T>	executeAsync(io.searchbox.action.Action<T> action)
protected static <T> CompletableFuture<com.google.common.collect.Table<Directional<T>,Long,Double>>	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.
CompletableFuture<io.searchbox.core.SearchResult>	searchAsync(String query, TimeRangeFilter timeRangeFilter)
protected static <T,A,R> CompletableFuture<R>	transpose(Iterable<CompletableFuture<T>> futures, java.util.stream.Collector<? super T,A,R> collector)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.opennms.netmgt.flows.api.FlowQueryService

getApplications, getApplicationSeries, getApplicationSummaries, getConversations, getConversationSeries, getConversationSummaries, getFlowCount, getHosts, getHostSeries, getHostSummaries, getTopNApplicationSeries, getTopNApplicationSummaries, getTopNConversationSeries, getTopNConversationSummaries, getTopNHostSeries, getTopNHostSummaries

Constructor Detail

ElasticFlowQueryService

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

Method Detail

mapTable

protected static <T> CompletableFuture<com.google.common.collect.Table<Directional<T>,Long,Double>> 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.

transpose

protected static <T,A,R> CompletableFuture<R> transpose(Iterable<CompletableFuture<T>> futures,
                                                        java.util.stream.Collector<? super T,A,R> collector)

searchAsync

public CompletableFuture<io.searchbox.core.SearchResult> searchAsync(String query,
                                                                     TimeRangeFilter timeRangeFilter)

executeAsync

public <T extends io.searchbox.client.JestResult> CompletableFuture<T> executeAsync(io.searchbox.action.Action<T> action)