Java 类org.apache.hadoop.fs.azure.NativeAzureFileSystem 实例源码

@Test
public void testMetricsSourceNames() {
  String name1 = NativeAzureFileSystem.newMetricsSourceName();
  String name2 = NativeAzureFileSystem.newMetricsSourceName();
  assertTrue(name1.startsWith("AzureFileSystemMetrics"));
  assertTrue(name2.startsWith("AzureFileSystemMetrics"));
  assertTrue(!name1.equals(name2));
}

@Test
public void testSkipMetricsCollection() throws Exception {
  AzureBlobStorageTestAccount a;
  a = AzureBlobStorageTestAccount.createMock();
  a.getFileSystem().getConf().setBoolean(
    NativeAzureFileSystem.SKIP_AZURE_METRICS_PROPERTY_NAME, true);
  a.getFileSystem().create(new Path("/foo")).close();
  a.closeFileSystem(); // Causes the file system to close, which publishes metrics
  assertEquals(0, getFilesCreated(a));
}

@Test
public void testMetricsSourceNames() {
  String name1 = NativeAzureFileSystem.newMetricsSourceName();
  String name2 = NativeAzureFileSystem.newMetricsSourceName();
  assertTrue(name1.startsWith("AzureFileSystemMetrics"));
  assertTrue(name2.startsWith("AzureFileSystemMetrics"));
  assertTrue(!name1.equals(name2));
}

@Test
public void testSkipMetricsCollection() throws Exception {
  AzureBlobStorageTestAccount a;
  a = AzureBlobStorageTestAccount.createMock();
  a.getFileSystem().getConf().setBoolean(
    NativeAzureFileSystem.SKIP_AZURE_METRICS_PROPERTY_NAME, true);
  a.getFileSystem().create(new Path("/foo")).close();
  a.closeFileSystem(); // Causes the file system to close, which publishes metrics
  assertEquals(0, getFilesCreated(a));
}

@Test
public void testMetricsSourceNames() {
  String name1 = NativeAzureFileSystem.newMetricsSourceName();
  String name2 = NativeAzureFileSystem.newMetricsSourceName();
  assertTrue(name1.startsWith("AzureFileSystemMetrics"));
  assertTrue(name2.startsWith("AzureFileSystemMetrics"));
  assertTrue(!name1.equals(name2));
}

@Test
public void testSkipMetricsCollection() throws Exception {
  AzureBlobStorageTestAccount a;
  a = AzureBlobStorageTestAccount.createMock();
  a.getFileSystem().getConf().setBoolean(
    NativeAzureFileSystem.SKIP_AZURE_METRICS_PROPERTY_NAME, true);
  a.getFileSystem().create(new Path("/foo")).close();
  a.closeFileSystem(); // Causes the file system to close, which publishes metrics
  assertEquals(0, getFilesCreated(a));
}

@Test
public void testMetricsSourceNames() {
  String name1 = NativeAzureFileSystem.newMetricsSourceName();
  String name2 = NativeAzureFileSystem.newMetricsSourceName();
  assertTrue(name1.startsWith("AzureFileSystemMetrics"));
  assertTrue(name2.startsWith("AzureFileSystemMetrics"));
  assertTrue(!name1.equals(name2));
}

private BandwidthGaugeUpdater getBandwidthGaugeUpdater() {
  NativeAzureFileSystem azureFs = (NativeAzureFileSystem)fs;
  AzureNativeFileSystemStore azureStore = azureFs.getStore();
  return azureStore.getBandwidthGaugeUpdater();
}

private AzureFileSystemInstrumentation getInstrumentation() {
  return ((NativeAzureFileSystem)fs).getInstrumentation();
}

private BandwidthGaugeUpdater getBandwidthGaugeUpdater() {
  NativeAzureFileSystem azureFs = (NativeAzureFileSystem)fs;
  AzureNativeFileSystemStore azureStore = azureFs.getStore();
  return azureStore.getBandwidthGaugeUpdater();
}

private AzureFileSystemInstrumentation getInstrumentation() {
  return ((NativeAzureFileSystem)fs).getInstrumentation();
}

private BandwidthGaugeUpdater getBandwidthGaugeUpdater() {
  NativeAzureFileSystem azureFs = (NativeAzureFileSystem)fs;
  AzureNativeFileSystemStore azureStore = azureFs.getStore();
  return azureStore.getBandwidthGaugeUpdater();
}

private AzureFileSystemInstrumentation getInstrumentation() {
  return ((NativeAzureFileSystem)fs).getInstrumentation();
}

private BandwidthGaugeUpdater getBandwidthGaugeUpdater() {
  NativeAzureFileSystem azureFs = (NativeAzureFileSystem)fs;
  AzureNativeFileSystemStore azureStore = azureFs.getStore();
  return azureStore.getBandwidthGaugeUpdater();
}

private AzureFileSystemInstrumentation getInstrumentation() {
  return ((NativeAzureFileSystem)fs).getInstrumentation();
}