private org.apache.hadoop.fs.FileSystem createInitializedAzureFS(URI fsUri, Configuration flinkConfig) throws IOException {
	org.apache.hadoop.conf.Configuration hadoopConfig = configLoader.getOrLoadHadoopConfig();

	org.apache.hadoop.fs.FileSystem azureFS = new NativeAzureFileSystem();
	azureFS.initialize(fsUri, hadoopConfig);

	return azureFS;
}
 

@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));
}
 

private org.apache.hadoop.fs.FileSystem createInitializedAzureFS(URI fsUri, Configuration flinkConfig) throws IOException {
	org.apache.hadoop.conf.Configuration hadoopConfig = configLoader.getOrLoadHadoopConfig();

	org.apache.hadoop.fs.FileSystem azureFS = new NativeAzureFileSystem();
	azureFS.initialize(fsUri, hadoopConfig);

	return azureFS;
}
 

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();
}