类org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker源码实例Demo

下面列出了怎么用org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: ranger   文件: RangerAuthorizationCoprocessor.java
@Override
public DeleteTracker postInstantiateDeleteTracker( ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker) throws IOException {
	final DeleteTracker ret;

	if(LOG.isDebugEnabled()) {
		LOG.debug("==> RangerAuthorizationCoprocessor.postInstantiateDeleteTracker()");
	}

	try {
		activatePluginClassLoader();
		ret = implRegionObserver.postInstantiateDeleteTracker(ctx, delTracker);
	} finally {
		deactivatePluginClassLoader();
	}

	if(LOG.isDebugEnabled()) {
		LOG.debug("<== RangerAuthorizationCoprocessor.postInstantiateDeleteTracker()");
	}

	return ret;
}
 
源代码2 项目: hbase   文件: VisibilityController.java
@Override
public DeleteTracker postInstantiateDeleteTracker(
    ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker)
    throws IOException {
  // Nothing to do if we are not filtering by visibility
  if (!authorizationEnabled) {
    return delTracker;
  }
  Region region = ctx.getEnvironment().getRegion();
  TableName table = region.getRegionInfo().getTable();
  if (table.isSystemTable()) {
    return delTracker;
  }
  // We are creating a new type of delete tracker here which is able to track
  // the timestamps and also the
  // visibility tags per cell. The covering cells are determined not only
  // based on the delete type and ts
  // but also on the visibility expression matching.
  return new VisibilityScanDeleteTracker(delTracker.getCellComparator());
}
 
源代码3 项目: hbase   文件: RegionCoprocessorHost.java
/**
 * @deprecated Since 2.0 with out any replacement and will be removed in 3.0
 */
@Deprecated
public DeleteTracker postInstantiateDeleteTracker(DeleteTracker result) throws IOException {
  if (this.coprocEnvironments.isEmpty()) {
    return result;
  }
  return execOperationWithResult(new ObserverOperationWithResult<RegionObserver, DeleteTracker>(
      regionObserverGetter, result) {
    @Override
    public DeleteTracker call(RegionObserver observer) throws IOException {
      return observer.postInstantiateDeleteTracker(this, getResult());
    }
  });
}
 
源代码4 项目: phoenix   文件: DelegateRegionObserver.java
@Override
public DeleteTracker postInstantiateDeleteTracker(
        ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker)
        throws IOException {
    return delegate.postInstantiateDeleteTracker(ctx, delTracker);
}
 
源代码5 项目: hbase   文件: RegionObserver.java
/**
 * Called after the ScanQueryMatcher creates ScanDeleteTracker. Implementing
 * this hook would help in creating customised DeleteTracker and returning
 * the newly created DeleteTracker
 * <p>
 * Warn: This is used by internal coprocessors. Should not be implemented by user coprocessors
 * @param ctx the environment provided by the region server
 * @param delTracker the deleteTracker that is created by the QueryMatcher
 * @return the Delete Tracker
 * @deprecated Since 2.0 with out any replacement and will be removed in 3.0
 */
@Deprecated
default DeleteTracker postInstantiateDeleteTracker(
    ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker)
    throws IOException {
  return delTracker;
}
 
 类所在包
 类方法
 同包方法