类 com.github.panhongan.util.conf.Config
的使用

使用Config的程序包

程序包	说明
com.github.panhongan.util.db
com.github.panhongan.util.hive
com.github.panhongan.util.kafka

com.github.panhongan.util.db中Config的使用

参数类型为Config的com.github.panhongan.util.db中的方法

限定符和类型	方法和说明
boolean	MysqlUtil.MysqlPool.create(Config conf)
static redis.clients.jedis.Jedis	JedisUtil.createJedis(Config conf)
static redis.clients.jedis.JedisCluster	JedisUtil.createJedisCluster(Config conf)
static redis.clients.util.Pool<redis.clients.jedis.Jedis>	JedisUtil.createJedisPool(Config conf)
static MysqlUtil.MysqlPool	MysqlUtil.createMysqlPool(Config conf)
static MysqlSession	MysqlUtil.createMysqlSession(Config conf)
static String	MysqlUtil.getJDBCUrl(Config jdbc_config)

com.github.panhongan.util.hive中Config的使用

参数类型为Config的com.github.panhongan.util.hive中的方法

限定符和类型	方法和说明
static HiveSession	HiveUtil.createHiveSession(Config jdbc_config, Config hive_conf, boolean is_new)
static HiveSession	HiveUtil.createHiveSession(String jdbc_conf_file, Config hive_conf, boolean is_new)
static String	HiveUtil.getJdbcUrl(Config jdbc_config, Config session_config, Config hive_conf, Config hive_var, boolean is_new)
static boolean	HiveUtil.validateHiveConfig(Config config)

com.github.panhongan.util.kafka中Config的使用

返回Config的com.github.panhongan.util.kafka中的方法

限定符和类型	方法和说明
Config	KafkaExporterConfig.getConfig()

参数类型为Config的com.github.panhongan.util.kafka中的方法

限定符和类型	方法和说明
static kafka.consumer.ConsumerConfig	KafkaUtil.createConsumerConfig(Config config)
static org.apache.kafka.clients.producer.Producer<String,String>	KafkaUtil.createProducer(Config producer_config)

参数类型为Config的com.github.panhongan.util.kafka中的构造器

构造器和说明
MessageKafkaWriter(Config producer_config, String send_failed_data_dir)
MessageKafkaWriter(Config producer_config, String dst_topic, String send_failed_data_dir)