Apache Storm Component Guide
Also available as:

Configuring Storm-Hive for a Secure Cluster

The Storm-Hive connector accepts configuration settings as part of the HiveOptions class. For more information about the HiveBolt and HiveOptions classes, see the Apache Storm HiveOptions and HiveBolt API documentation.

There are two required settings for accessing secure Hive:

  • withKerberosPrincipal, the Kerberos principal for accessing Hive:

    public HiveOptions withKerberosPrincipal(String kerberosPrincipal)
  • withKerberosKeytab, the Kerberos keytab for accessing Hive:

    public HiveOptions withKerberosKeytab(String kerberosKeytab)
{"cc_re__cc_re__cc_by_sa_4_0_le": ["ting\">public HiveOptions withKerberosPrincipal(String kerberosPrincipal)</pre></li><li class=\"listitem\"><p><code class=\"code\">withKerberosKeytab</code>, the Kerberos keytab for accessing Hive:</p><pre class=\"programlisting\">public HiveOptions withKerberosKeytab(String kerberosKeytab)</pre></li></ul></div></div></div></div></section></div></div></div><section class=\"ps footer\"><div><div class=\"copyright\">\u00a9 2012\u20132021 by Cloudera, Inc.</div><div class=\"license\">Document licensed under the\n      <a href=\"https://creativecommons.org/licenses/by-sa/4.0/legalcode\">Creative\n      Commons Attribution ShareAlike 4.0 License</a>.</div><div class=\"menulinks\"><a href=\"https://cloudera.com/\">Cloudera.com</a> |\n                  <a href=\"/\">Documentation</a> |\n                  <a href=\"https://my.cloudera.com/support.html\">Support</a> |\n                  <a href=\"https://community.cloudera.com/\">Community</a></div></div></section><script type=\"application/javascript\" src=\"../common/js/plugins.js\"><!-- --></script><script type=\"application/javascript\" src=\"../com"], "copyright__copyright__copyright": ["ngs as part of the HiveOptions class. For more information about the HiveBolt and HiveOptions classes, see the Apache Storm HiveOptions and HiveBolt API documentation.\n\nThere are two required settings for accessing secure Hive:\n\n  \u2022 withKerberosPrincipal, the Kerberos principal for accessing Hive:\n\n    public HiveOptions withKerberosPrincipal(String kerberosPrincipal)\n  \u2022 withKerberosKeytab, the Kerberos keytab for accessing Hive:\n\n    public HiveOptions withKerberosKeytab(String kerberosKeytab)", "ngs as part of the HiveOptions class. For more information about the HiveBolt and HiveOptions classes, see the Apache Storm HiveOptions and HiveBolt API documentation.\n\nThere are two required settings for accessing secure Hive:\n\n  \u2022 withKerberosPrincipal, the Kerberos principal for accessing Hive:\n\n    public HiveOptions withKerberosPrincipal(String kerberosPrincipal)\n  \u2022 withKerberosKeytab, the Kerberos keytab for accessing Hive:\n\n    public HiveOptions withKerberosKeytab(String kerberosKeytab)", "ngs as part of the HiveOptions class. For more information about the HiveBolt and HiveOptions classes, see the Apache Storm HiveOptions and HiveBolt API documentation.\n\nThere are two required settings for accessing secure Hive:\n\n  \u2022 withKerberosPrincipal, the Kerberos principal for accessing Hive:\n\n    public HiveOptions withKerberosPrincipal(String kerberosPrincipal)\n  \u2022 withKerberosKeytab, the Kerberos keytab for accessing Hive:\n\n    public HiveOptions withKerberosKeytab(String kerberosKeytab)"]}