/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/ |
H A D | CachingStrategy.java | 23 public class CachingStrategy { class 27 public static CachingStrategy newDefaultStrategy() { in newDefaultStrategy() 28 return new CachingStrategy(null, null); in newDefaultStrategy() 31 public static CachingStrategy newDropBehind() { in newDropBehind() 32 return new CachingStrategy(true, null); in newDropBehind() 39 public Builder(CachingStrategy prev) { in Builder() 54 public CachingStrategy build() { in build() 55 return new CachingStrategy(dropBehind, readahead); in build() 59 public CachingStrategy(Boolean dropBehind, Long readahead) { in CachingStrategy() method in CachingStrategy
|
H A D | DataXceiver.java | 515 final CachingStrategy cachingStrategy) throws IOException { in readBlock() 618 CachingStrategy cachingStrategy, in writeBlock() 1007 null, CachingStrategy.newDropBehind()); 1132 CachingStrategy.newDropBehind(), false, false);
|
H A D | VolumeScanner.java | 437 CachingStrategy.newDropBehind()); in scanBlock()
|
H A D | BlockSender.java | 188 CachingStrategy cachingStrategy) in BlockSender()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocol/datatransfer/ |
H A D | DataTransferProtocol.java | 30 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 71 final CachingStrategy cachingStrategy) throws IOException; in readBlock() 111 final CachingStrategy cachingStrategy, in writeBlock()
|
H A D | Receiver.java | 41 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 102 static private CachingStrategy getCachingStrategy(CachingStrategyProto strategy) { in getCachingStrategy() 107 return new CachingStrategy(dropBehind, readahead); in getCachingStrategy() 124 CachingStrategy.newDefaultStrategy())); in opReadBlock() 151 CachingStrategy.newDefaultStrategy()), in opWriteBlock()
|
H A D | Sender.java | 46 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 85 static private CachingStrategyProto getCachingStrategy(CachingStrategy cachingStrategy) { in getCachingStrategy() 103 final CachingStrategy cachingStrategy) throws IOException { in readBlock() 131 final CachingStrategy cachingStrategy, in writeBlock()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/ |
H A D | TestDataTransferProtocol.java | 62 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 442 0L, fileLen, true, CachingStrategy.newDefaultStrategy()); in testDataTransferProtocol() 449 -1L, fileLen, true, CachingStrategy.newDefaultStrategy()); in testDataTransferProtocol() 456 fileLen, fileLen, true, CachingStrategy.newDefaultStrategy()); in testDataTransferProtocol() 474 CachingStrategy.newDefaultStrategy()); in testDataTransferProtocol() 487 0L, fileLen+1, true, CachingStrategy.newDefaultStrategy()); in testDataTransferProtocol() 494 0L, fileLen, true, CachingStrategy.newDefaultStrategy()); in testDataTransferProtocol() 570 checksum, CachingStrategy.newDefaultStrategy(), false, false, null); in writeBlock()
|
H A D | BlockReaderTestUtil.java | 43 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 193 setCachingStrategy(CachingStrategy.newDefaultStrategy()). in getBlockReader()
|
H A D | TestBlockReaderLocal.java | 37 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 194 setCachingStrategy(new CachingStrategy(false, readahead)). in runBlockReaderLocalTest()
|
/dports/www/hs-postgrest/postgrest-8.0.0/_cabal_deps/wai-middleware-static-0.9.0/Network/Wai/Middleware/ |
H A D | Static.hs | 19 CachingStrategy(..), FileMeta(..), initCaching, CacheContainer 82 data CachingStrategy type 298 | CacheContainer (FilePath -> IO FileMeta) CachingStrategy 309 initCaching :: CachingStrategy -> IO CacheContainer
|
/dports/graphics/tesseract/tesseract-5.0.0/src/ccstruct/ |
H A D | imagedata.h | 42 enum CachingStrategy { enum 306 bool LoadDocuments(const std::vector<std::string> &filenames, CachingStrategy cache_strategy, 352 CachingStrategy cache_strategy_ = CS_SEQUENTIAL;
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/ |
H A D | BlockReaderFactory.java | 45 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 152 private CachingStrategy cachingStrategy; 250 CachingStrategy cachingStrategy) { in setCachingStrategy()
|
H A D | DFSInputStream.java | 69 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 119 private CachingStrategy cachingStrategy; 650 CachingStrategy curCachingStrategy; in blockSeekTo() 1140 CachingStrategy curCachingStrategy; 1697 new CachingStrategy.Builder(this.cachingStrategy).setReadahead(readahead).build(); 1707 new CachingStrategy.Builder(this.cachingStrategy).setDropBehind(dropBehind).build();
|
H A D | RemoteBlockReader.java | 44 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 409 CachingStrategy cachingStrategy) in newBlockReader()
|
H A D | RemoteBlockReader2.java | 48 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 410 CachingStrategy cachingStrategy) throws IOException { in newBlockReader()
|
H A D | BlockReaderLocal.java | 32 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 86 public Builder setCachingStrategy(CachingStrategy cachingStrategy) { in setCachingStrategy()
|
H A D | DFSClient.java | 196 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 275 private final CachingStrategy defaultReadCachingStrategy; 276 private final CachingStrategy defaultWriteCachingStrategy; 700 new CachingStrategy(readDropBehind, readahead); in DFSClient() 702 new CachingStrategy(writeDropBehind, readahead); in DFSClient() 2419 0, 1, true, CachingStrategy.newDefaultStrategy()); in inferChecksumTypeByReading() 3152 public CachingStrategy getDefaultReadCachingStrategy() { in getDefaultReadCachingStrategy() 3156 public CachingStrategy getDefaultWriteCachingStrategy() { in getDefaultWriteCachingStrategy()
|
H A D | DFSOutputStream.java | 82 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 184 private final AtomicReference<CachingStrategy> cachingStrategy; 1597 this.cachingStrategy = new AtomicReference<CachingStrategy>( in DFSOutputStream() 2360 CachingStrategy prevStrategy, nextStrategy; in setDropBehind() 2365 nextStrategy = new CachingStrategy.Builder(prevStrategy). in setDropBehind()
|
/dports/net/rclone/rclone-1.57.0/vendor/github.com/colinmarc/hdfs/v2/internal/protocol/hadoop_hdfs/ |
H A D | datatransfer.pb.go | 378 …CachingStrategy *CachingStrategyProto `protobuf:"bytes,5,opt,name=cachingStrategy" json:"ca… member 419 return m.CachingStrategy 461 …CachingStrategy *CachingStrategyProto `protobuf:"bytes,10,opt,name=cachingStrategy" json:"cachi… member 549 return m.CachingStrategy
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/ |
H A D | TestBlockTokenWithDFS.java | 58 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 159 setCachingStrategy(CachingStrategy.newDefaultStrategy()). in tryRead()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/ |
H A D | TestDiskError.java | 155 checksum, CachingStrategy.newDefaultStrategy(), false, false, null); in testReplicationError()
|
H A D | TestDataNodeVolumeFailure.java | 419 setCachingStrategy(CachingStrategy.newDefaultStrategy()). in accessBlock()
|
/dports/graphics/tesseract/tesseract-5.0.0/src/training/unicharset/ |
H A D | lstmtrainer.h | 190 CachingStrategy cache_strategy,
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ |
H A D | NamenodeFsck.java | 73 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy; 741 setCachingStrategy(CachingStrategy.newDropBehind()). in copyBlock()
|