@Test public void testDoGetInputStream() throws Exception { InputStream inputStream = mock( InputStream.class ); when( hadoopFileSystem.open( hadoopFileSystemPath ) ).thenReturn( inputStream ); assertEquals( inputStream, hdfsFileObject.doGetInputStream() ); }
@Override protected InputStream doGetInputStream() throws Exception { return hdfs.open( hdfs.getPath( getName().getPath() ) ); }
HDFSFileObject extends AbstractFileObject { @Override protected InputStream doGetInputStream() throws Exception { return hdfs.open( hdfs.getPath( getName().getPath() ) ); } }
HDFSFileObject extends AbstractFileObject { @Override protected InputStream doGetInputStream() throws Exception { return hdfs.open( hdfs.getPath( getName().getPath() ) ); } HDFSFileObject( final AbstractFileName name, final HDFSFileSystem fileSystem ); }
HDFSFileObject extends AbstractFileObject { @Override protected InputStream doGetInputStream() throws Exception { return hdfs.open( hdfs.getPath( getName().getPath() ) ); } HDFSFileObject( final AbstractFileName name, final HDFSFileSystem fileSystem ); @Override void doCreateFolder(); @Override void doDelete(); }
HDFSFileObject extends AbstractFileObject { @Override protected InputStream doGetInputStream() throws Exception { return hdfs.open( hdfs.getPath( getName().getPath() ) ); } HDFSFileObject( final AbstractFileName name, final HDFSFileSystem fileSystem ); @Override void doCreateFolder(); @Override void doDelete();  }