org.apache.spark.kafka010

Class KafkaTokenUtil

Object

org.apache.spark.kafka010.KafkaTokenUtil

public class KafkaTokenUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaTokenUtil()

Method Summary

Modifier and Type	Method and Description
static scala.Option<org.apache.spark.kafka010.KafkaTokenClusterConf>	findMatchingTokenClusterConfig(SparkConf sparkConf, String bootStrapServers)
static String	getKeytabJaasParams(String keyTab, String principal, String kerberosServiceName)
static String	getTokenJaasParams(org.apache.spark.kafka010.KafkaTokenClusterConf clusterConf)
static boolean	isGlobalJaasConfigurationProvided()
static boolean	needTokenUpdate(java.util.Map<String,Object> params, scala.Option<org.apache.spark.kafka010.KafkaTokenClusterConf> clusterConfig)
static void	org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
static org.slf4j.Logger	org$apache$spark$internal$Logging$$log_()
static org.apache.hadoop.io.Text	TOKEN_KIND()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaTokenUtil

public KafkaTokenUtil()

Method Detail

TOKEN_KIND

public static org.apache.hadoop.io.Text TOKEN_KIND()

isGlobalJaasConfigurationProvided

public static boolean isGlobalJaasConfigurationProvided()

getKeytabJaasParams

public static String getKeytabJaasParams(String keyTab,
                                         String principal,
                                         String kerberosServiceName)

findMatchingTokenClusterConfig

public static scala.Option<org.apache.spark.kafka010.KafkaTokenClusterConf> findMatchingTokenClusterConfig(SparkConf sparkConf,
                                                                                                           String bootStrapServers)

getTokenJaasParams

public static String getTokenJaasParams(org.apache.spark.kafka010.KafkaTokenClusterConf clusterConf)

needTokenUpdate

public static boolean needTokenUpdate(java.util.Map<String,Object> params,
                                      scala.Option<org.apache.spark.kafka010.KafkaTokenClusterConf> clusterConfig)

org$apache$spark$internal$Logging$$log_

public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()

org$apache$spark$internal$Logging$$log__$eq

public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)