[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 <wojciechin...@gmail.com> Authored: Tue Nov 24 14:01:41 2015 +0100 Committer: Claus Ibsen <davscl...@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);
