李小李可不能落后呀
IP属地：四川
-
十七.Hadoop部分问题思考
1.关于切片的时候保证数据完整性的问题 MapReduce在进行切片的时候有几个参数，一个是最小切片大小(mapred.min.split.size)，一个是最大切片大小(m...
-
关于IDEA配置文件和代码的路径Sources Root：告诉idea这个文件夹及其子文件夹中包含源代码，是需要编译构建的一部分 Test Sources Root：测试源文件夹允许您将与测试相关的代码与生...
-
-
三.Flink集群搭建Flink可以选择的部署方式有： Local、Standalone（资源利用率低）、Yarn、Mesos、Docker、Kubernetes、AWS。 我们主要对Standa...
-
二.Flink基本架构
2.0 JobManager与TaskManager Flink运行时包含了两种类型的处理器： JobManager处理器：也称之为Master，用于协调分布式执行，它们用来...
-
-
五.Logstash5.1 Logstash简介 Logstash is a tool for managing events and logs. You can use it to colle...
-
三.Java API操作
Elasticsearch的Java客户端非常强大；它可以建立一个嵌入式实例并在必要时运行管理任务。 运行一个Java应用程序和Elasticsearch时，有两种操作模式可...
-
-
一.Elasticsearch概述1.1 什么是搜索 百度：我们比如说想找寻任何的信息的时候，就会上百度去搜索一下，比如说找一部自己喜欢的电影，或者说找一本喜欢的书，或者找一条感兴趣的新闻（提到搜索的第一印象...
-
六.kafka Streams6.1 概述 6.1.1 Kafka Streams Kafka Streams。Apache Kafka开源项目的一个组成部分。是一个功能强大，易于使用的库。用于在Kafk...
-
五.Kafka producer拦截器(interceptor)
5.1 拦截器原理 Producer拦截器(interceptor)是在Kafka 0.10版本被引入的，主要用于实现clients端的定制化控制逻辑。 对于producer...
-
四.KafkaAPI实战
4.1 环境准备 1）在eclipse中创建一个java工程 2）在工程的根目录创建一个lib文件夹 3）解压kafka安装包，将安装包libs目录下的jar包拷贝到工程的l...
-
三.Kafka工作流程分析3.1 Kafka生产过程分析 3.1.1 写入方式 producer采用推（push）模式将消息发布到broker，每条消息都被追加（append）到分区（patition...
-
-
