Home
last modified time | relevance | path

Searched refs:CachingStrategy (Results 1 – 25 of 36) sorted by relevance

12

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/
H A DCachingStrategy.java23 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 DDataXceiver.java515 final CachingStrategy cachingStrategy) throws IOException { in readBlock()
618 CachingStrategy cachingStrategy, in writeBlock()
1007 null, CachingStrategy.newDropBehind());
1132 CachingStrategy.newDropBehind(), false, false);
H A DVolumeScanner.java437 CachingStrategy.newDropBehind()); in scanBlock()
H A DBlockSender.java188 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 DDataTransferProtocol.java30 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy;
71 final CachingStrategy cachingStrategy) throws IOException; in readBlock()
111 final CachingStrategy cachingStrategy, in writeBlock()
H A DReceiver.java41 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 DSender.java46 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 DTestDataTransferProtocol.java62 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 DBlockReaderTestUtil.java43 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy;
193 setCachingStrategy(CachingStrategy.newDefaultStrategy()). in getBlockReader()
H A DTestBlockReaderLocal.java37 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 DStatic.hs19 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 Dimagedata.h42 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 DBlockReaderFactory.java45 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy;
152 private CachingStrategy cachingStrategy;
250 CachingStrategy cachingStrategy) { in setCachingStrategy()
H A DDFSInputStream.java69 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 DRemoteBlockReader.java44 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy;
409 CachingStrategy cachingStrategy) in newBlockReader()
H A DRemoteBlockReader2.java48 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy;
410 CachingStrategy cachingStrategy) throws IOException { in newBlockReader()
H A DBlockReaderLocal.java32 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy;
86 public Builder setCachingStrategy(CachingStrategy cachingStrategy) { in setCachingStrategy()
H A DDFSClient.java196 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 DDFSOutputStream.java82 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 Ddatatransfer.pb.go378CachingStrategy *CachingStrategyProto `protobuf:"bytes,5,opt,name=cachingStrategy" json:"ca… member
419 return m.CachingStrategy
461CachingStrategy *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 DTestBlockTokenWithDFS.java58 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 DTestDiskError.java155 checksum, CachingStrategy.newDefaultStrategy(), false, false, null); in testReplicationError()
H A DTestDataNodeVolumeFailure.java419 setCachingStrategy(CachingStrategy.newDefaultStrategy()). in accessBlock()
/dports/graphics/tesseract/tesseract-5.0.0/src/training/unicharset/
H A Dlstmtrainer.h190 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 DNamenodeFsck.java73 import org.apache.hadoop.hdfs.server.datanode.CachingStrategy;
741 setCachingStrategy(CachingStrategy.newDropBehind()). in copyBlock()

12