Uses of Class
io.streamthoughts.azkarra.api.monad.Tuple

Packages that use Tuple

Package	Description
io.streamthoughts.azkarra.api
io.streamthoughts.azkarra.api.model.predicate
io.streamthoughts.azkarra.api.monad
io.streamthoughts.azkarra.http.prometheus
io.streamthoughts.azkarra.http.query
io.streamthoughts.azkarra.runtime.service

Uses of Tuple in io.streamthoughts.azkarra.api

Method parameters in io.streamthoughts.azkarra.api with type arguments of type Tuple

Modifier and Type	Method	Description
Set<MetricGroup>	AzkarraStreamsService.getStreamsMetricsById(String applicationId, Predicate<Tuple<String,Metric>> filter)	Gets metrics for the specified streams application matching a predicate.

Uses of Tuple in io.streamthoughts.azkarra.api.model.predicate

Methods in io.streamthoughts.azkarra.api.model.predicate with parameters of type Tuple

Modifier and Type	Method	Description
boolean	GroupMetricFilter.test(Tuple<String,Metric> t)
boolean	NameMetricFilter.test(Tuple<String,Metric> t)
boolean	NonNullMetricFilter.test(Tuple<String,Metric> t)

Uses of Tuple in io.streamthoughts.azkarra.api.monad

Methods in io.streamthoughts.azkarra.api.monad that return Tuple

Modifier and Type	Method	Description
<LL,RR> Tuple<LL,RR>	Tuple.flatMap(Function<Tuple<L,R>,Tuple<LL,RR>> mapper)
<LL,RR> Tuple<LL,RR>	Tuple.fold(Function<L,LL> fl, Function<R,RR> fr)
<LL> Tuple<LL,R>	Tuple.mapKey(Function<L,LL> fn)
<RR> Tuple<L,RR>	Tuple.mapValue(Function<R,RR> fn)
static <L,R> Tuple<L,R>	Tuple.of(Map.Entry<L,R> entry)
static <L,R> Tuple<L,R>	Tuple.of(L l, R r)

Method parameters in io.streamthoughts.azkarra.api.monad with type arguments of type Tuple

Modifier and Type	Method	Description
<LL,RR> Tuple<LL,RR>	Tuple.flatMap(Function<Tuple<L,R>,Tuple<LL,RR>> mapper)
<LL,RR> Tuple<LL,RR>	Tuple.flatMap(Function<Tuple<L,R>,Tuple<LL,RR>> mapper)

Uses of Tuple in io.streamthoughts.azkarra.http.prometheus

Constructor parameters in io.streamthoughts.azkarra.http.prometheus with type arguments of type Tuple

Constructor	Description
KafkaStreamsMetricsCollector(AzkarraStreamsService service, Predicate<Tuple<String,Metric>> filter, String... applications)	Creates a new KafkaStreamsMetricsCollector instance.

Uses of Tuple in io.streamthoughts.azkarra.http.query

Methods in io.streamthoughts.azkarra.http.query that return Tuple

Modifier and Type	Method	Description
static Tuple<QueryInfo,Queried>	JsonQuerySerde.deserialize(String storeName, byte[] data)

Uses of Tuple in io.streamthoughts.azkarra.runtime.service

Method parameters in io.streamthoughts.azkarra.runtime.service with type arguments of type Tuple

Modifier and Type	Method	Description
Set<MetricGroup>	LocalAzkarraStreamsService.getStreamsMetricsById(String applicationId, Predicate<Tuple<String,Metric>> filter)	Gets metrics for the specified streams application matching a predicate.