@Test @Category(UnitTest.class) public void testCanOpenNothingWritten() throws Exception { String name = provider.getResourceName(); Assert.assertFalse("Should not be able to open!", HdfsAdHocDataProvider.canOpen(conf, name, providerProperties)); }
@SuppressWarnings("squid:S1166") public static boolean canOpen(Configuration conf, String name, ProviderProperties providerProperties) throws IOException { try { Path p = determineResourcePath(conf, name); FileSystem fs = HadoopFileUtils.getFileSystem(conf, p); return fs.exists(p); } catch (URISyntaxException e) { } return false; }
HdfsAdHocDataProvider extends AdHocDataProvider { @SuppressWarnings("squid:S1166") public static boolean canOpen(Configuration conf, String name, ProviderProperties providerProperties) throws IOException { try { Path p = determineResourcePath(conf, name); FileSystem fs = HadoopFileUtils.getFileSystem(conf, p); return fs.exists(p); } catch (URISyntaxException e) { } return false; } }
HdfsAdHocDataProvider extends AdHocDataProvider { @SuppressWarnings("squid:S1166") public static boolean canOpen(Configuration conf, String name, ProviderProperties providerProperties) throws IOException { try { Path p = determineResourcePath(conf, name); FileSystem fs = HadoopFileUtils.getFileSystem(conf, p); return fs.exists(p); } catch (URISyntaxException e) { } return false; } HdfsAdHocDataProvider(Configuration conf,
    ProviderProperties providerProperties);  HdfsAdHocDataProvider(Configuration conf, String resourceName,
    ProviderProperties providerProperties); }
HdfsAdHocDataProvider extends AdHocDataProvider { @SuppressWarnings("squid:S1166") public static boolean canOpen(Configuration conf, String name, ProviderProperties providerProperties) throws IOException { try { Path p = determineResourcePath(conf, name); FileSystem fs = HadoopFileUtils.getFileSystem(conf, p); return fs.exists(p); } catch (URISyntaxException e) { } return false; } HdfsAdHocDataProvider(Configuration conf,
    ProviderProperties providerProperties);  HdfsAdHocDataProvider(Configuration conf, String resourceName,
    ProviderProperties providerProperties); @SuppressWarnings("squid:S1166") // Exception caught and handled static boolean canOpen(Configuration conf,
    String name, ProviderProperties providerProperties); static boolean canWrite(String name, Configuration conf,
    ProviderProperties providerProperties); @SuppressWarnings("squid:S1166") // Exception caught and handled static boolean exists(Configuration conf, String name,
    ProviderProperties providerProperties); static void delete(Configuration conf, String name,
    ProviderProperties providerProperties); @Override void setupJob(Job job); @Override OutputStream add(); @Override @SuppressWarnings("squid:S1166") // Exception caught and handled OutputStream add(String name); @Override void delete(); @Override void move(String toResource); @Override InputStream get(int index); @Override @SuppressFBWarnings(value = "WEAK_FILENAMEUTILS", justification = "adhoc provider, our class, we control the filenames") InputStream get(String name); @Override String getName(int index); Path getResourcePath(); @Override int size(); }
HdfsAdHocDataProvider extends AdHocDataProvider { @SuppressWarnings("squid:S1166") public static boolean canOpen(Configuration conf, String name, ProviderProperties providerProperties) throws IOException { try { Path p = determineResourcePath(conf, name); FileSystem fs = HadoopFileUtils.getFileSystem(conf, p); return fs.exists(p); } catch (URISyntaxException e) { } return false; } HdfsAdHocDataProvider(Configuration conf,
    ProviderProperties providerProperties);  HdfsAdHocDataProvider(Configuration conf, String resourceName,
    ProviderProperties providerProperties); @SuppressWarnings("squid:S1166") // Exception caught and handled static boolean canOpen(Configuration conf,
    String name, ProviderProperties providerProperties); static boolean canWrite(String name, Configuration conf,
    ProviderProperties providerProperties); @SuppressWarnings("squid:S1166") // Exception caught and handled static boolean exists(Configuration conf, String name,
    ProviderProperties providerProperties); static void delete(Configuration conf, String name,
    ProviderProperties providerProperties); @Override void setupJob(Job job); @Override OutputStream add(); @Override @SuppressWarnings("squid:S1166") // Exception caught and handled OutputStream add(String name); @Override void delete(); @Override void move(String toResource); @Override InputStream get(int index); @Override @SuppressFBWarnings(value = "WEAK_FILENAMEUTILS", justification = "adhoc provider, our class, we control the filenames") InputStream get(String name); @Override String getName(int index); Path getResourcePath(); @Override int size();  }