Searched refs:dfsis (Results 1 – 4 of 4) sorted by relevance
94 HdfsDataInputStream dfsis = (HdfsDataInputStream) fis; in testRamDiskShortCircuitRead() local96 dfsis.getReadStatistics().getTotalBytesRead()); in testRamDiskShortCircuitRead()98 dfsis.getReadStatistics().getTotalShortCircuitBytesRead()); in testRamDiskShortCircuitRead()141 HdfsDataInputStream dfsis = (HdfsDataInputStream) fis; in testRamDiskEvictionWithShortCircuitReadHandle() local143 dfsis.getReadStatistics().getTotalBytesRead()); in testRamDiskEvictionWithShortCircuitReadHandle()145 dfsis.getReadStatistics().getTotalShortCircuitBytesRead()); in testRamDiskEvictionWithShortCircuitReadHandle()
315 final DFSInputStream dfsis = dfs.open(getUriPath(f),317 return dfs.createWrappedInputStream(dfsis);
1443 public HdfsDataInputStream createWrappedInputStream(DFSInputStream dfsis) in createWrappedInputStream() argument1445 final FileEncryptionInfo feInfo = dfsis.getFileEncryptionInfo(); in createWrappedInputStream()1453 new CryptoInputStream(dfsis, codec, decrypted.getMaterial(), in createWrappedInputStream()1458 return new HdfsDataInputStream(dfsis); in createWrappedInputStream()
303 final DFSInputStream dfsis =305 return dfs.createWrappedInputStream(dfsis);