最近一直在研究presto接口hive和mysql的一些使用和功能，因此，我在想是否能将数据实时的写入到hive呢，刚好公司项目有需求数据实时写入到hive中，对此，我特定实...
IP属地：北京
-
sparkstreaming实时写入hive
-
Spark-Streaming KafkaClient 异常解决
在使用Spark-Streaming消费Kafka数据的时候，使用如下命令提交到yarn 如出现如上异常配置代码如下 /tmp/kafka_jaas.conf 提交命令 问题...
-
Spark优雅的操作RedisSpark的优势在于内存计算，然而在计算中难免会用到一些元数据或中间数据，有的存在关系型数据库中，有的存在HDFS上，有的存在HBase中，但其读写速度都和Spark计算的速...
-
Flink - CEP分析攻击行为在这样一种场景，用户的登录行为数据都会以LoginEvent的行式记录下来，每次失败或者成功以及错误都会记录下来，一般客户端都会进行检验，正常的用户不可能在一秒钟之内登录错误...
-
Flink - 1.8 最新版本使用Flink 1.8 的快照版本已经发布，我们可以来使用一下，当然了，过程肯定还是有一些曲折的，这里已经帮大家给记录下来了，顺便给大家踩坑 使用过程 下载 编译（大概有20分钟...
-
Kafka 新版消费者 API（三）：以时间戳查询消息和消费速度控制
1. 以时间戳查询消息 (1) Kafka 新版消费者基于时间戳索引消费消息 kafka 在 0.10.1.1 版本增加了时间索引文件，因此我们可以根据时间戳来访问消息。如以...
