• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

Java ByteArrayManager类的典型用法和代码示例

java 1次浏览

本文整理汇总了Java中org.apache.hadoop.hdfs.util.ByteArrayManager的典型用法代码示例。如果您正苦于以下问题:Java ByteArrayManager类的具体用法?Java ByteArrayManager怎么用?Java ByteArrayManager使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ByteArrayManager类属于org.apache.hadoop.hdfs.util包,在下文中一共展示了ByteArrayManager类的13个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: ClientContext

点赞 3

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
private ClientContext(String name, Conf conf) {
  this.name = name;
  this.confString = confAsString(conf);
  this.shortCircuitCache = new ShortCircuitCache(
      conf.shortCircuitStreamsCacheSize,
      conf.shortCircuitStreamsCacheExpiryMs,
      conf.shortCircuitMmapCacheSize,
      conf.shortCircuitMmapCacheExpiryMs,
      conf.shortCircuitMmapCacheRetryTimeout,
      conf.shortCircuitCacheStaleThresholdMs,
      conf.shortCircuitSharedMemoryWatcherInterruptCheckMs);
  this.peerCache =
        new PeerCache(conf.socketCacheCapacity, conf.socketCacheExpiry);
  this.keyProviderCache = new KeyProviderCache(conf.keyProviderCacheExpiryMs);
  this.useLegacyBlockReaderLocal = conf.useLegacyBlockReaderLocal;
  this.domainSocketFactory = new DomainSocketFactory(conf);

  this.byteArrayManager = ByteArrayManager.newInstance(conf.writeByteArrayManagerConf);
}
 

开发者ID:naver,
项目名称:hadoop,
代码行数:20,
代码来源:ClientContext.java

示例2: ClientContext

点赞 3

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
private ClientContext(String name, DfsClientConf conf) {
  final ShortCircuitConf scConf = conf.getShortCircuitConf();

  this.name = name;
  this.confString = scConf.confAsString();
  this.shortCircuitCache = ShortCircuitCache.fromConf(scConf);
  this.peerCache = new PeerCache(scConf.getSocketCacheCapacity(),
      scConf.getSocketCacheExpiry());
  this.keyProviderCache = new KeyProviderCache(
      scConf.getKeyProviderCacheExpiryMs());
  this.useLegacyBlockReaderLocal = scConf.isUseLegacyBlockReaderLocal();
  this.domainSocketFactory = new DomainSocketFactory(scConf);

  this.byteArrayManager = ByteArrayManager.newInstance(
      conf.getWriteByteArrayManagerConf());
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:17,
代码来源:ClientContext.java

示例3: DataStreamer

点赞 3

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
private DataStreamer(HdfsFileStatus stat, ExtendedBlock block,
                     DFSClient dfsClient, String src,
                     Progressable progress, DataChecksum checksum,
                     AtomicReference<CachingStrategy> cachingStrategy,
                     ByteArrayManager byteArrayManage,
                     boolean isAppend, String[] favoredNodes) {
  this.block = block;
  this.dfsClient = dfsClient;
  this.src = src;
  this.progress = progress;
  this.stat = stat;
  this.checksum4WriteBlock = checksum;
  this.cachingStrategy = cachingStrategy;
  this.byteArrayManager = byteArrayManage;
  this.isLazyPersistFile = isLazyPersist(stat);
  this.isAppend = isAppend;
  this.favoredNodes = favoredNodes;

  final DfsClientConf conf = dfsClient.getConf();
  this.dfsclientSlowLogThresholdMs = conf.getSlowIoWarningThresholdMs();
  this.excludedNodes = initExcludedNodes(conf.getExcludedNodesCacheExpiry());
  this.errorState = new ErrorState(conf.getDatanodeRestartTimeout());
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:24,
代码来源:DataStreamer.java

示例4: ClientContext

点赞 3

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
private ClientContext(String name, Conf conf) {
  this.name = name;
  this.confString = confAsString(conf);
  this.shortCircuitCache = new ShortCircuitCache(
      conf.shortCircuitStreamsCacheSize,
      conf.shortCircuitStreamsCacheExpiryMs,
      conf.shortCircuitMmapCacheSize,
      conf.shortCircuitMmapCacheExpiryMs,
      conf.shortCircuitMmapCacheRetryTimeout,
      conf.shortCircuitCacheStaleThresholdMs,
      conf.shortCircuitSharedMemoryWatcherInterruptCheckMs);
  this.peerCache =
        new PeerCache(conf.socketCacheCapacity, conf.socketCacheExpiry);
  this.useLegacyBlockReaderLocal = conf.useLegacyBlockReaderLocal;
  this.domainSocketFactory = new DomainSocketFactory(conf);

  this.byteArrayManager = ByteArrayManager.newInstance(conf.writeByteArrayManagerConf);
}
 

开发者ID:yncxcw,
项目名称:FlexMap,
代码行数:19,
代码来源:ClientContext.java

示例5: releaseBuffer

点赞 2

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
/**
 * release a list of packets to ByteArrayManager
 *
 * @param packets packets to be release
 * @param bam ByteArrayManager
 */
private static void releaseBuffer(List<DFSPacket> packets, ByteArrayManager bam) {
  for(DFSPacket p : packets) {
    p.releaseBuffer(bam);
  }
  packets.clear();
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:13,
代码来源:DataStreamer.java

示例6: StripedDataStreamer

点赞 2

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
StripedDataStreamer(HdfsFileStatus stat,
                    DFSClient dfsClient, String src,
                    Progressable progress, DataChecksum checksum,
                    AtomicReference<CachingStrategy> cachingStrategy,
                    ByteArrayManager byteArrayManage, String[] favoredNodes,
                    short index, Coordinator coordinator) {
  super(stat, null, dfsClient, src, progress, checksum, cachingStrategy,
      byteArrayManage, favoredNodes);
  this.index = index;
  this.coordinator = coordinator;
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:12,
代码来源:StripedDataStreamer.java

示例7: releaseBuffer

点赞 2

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
private static void releaseBuffer(List<DFSPacket> packets, ByteArrayManager bam) {
  for (DFSPacket p : packets) {
    p.releaseBuffer(bam);
  }
  packets.clear();
}
 

开发者ID:naver,
项目名称:hadoop,
代码行数:7,
代码来源:DFSOutputStream.java

示例8: getByteArrayManager

点赞 2

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
public ByteArrayManager getByteArrayManager() {
  return byteArrayManager;
}
 

开发者ID:naver,
项目名称:hadoop,
代码行数:4,
代码来源:ClientContext.java

示例9: getWriteByteArrayManagerConf

点赞 2

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
/**
 * @return the writeByteArrayManagerConf
 */
public ByteArrayManager.Conf getWriteByteArrayManagerConf() {
  return writeByteArrayManagerConf;
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:7,
代码来源:DfsClientConf.java

示例10: releaseBuffer

点赞 2

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
/**
 * Release the buffer in this packet to ByteArrayManager.
 */
synchronized void releaseBuffer(ByteArrayManager bam) {
  bam.release(buf);
  buf = null;
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:8,
代码来源:DFSPacket.java

示例11: releaseBuffer

点赞 2

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
private synchronized void releaseBuffer(ByteArrayManager bam) {
  bam.release(buf);
  buf = null;
}
 

开发者ID:Nextzero,
项目名称:hadoop-2.6.0-cdh5.4.3,
代码行数:5,
代码来源:DFSOutputStream.java

示例12: releaseBuffer

点赞 2

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
private void releaseBuffer(ByteArrayManager bam) {
  bam.release(buf);
  buf = null;
}
 

开发者ID:yncxcw,
项目名称:FlexMap,
代码行数:5,
代码来源:DFSOutputStream.java

示例13: releaseBuffer

点赞 1

import org.apache.hadoop.hdfs.util.ByteArrayManager; //导入依赖的package包/类
/**
 * Release the buffer in this packet to ByteArrayManager.
 *
 * @param bam
 */
synchronized void releaseBuffer(ByteArrayManager bam) {
  bam.release(buf);
  buf = null;
}
 

开发者ID:naver,
项目名称:hadoop,
代码行数:10,
代码来源:DFSPacket.java


版权声明:本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系管理员进行删除。
喜欢 (0)