|
21 | 21 | import java.net.URI;
|
22 | 22 | import java.util.Map;
|
23 | 23 | import java.util.UUID;
|
24 |
| -import org.apache.hadoop.classification.VisibleForTesting; |
| 24 | +import java.util.concurrent.atomic.AtomicLong; |
25 | 25 |
|
| 26 | +import org.apache.hadoop.classification.VisibleForTesting; |
26 | 27 | import org.apache.hadoop.fs.azurebfs.services.AbfsCounters;
|
| 28 | +import org.apache.hadoop.fs.azurebfs.services.AbfsReadFooterMetrics; |
27 | 29 | import org.apache.hadoop.fs.azurebfs.utils.MetricFormat;
|
28 | 30 | import org.apache.hadoop.fs.statistics.DurationTracker;
|
29 | 31 | import org.apache.hadoop.fs.statistics.IOStatistics;
|
|
33 | 35 | import org.apache.hadoop.metrics2.lib.MetricsRegistry;
|
34 | 36 | import org.apache.hadoop.metrics2.lib.MutableCounterLong;
|
35 | 37 | import org.apache.hadoop.metrics2.lib.MutableMetric;
|
36 |
| -import org.apache.hadoop.fs.azurebfs.services.AbfsReadFooterMetrics; |
37 |
| -import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.*; |
| 38 | + |
| 39 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.BYTES_RECEIVED; |
| 40 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.BYTES_SENT; |
| 41 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.CALL_APPEND; |
| 42 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.CALL_CREATE; |
| 43 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.CALL_CREATE_NON_RECURSIVE; |
| 44 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.CALL_DELETE; |
| 45 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.CALL_EXIST; |
| 46 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.CALL_GET_DELEGATION_TOKEN; |
| 47 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.CALL_GET_FILE_STATUS; |
| 48 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.CALL_LIST_STATUS; |
| 49 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.CALL_MKDIRS; |
| 50 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.CALL_OPEN; |
| 51 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.CALL_RENAME; |
| 52 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.CONNECTIONS_MADE; |
| 53 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.DIRECTORIES_CREATED; |
| 54 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.DIRECTORIES_DELETED; |
| 55 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.ERROR_IGNORED; |
| 56 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.FILES_CREATED; |
| 57 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.FILES_DELETED; |
| 58 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.GET_RESPONSES; |
| 59 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.HTTP_DELETE_REQUEST; |
| 60 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.HTTP_GET_REQUEST; |
| 61 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.HTTP_HEAD_REQUEST; |
| 62 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.HTTP_PATCH_REQUEST; |
| 63 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.HTTP_POST_REQUEST; |
| 64 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.HTTP_PUT_REQUEST; |
| 65 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.METADATA_INCOMPLETE_RENAME_FAILURES; |
| 66 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.READ_THROTTLES; |
| 67 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.RENAME_PATH_ATTEMPTS; |
| 68 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.RENAME_RECOVERY; |
| 69 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.SEND_REQUESTS; |
| 70 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.SERVER_UNAVAILABLE; |
| 71 | +import static org.apache.hadoop.fs.azurebfs.AbfsStatistic.WRITE_THROTTLES; |
38 | 72 | import static org.apache.hadoop.fs.statistics.impl.IOStatisticsBinding.iostatisticsStore;
|
39 | 73 | import static org.apache.hadoop.util.Time.now;
|
40 | 74 |
|
41 |
| -import java.util.concurrent.atomic.AtomicLong; |
42 | 75 |
|
43 | 76 | /**
|
44 | 77 | * Instrumentation of Abfs counters.
|
|
0 commit comments