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

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;
}

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());
}

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());
}

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;
}

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());
}

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;
}

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());
}

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;
}

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());
}

@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;
}

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());
}

@Override
public ContentSummaryComputationContext computeContentSummary(
    ContentSummaryComputationContext summary) {
  int snapshotId = getParent().getSnapshot(getLocalNameBytes()).getId();
  return computeDirectoryContentSummary(summary, snapshotId);
}

@Override
public ContentSummaryComputationContext computeContentSummary(
    int snapshotId, ContentSummaryComputationContext summary) {
  return computeDirectoryContentSummary(summary, snapshotId);
}

@Override
public ContentSummaryComputationContext computeContentSummary(
    ContentSummaryComputationContext summary) {
  int snapshotId = getParent().getSnapshot(getLocalNameBytes()).getId();
  return computeDirectoryContentSummary(summary, snapshotId);
}

@Override
public ContentSummaryComputationContext computeContentSummary(
    ContentSummaryComputationContext summary) {
  int snapshotId = getParent().getSnapshot(getLocalNameBytes()).getId();
  return computeDirectoryContentSummary(summary, snapshotId);
}