Java 类org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager 实例源码

项目：hadoop-oss 文件：DelegationTokenAuthenticationFilter.java

@Override
protected void initializeAuthHandler(String authHandlerClassName,
    FilterConfig filterConfig) throws ServletException {
  // A single CuratorFramework should be used for a ZK cluster.
  // If the ZKSignerSecretProvider has already created it, it has to
  // be set here... to be used by the ZKDelegationTokenSecretManager
  ZKDelegationTokenSecretManager.setCurator((CuratorFramework)
      filterConfig.getServletContext().getAttribute(ZKSignerSecretProvider.
          ZOOKEEPER_SIGNER_SECRET_PROVIDER_CURATOR_CLIENT_ATTRIBUTE));
  super.initializeAuthHandler(authHandlerClassName, filterConfig);
  ZKDelegationTokenSecretManager.setCurator(null);
}

项目：hadoop 文件：DelegationTokenAuthenticationFilter.java

@Override
protected void initializeAuthHandler(String authHandlerClassName,
    FilterConfig filterConfig) throws ServletException {
  // A single CuratorFramework should be used for a ZK cluster.
  // If the ZKSignerSecretProvider has already created it, it has to
  // be set here... to be used by the ZKDelegationTokenSecretManager
  ZKDelegationTokenSecretManager.setCurator((CuratorFramework)
      filterConfig.getServletContext().getAttribute(ZKSignerSecretProvider.
          ZOOKEEPER_SIGNER_SECRET_PROVIDER_CURATOR_CLIENT_ATTRIBUTE));
  super.initializeAuthHandler(authHandlerClassName, filterConfig);
  ZKDelegationTokenSecretManager.setCurator(null);
}

项目：aliyun-oss-hadoop-fs 文件：DelegationTokenAuthenticationFilter.java

@Override
protected void initializeAuthHandler(String authHandlerClassName,
    FilterConfig filterConfig) throws ServletException {
  // A single CuratorFramework should be used for a ZK cluster.
  // If the ZKSignerSecretProvider has already created it, it has to
  // be set here... to be used by the ZKDelegationTokenSecretManager
  ZKDelegationTokenSecretManager.setCurator((CuratorFramework)
      filterConfig.getServletContext().getAttribute(ZKSignerSecretProvider.
          ZOOKEEPER_SIGNER_SECRET_PROVIDER_CURATOR_CLIENT_ATTRIBUTE));
  super.initializeAuthHandler(authHandlerClassName, filterConfig);
  ZKDelegationTokenSecretManager.setCurator(null);
}

项目：big-c 文件：DelegationTokenAuthenticationFilter.java

@Override
protected void initializeAuthHandler(String authHandlerClassName,
    FilterConfig filterConfig) throws ServletException {
  // A single CuratorFramework should be used for a ZK cluster.
  // If the ZKSignerSecretProvider has already created it, it has to
  // be set here... to be used by the ZKDelegationTokenSecretManager
  ZKDelegationTokenSecretManager.setCurator((CuratorFramework)
      filterConfig.getServletContext().getAttribute(ZKSignerSecretProvider.
          ZOOKEEPER_SIGNER_SECRET_PROVIDER_CURATOR_CLIENT_ATTRIBUTE));
  super.initializeAuthHandler(authHandlerClassName, filterConfig);
  ZKDelegationTokenSecretManager.setCurator(null);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：DelegationTokenAuthenticationFilter.java

@Override
protected void initializeAuthHandler(String authHandlerClassName,
    FilterConfig filterConfig) throws ServletException {
  // A single CuratorFramework should be used for a ZK cluster.
  // If the ZKSignerSecretProvider has already created it, it has to
  // be set here... to be used by the ZKDelegationTokenSecretManager
  ZKDelegationTokenSecretManager.setCurator((CuratorFramework)
      filterConfig.getServletContext().getAttribute(ZKSignerSecretProvider.
          ZOOKEEPER_SIGNER_SECRET_PROVIDER_CURATOR_CLIENT_ATTRIBUTE));
  super.initializeAuthHandler(authHandlerClassName, filterConfig);
  ZKDelegationTokenSecretManager.setCurator(null);
}

项目：hops 文件：DelegationTokenAuthenticationFilter.java

@Override
protected void initializeAuthHandler(String authHandlerClassName,
    FilterConfig filterConfig) throws ServletException {
  // A single CuratorFramework should be used for a ZK cluster.
  // If the ZKSignerSecretProvider has already created it, it has to
  // be set here... to be used by the ZKDelegationTokenSecretManager
  ZKDelegationTokenSecretManager.setCurator((CuratorFramework)
      filterConfig.getServletContext().getAttribute(ZKSignerSecretProvider.
          ZOOKEEPER_SIGNER_SECRET_PROVIDER_CURATOR_CLIENT_ATTRIBUTE));
  super.initializeAuthHandler(authHandlerClassName, filterConfig);
  ZKDelegationTokenSecretManager.setCurator(null);
}