@Test @Category(UnitTest.class) public void testGetResourcePath() throws Exception { Path pathFromName = new Path(provider.getResourceName()); Path path = provider.getResourcePath(); Assert.assertEquals("Paths are different!", pathFromName.toString(), path.toString()); }
public Path getResourcePath() throws IOException { if (resourcePath == null) { try { resourcePath = determineResourcePath(getConfiguration(), getResourceName()); } catch (URISyntaxException e) { throw new IOException(e); } } return resourcePath; }
HdfsAdHocDataProvider extends AdHocDataProvider { public Path getResourcePath() throws IOException { if (resourcePath == null) { try { resourcePath = determineResourcePath(getConfiguration(), getResourceName()); } catch (URISyntaxException e) { throw new IOException(e); } } return resourcePath; } }
HdfsAdHocDataProvider extends AdHocDataProvider { public Path getResourcePath() throws IOException { if (resourcePath == null) { try { resourcePath = determineResourcePath(getConfiguration(), getResourceName()); } catch (URISyntaxException e) { throw new IOException(e); } } return resourcePath; } HdfsAdHocDataProvider(Configuration conf,
    ProviderProperties providerProperties);  HdfsAdHocDataProvider(Configuration conf, String resourceName,
    ProviderProperties providerProperties); }
HdfsAdHocDataProvider extends AdHocDataProvider { public Path getResourcePath() throws IOException { if (resourcePath == null) { try { resourcePath = determineResourcePath(getConfiguration(), getResourceName()); } catch (URISyntaxException e) { throw new IOException(e); } } return resourcePath; } 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 { public Path getResourcePath() throws IOException { if (resourcePath == null) { try { resourcePath = determineResourcePath(getConfiguration(), getResourceName()); } catch (URISyntaxException e) { throw new IOException(e); } } return resourcePath; } 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();  }