- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.hadoop.hive.thrift.ZooKeeperTokenStore.getSession()
方法的一些代码示例,展示了ZooKeeperTokenStore.getSession()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperTokenStore.getSession()
方法的具体详情如下:
包路径:org.apache.hadoop.hive.thrift.ZooKeeperTokenStore
类名称:ZooKeeperTokenStore
方法名:getSession
暂无
代码示例来源:origin: com.facebook.presto.hive/hive-apache
private List<String> zkGetChildren(String path) {
CuratorFramework zk = getSession();
try {
return zk.getChildren().forPath(path);
} catch (Exception e) {
throw new TokenStoreException("Error getting children for " + path, e);
}
}
代码示例来源:origin: com.github.hyukjinkwon.shims/hive-shims-common
private List<String> zkGetChildren(String path) {
CuratorFramework zk = getSession();
try {
return zk.getChildren().forPath(path);
} catch (Exception e) {
throw new TokenStoreException("Error getting children for " + path, e);
}
}
代码示例来源:origin: org.apache.hive.shims/hive-shims-common-secure
private byte[] zkGetData(String nodePath) {
CuratorFramework zk = getSession();
try {
return zk.getData().forPath(nodePath);
} catch (KeeperException.NoNodeException ex) {
return null;
} catch (Exception e) {
throw new TokenStoreException("Error reading " + nodePath, e);
}
}
代码示例来源:origin: com.github.hyukjinkwon.shims/hive-shims-common
private byte[] zkGetData(String nodePath) {
CuratorFramework zk = getSession();
try {
return zk.getData().forPath(nodePath);
} catch (KeeperException.NoNodeException ex) {
return null;
} catch (Exception e) {
throw new TokenStoreException("Error reading " + nodePath, e);
}
}
代码示例来源:origin: com.facebook.presto.hive/hive-apache
private byte[] zkGetData(String nodePath) {
CuratorFramework zk = getSession();
try {
return zk.getData().forPath(nodePath);
} catch (KeeperException.NoNodeException ex) {
return null;
} catch (Exception e) {
throw new TokenStoreException("Error reading " + nodePath, e);
}
}
代码示例来源:origin: org.apache.hive.shims/hive-shims-common-secure
private List<String> zkGetChildren(String path) {
CuratorFramework zk = getSession();
try {
return zk.getChildren().forPath(path);
} catch (Exception e) {
throw new TokenStoreException("Error getting children for " + path, e);
}
}
代码示例来源:origin: org.spark-project.hive.shims/hive-shims-common-secure
private Map<Integer, byte[]> getAllKeys() throws KeeperException,
InterruptedException {
String masterKeyNode = rootNode + NODE_KEYS;
ZooKeeper zk = getSession();
List<String> nodes = zk.getChildren(masterKeyNode, false);
Map<Integer, byte[]> result = new HashMap<Integer, byte[]>();
for (String node : nodes) {
byte[] data = zk.getData(masterKeyNode + "/" + node, false, null);
if (data != null) {
result.put(getSeq(node), data);
}
}
return result;
}
代码示例来源:origin: com.github.hyukjinkwon.shims/hive-shims-common
@Override
public void updateMasterKey(int keySeq, String s) {
CuratorFramework zk = getSession();
String keyPath = rootNode + NODE_KEYS + "/" + String.format(ZK_SEQ_FORMAT, keySeq);
try {
zk.setData().forPath(keyPath, s.getBytes());
} catch (Exception e) {
throw new TokenStoreException("Error setting data in " + keyPath, e);
}
}
代码示例来源:origin: org.apache.hive.shims/hive-shims-common-secure
@Override
public void updateMasterKey(int keySeq, String s) {
CuratorFramework zk = getSession();
String keyPath = rootNode + NODE_KEYS + "/" + String.format(ZK_SEQ_FORMAT, keySeq);
try {
zk.setData().forPath(keyPath, s.getBytes());
} catch (Exception e) {
throw new TokenStoreException("Error setting data in " + keyPath, e);
}
}
代码示例来源:origin: com.facebook.presto.hive/hive-apache
@Override
public void updateMasterKey(int keySeq, String s) {
CuratorFramework zk = getSession();
String keyPath = rootNode + NODE_KEYS + "/" + String.format(ZK_SEQ_FORMAT, keySeq);
try {
zk.setData().forPath(keyPath, s.getBytes());
} catch (Exception e) {
throw new TokenStoreException("Error setting data in " + keyPath, e);
}
}
代码示例来源:origin: com.facebook.presto.hive/hive-apache
private void zkDelete(String path) {
CuratorFramework zk = getSession();
try {
zk.delete().forPath(path);
} catch (KeeperException.NoNodeException ex) {
// already deleted
} catch (Exception e) {
throw new TokenStoreException("Error deleting " + path, e);
}
}
代码示例来源:origin: org.apache.hive.shims/hive-shims-common-secure
private void zkDelete(String path) {
CuratorFramework zk = getSession();
try {
zk.delete().forPath(path);
} catch (KeeperException.NoNodeException ex) {
// already deleted
} catch (Exception e) {
throw new TokenStoreException("Error deleting " + path, e);
}
}
代码示例来源:origin: com.github.hyukjinkwon.shims/hive-shims-common
private void zkDelete(String path) {
CuratorFramework zk = getSession();
try {
zk.delete().forPath(path);
} catch (KeeperException.NoNodeException ex) {
// already deleted
} catch (Exception e) {
throw new TokenStoreException("Error deleting " + path, e);
}
}
代码示例来源:origin: org.spark-project.hive.shims/hive-shims-common-secure
@Override
public int addMasterKey(String s) {
try {
ZooKeeper zk = getSession();
String newNode = zk.create(rootNode + NODE_KEYS + "/", s.getBytes(), newNodeAcl,
CreateMode.PERSISTENT_SEQUENTIAL);
LOGGER.info("Added key {}", newNode);
return getSeq(newNode);
} catch (KeeperException ex) {
throw new TokenStoreException(ex);
} catch (InterruptedException ex) {
throw new TokenStoreException(ex);
}
}
代码示例来源:origin: org.spark-project.hive.shims/hive-shims-common-secure
@Override
public void updateMasterKey(int keySeq, String s) {
try {
ZooKeeper zk = getSession();
zk.setData(rootNode + NODE_KEYS + "/" + String.format(ZK_SEQ_FORMAT, keySeq), s.getBytes(),
-1);
} catch (KeeperException ex) {
throw new TokenStoreException(ex);
} catch (InterruptedException ex) {
throw new TokenStoreException(ex);
}
}
代码示例来源:origin: org.spark-project.hive.shims/hive-shims-common-secure
@Override
public boolean removeMasterKey(int keySeq) {
try {
ZooKeeper zk = getSession();
zk.delete(rootNode + NODE_KEYS + "/" + String.format(ZK_SEQ_FORMAT, keySeq), -1);
return true;
} catch (KeeperException.NoNodeException ex) {
return false;
} catch (KeeperException ex) {
throw new TokenStoreException(ex);
} catch (InterruptedException ex) {
throw new TokenStoreException(ex);
}
}
代码示例来源:origin: org.apache.hive.shims/hive-shims-common-secure
@Override
public int addMasterKey(String s) {
String keysPath = rootNode + NODE_KEYS + "/";
CuratorFramework zk = getSession();
String newNode;
try {
newNode = zk.create().withMode(CreateMode.PERSISTENT_SEQUENTIAL).withACL(newNodeAcl)
.forPath(keysPath, s.getBytes());
} catch (Exception e) {
throw new TokenStoreException("Error creating new node with path " + keysPath, e);
}
LOGGER.info("Added key {}", newNode);
return getSeq(newNode);
}
代码示例来源:origin: com.github.hyukjinkwon.shims/hive-shims-common
@Override
public int addMasterKey(String s) {
String keysPath = rootNode + NODE_KEYS + "/";
CuratorFramework zk = getSession();
String newNode;
try {
newNode = zk.create().withMode(CreateMode.PERSISTENT_SEQUENTIAL).withACL(newNodeAcl)
.forPath(keysPath, s.getBytes());
} catch (Exception e) {
throw new TokenStoreException("Error creating new node with path " + keysPath, e);
}
LOGGER.info("Added key {}", newNode);
return getSeq(newNode);
}
代码示例来源:origin: com.facebook.presto.hive/hive-apache
@Override
public int addMasterKey(String s) {
String keysPath = rootNode + NODE_KEYS + "/";
CuratorFramework zk = getSession();
String newNode;
try {
newNode = zk.create().withMode(CreateMode.PERSISTENT_SEQUENTIAL).withACL(newNodeAcl)
.forPath(keysPath, s.getBytes());
} catch (Exception e) {
throw new TokenStoreException("Error creating new node with path " + keysPath, e);
}
LOGGER.info("Added key {}", newNode);
return getSeq(newNode);
}
代码示例来源:origin: org.spark-project.hive.shims/hive-shims-common-secure
@Override
public boolean removeToken(DelegationTokenIdentifier tokenIdentifier) {
try {
ZooKeeper zk = getSession();
zk.delete(getTokenPath(tokenIdentifier), -1);
return true;
} catch (KeeperException.NoNodeException ex) {
return false;
} catch (KeeperException ex) {
throw new TokenStoreException(ex);
} catch (InterruptedException ex) {
throw new TokenStoreException(ex);
}
}
有什么区别 request.getSession() 和 getThreadLocalRequest().getSession() 我正在维护的应用程序似乎将第一个用于直接 Servlet,将第二个用
我了解 request.getSession(true) 和 request.getSession(false) 之间的区别。但是 request.getSession() 和 request.get
就 session 而言,这些调用实际上意味着什么? System.out.println("print1: "+request.getSession().getId()); System.out.p
在过滤器中,我使用request.getSession(false)来获取 session ,这没关系。但是当我对其进行单元测试时,request.getSession(false)将返回null o
我们通过实现 Filter 在我们的应用程序中拥有 SecurityFilter 类,我们的 doFilter 方法如下所示。 public void doFilter(ServletRequest
我有一个 servlet LogMeOut.java,我在其中编写以下代码: HttpSession session = request.getSession(false); if (session
非常简单的问题,request.getSession(true) 返回 null,就好像拒绝创建 session 一样。我已经重新启动了我的机器并为 Tomcat 和 IntelliJ 添加了内存。任
我创建了一个登录 servlet: @WebServlet( name = "SignInServlet", description = "check email & pass",
在某些设备上我遇到以下崩溃: //崩溃信息 SIGABRT 00 pc 00041300 /system/lib/libc.so (tgkill+12) [armeabi-v7a::1b3176677
我理解如果我们使用下面的语句 HttpSession session = request.getSession(); 将创建唯一 session ID,创建 Cookie 并将 Cookie 与 se
是否可以找到Android OpenSSLSocketImpl 关闭Socket 的原因? (如何调试 Android 内部库?) 背景:可以找到我尝试创建 SSLContext 的来源 in TLS
本文整理了Java中org.directwebremoting.WebContext.getSession()方法的一些代码示例,展示了WebContext.getSession()的具体用法。这些代
sessionCreated()中的HttpSessionListener方法是否自动与request.getSession()调用同步?特别是,我想知道在sessionCreated()方法中设置
我试图在Grails 2.3.5的TagLib中使用以下代码。 class LoginTagLib { def loginControl = { if(request.getSession(
使用 Spring 的 SessionFactoryUtils for Hibernate,getSession() 和 getNewSession() 之间的实际区别是什么? 我一直在 DAO 方法
由于对 Spring 方法的理解不当,我遇到了一个问题 -> GetHibernateTemplate/GetSession。当我使用 native sql 查询 [getSession().crea
我编写了一个过滤器,它会使当前 session 无效并创建新 session 并将旧 session 的属性复制到新 session 中。这在 tomcat5 和 jdk 1,4 中工作正常但是当我将
我正在测试以下方法: public static String createSn(HttpServletRequest request, String usrnm) { HttpSession
我脑子里有以下代码 jQuery(document).ready(function() { var pic = 0; FB.init({appId: '135570939849404'
我有一个问题。在 glassfish 的 servlet 中,我调用方法 request.getSession(false)。它应该返回 null。但是总是返回一个 session。此外,如果我在调用
我是一名优秀的程序员,十分优秀!