@Test @Category(UnitTest.class) public void testGetName() throws Exception { String name = "foo"; OutputStream outputStream = provider.add(name); outputStream.close(); Assert.assertEquals("Adhoc size should be 1!", 1, provider.size()); Path pname = new Path(provider.getName(0)); Assert.assertEquals("Names are different!", name, pname.getName()); }
@Override public String getName(int index) throws IOException { initializeFiles(getConfiguration()); if (index >= 0 && index < files.size()) { return files.get(index).toString(); } throw new IOException("Index out of range (" + index + ") "); }
HdfsAdHocDataProvider extends AdHocDataProvider { @Override public String getName(int index) throws IOException { initializeFiles(getConfiguration()); if (index >= 0 && index < files.size()) { return files.get(index).toString(); } throw new IOException("Index out of range (" + index + ") "); } }
HdfsAdHocDataProvider extends AdHocDataProvider { @Override public String getName(int index) throws IOException { initializeFiles(getConfiguration()); if (index >= 0 && index < files.size()) { return files.get(index).toString(); } throw new IOException("Index out of range (" + index + ") "); } HdfsAdHocDataProvider(Configuration conf,
    ProviderProperties providerProperties);  HdfsAdHocDataProvider(Configuration conf, String resourceName,
    ProviderProperties providerProperties); }
HdfsAdHocDataProvider extends AdHocDataProvider { @Override public String getName(int index) throws IOException { initializeFiles(getConfiguration()); if (index >= 0 && index < files.size()) { return files.get(index).toString(); } throw new IOException("Index out of range (" + index + ") "); } 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 { @Override public String getName(int index) throws IOException { initializeFiles(getConfiguration()); if (index >= 0 && index < files.size()) { return files.get(index).toString(); } throw new IOException("Index out of range (" + index + ") "); } 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();  }