Java 类org.apache.hadoop.hdfs.server.namenode.ContentSummaryComputationContext 实例源码

项目:hadoop    文件:DirectorySnapshottableFeature.java   
public ContentSummaryComputationContext computeContentSummary(
    final BlockStoragePolicySuite bsps,
    final INodeDirectory snapshotRoot,
    final ContentSummaryComputationContext summary) {
  snapshotRoot.computeContentSummary(summary);
  summary.getCounts().addContent(Content.SNAPSHOT, snapshotsByNames.size());
  summary.getCounts().addContent(Content.SNAPSHOTTABLE_DIRECTORY, 1);
  return summary;
}
项目:hadoop    文件:DirectoryWithSnapshotFeature.java   
public void computeContentSummary4Snapshot(final BlockStoragePolicySuite bsps,
    final ContentCounts counts) {
  // Create a new blank summary context for blocking processing of subtree.
  ContentSummaryComputationContext summary = 
      new ContentSummaryComputationContext(bsps);
  for(DirectoryDiff d : diffs) {
    for(INode deleted : d.getChildrenDiff().getList(ListType.DELETED)) {
      deleted.computeContentSummary(summary);
    }
  }
  // Add the counts from deleted trees.
  counts.addContents(summary.getCounts());
  // Add the deleted directory count.
  counts.addContent(Content.DIRECTORY, diffs.asList().size());
}
项目:aliyun-oss-hadoop-fs    文件:DirectoryWithSnapshotFeature.java   
public void computeContentSummary4Snapshot(final BlockStoragePolicySuite bsps,
    final ContentCounts counts) {
  // Create a new blank summary context for blocking processing of subtree.
  ContentSummaryComputationContext summary = 
      new ContentSummaryComputationContext(bsps);
  for(DirectoryDiff d : diffs) {
    for(INode deleted : d.getChildrenDiff().getList(ListType.DELETED)) {
      deleted.computeContentSummary(Snapshot.CURRENT_STATE_ID, summary);
    }
  }
  // Add the counts from deleted trees.
  counts.addContents(summary.getCounts());
}
项目:big-c    文件:DirectorySnapshottableFeature.java   
public ContentSummaryComputationContext computeContentSummary(
    final BlockStoragePolicySuite bsps,
    final INodeDirectory snapshotRoot,
    final ContentSummaryComputationContext summary) {
  snapshotRoot.computeContentSummary(summary);
  summary.getCounts().addContent(Content.SNAPSHOT, snapshotsByNames.size());
  summary.getCounts().addContent(Content.SNAPSHOTTABLE_DIRECTORY, 1);
  return summary;
}
项目:big-c    文件:DirectoryWithSnapshotFeature.java   
public void computeContentSummary4Snapshot(final BlockStoragePolicySuite bsps,
    final ContentCounts counts) {
  // Create a new blank summary context for blocking processing of subtree.
  ContentSummaryComputationContext summary = 
      new ContentSummaryComputationContext(bsps);
  for(DirectoryDiff d : diffs) {
    for(INode deleted : d.getChildrenDiff().getList(ListType.DELETED)) {
      deleted.computeContentSummary(summary);
    }
  }
  // Add the counts from deleted trees.
  counts.addContents(summary.getCounts());
  // Add the deleted directory count.
  counts.addContent(Content.DIRECTORY, diffs.asList().size());
}
项目:hadoop-2.6.0-cdh5.4.3    文件:DirectorySnapshottableFeature.java   
public ContentSummaryComputationContext computeContentSummary(
    final INodeDirectory snapshotRoot,
    final ContentSummaryComputationContext summary) {
  snapshotRoot.computeContentSummary(summary);
  summary.getCounts().add(Content.SNAPSHOT, snapshotsByNames.size());
  summary.getCounts().add(Content.SNAPSHOTTABLE_DIRECTORY, 1);
  return summary;
}
项目:hadoop-2.6.0-cdh5.4.3    文件:DirectoryWithSnapshotFeature.java   
public void computeContentSummary4Snapshot(final Content.Counts counts) {
  // Create a new blank summary context for blocking processing of subtree.
  ContentSummaryComputationContext summary = 
      new ContentSummaryComputationContext();
  for(DirectoryDiff d : diffs) {
    for(INode deleted : d.getChildrenDiff().getList(ListType.DELETED)) {
      deleted.computeContentSummary(summary);
    }
  }
  // Add the counts from deleted trees.
  counts.add(summary.getCounts());
  // Add the deleted directory count.
  counts.add(Content.DIRECTORY, diffs.asList().size());
}
项目:FlexMap    文件:DirectorySnapshottableFeature.java   
public ContentSummaryComputationContext computeContentSummary(
    final INodeDirectory snapshotRoot,
    final ContentSummaryComputationContext summary) {
  snapshotRoot.computeContentSummary(summary);
  summary.getCounts().add(Content.SNAPSHOT, snapshotsByNames.size());
  summary.getCounts().add(Content.SNAPSHOTTABLE_DIRECTORY, 1);
  return summary;
}
项目:FlexMap    文件:DirectoryWithSnapshotFeature.java   
public void computeContentSummary4Snapshot(final Content.Counts counts) {
  // Create a new blank summary context for blocking processing of subtree.
  ContentSummaryComputationContext summary = 
      new ContentSummaryComputationContext();
  for(DirectoryDiff d : diffs) {
    for(INode deleted : d.getChildrenDiff().getList(ListType.DELETED)) {
      deleted.computeContentSummary(summary);
    }
  }
  // Add the counts from deleted trees.
  counts.add(summary.getCounts());
  // Add the deleted directory count.
  counts.add(Content.DIRECTORY, diffs.asList().size());
}
项目:hadoop-on-lustre2    文件:INodeDirectorySnapshottable.java   
@Override
public ContentSummaryComputationContext computeContentSummary(
    final ContentSummaryComputationContext summary) {
  super.computeContentSummary(summary);
  summary.getCounts().add(Content.SNAPSHOT, snapshotsByNames.size());
  summary.getCounts().add(Content.SNAPSHOTTABLE_DIRECTORY, 1);
  return summary;
}
项目:hadoop-on-lustre2    文件:DirectoryWithSnapshotFeature.java   
public void computeContentSummary4Snapshot(final Content.Counts counts) {
  // Create a new blank summary context for blocking processing of subtree.
  ContentSummaryComputationContext summary = 
      new ContentSummaryComputationContext();
  for(DirectoryDiff d : diffs) {
    for(INode deleted : d.getChildrenDiff().getList(ListType.DELETED)) {
      deleted.computeContentSummary(summary);
    }
  }
  // Add the counts from deleted trees.
  counts.add(summary.getCounts());
  // Add the deleted directory count.
  counts.add(Content.DIRECTORY, diffs.asList().size());
}
项目:hadoop    文件:Snapshot.java   
@Override
public ContentSummaryComputationContext computeContentSummary(
    ContentSummaryComputationContext summary) {
  int snapshotId = getParent().getSnapshot(getLocalNameBytes()).getId();
  return computeDirectoryContentSummary(summary, snapshotId);
}
项目:aliyun-oss-hadoop-fs    文件:Snapshot.java   
@Override
public ContentSummaryComputationContext computeContentSummary(
    int snapshotId, ContentSummaryComputationContext summary) {
  return computeDirectoryContentSummary(summary, snapshotId);
}
项目:big-c    文件:Snapshot.java   
@Override
public ContentSummaryComputationContext computeContentSummary(
    ContentSummaryComputationContext summary) {
  int snapshotId = getParent().getSnapshot(getLocalNameBytes()).getId();
  return computeDirectoryContentSummary(summary, snapshotId);
}
项目:hadoop-2.6.0-cdh5.4.3    文件:Snapshot.java   
@Override
public ContentSummaryComputationContext computeContentSummary(
    ContentSummaryComputationContext summary) {
  int snapshotId = getParent().getSnapshot(getLocalNameBytes()).getId();
  return computeDirectoryContentSummary(summary, snapshotId);
}