Package | Description |
---|---|
org.apache.flink.runtime.metrics.dump | |
org.apache.flink.runtime.webmonitor.retriever |
Modifier and Type | Method and Description |
---|---|
MetricDumpSerialization.MetricSerializationResult |
MetricDumpSerialization.MetricDumpSerializer.serialize(Map<Counter,Tuple2<QueryScopeInfo,String>> counters,
Map<Gauge<?>,Tuple2<QueryScopeInfo,String>> gauges,
Map<Histogram,Tuple2<QueryScopeInfo,String>> histograms,
Map<Meter,Tuple2<QueryScopeInfo,String>> meters)
Serializes the given metrics and returns the resulting byte array.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<MetricDumpSerialization.MetricSerializationResult> |
MetricQueryService.queryMetrics(Time timeout) |
Modifier and Type | Method and Description |
---|---|
List<MetricDump> |
MetricDumpSerialization.MetricDumpDeserializer.deserialize(MetricDumpSerialization.MetricSerializationResult data)
De-serializes metrics from the given byte array and returns them as a list of
MetricDump . |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<MetricDumpSerialization.MetricSerializationResult> |
MetricQueryServiceGateway.queryMetrics(Time timeout) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.