You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2015/11/24 19:21:25 UTC
[5/6] camel git commit: [CAMEL-9206] full name of the field
userGroupInformation
[CAMEL-9206] full name of the field userGroupInformation
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f614eeba
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f614eeba
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f614eeba
Branch: refs/heads/master
Commit: f614eeba18005bdf60045b46e52213a682465059
Parents: 3c013e9
Author: woj-i <wo...@gmail.com>
Authored: Tue Nov 24 14:01:41 2015 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Tue Nov 24 19:07:56 2015 +0100
----------------------------------------------------------------------
.../org/apache/camel/component/hbase/HBaseEndpoint.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/f614eeba/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
index a8f94d0..8c20d3b 100644
--- a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
+++ b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
@@ -69,7 +69,7 @@ public class HBaseEndpoint extends DefaultEndpoint {
@UriParam(label = "consumer")
private int maxMessagesPerPoll;
@UriParam(description = "UserGroupInformation for HBase communication. If not specified, then Camel talks with HBase without Kerberos")
- private UserGroupInformation ugi;
+ private UserGroupInformation userGroupInformation;
/**
* in the purpose of performance optimization
@@ -232,10 +232,10 @@ public class HBaseEndpoint extends DefaultEndpoint {
/**
* Defines privileges to communicate with HBase table by {@link #getTable()}
- * @param ugi
+ * @param userGroupInformation
*/
- public void setUgi(UserGroupInformation ugi) {
- this.ugi = ugi;
+ public void setUserGroupInformation(UserGroupInformation userGroupInformation) {
+ this.userGroupInformation = userGroupInformation;
}
/**
@@ -244,8 +244,8 @@ public class HBaseEndpoint extends DefaultEndpoint {
* @return table, remember to close!
*/
public HTableInterface getTable() {
- if (ugi != null) {
- return ugi.doAs(new PrivilegedAction<HTableInterface>() {
+ if (userGroupInformation != null) {
+ return userGroupInformation.doAs(new PrivilegedAction<HTableInterface>() {
@Override
public HTableInterface run() {
return tablePool.getTable(tableNameBytes);