ElasticSearch Head下载和安装(三)

(1). 下载head插件

ElasticSearch IK中文分词结合案例(十四)

(1). 添加索引(指定IK分词器)PUT /hobby{ "settings": { "index":{ "number_of_shards":"1", "number_of_replicas":"0" } ...

ElasticSearch Document Bulk API(八)

(1). Bulk产生原因 由于ES是通过http来提供请求的,而http连接的创建和销毁都是损耗性能的,所以,ES Bulk API支持批处理.

ElasticSearch Document API(八)

(1). 文档的CRUD

ElasticSearch 集群搭建(十九)

(1). 集群机器

ElasticSearch 集群相关API(七)

(1). 查看集群状态```查看集群状态GET _cluster/health

ElasticSearch Cerebro下载和安装(三)

(1). 下载Cerebro插件

ElasticSearch Analyzer进行分词(九)

(1). Analyzer 把全文本转换成一系列单词(term/token)的过程,就叫分词. 注意:数据在写入时转换成词条,所使用的分析器.在Query时,也要使用相同的分析器对查询语句进行分析.

ElasticSearch 安装IK(九)

(1). 下载IK与ES对应的版本 https://github.com/medcl/elasticsearch-analysis-ik https://github.com/medcl/elasticsearch-analysis-ik/re...

JoptSimple Hello World

(1). pom.xml``` 4.0.0

Spring Boot LogBack配置

(1). logback-spring.xml配置```<?xml version=”1.0” encoding=”UTF-8”?>

Spring Boot启用AccessLog

(1). Spring Boot启用AccessLog# 配置日志目录server.tomcat.basedir=.# 启用accesslogserver.tomcat.accesslog.enabled=true# 日志输出目录:basedir...

Flume 架构及概述

(1). Flume架构图

Flume Tomcat AccessLog

(1). 监控Tomcat AccessLog 监控Tomcat AccessLog 输出到另一个日志文件中

Flume TailDir

(1). 监控多个目录或文件,并能实现断点续传功能 监控多个目录 断点续传(exec不支持)

Flume SpoolDir

(1). 监控某个目录,并输出结果到文件中 监控目录 输出到某个文件中

Flume 自定义Source

(1). 需求

Flume Sink Load Balancing

(1). 需求 Flume1接受数据,同步给Flum2和Flume3.同步时,如果出现错误,需要进行失败转移或负载均衡.

Flume 自定义Sink

(1). 需求

Flume Replicating Channel Selector

(1). 业务需求 Flum1 收集数据 传输给 Flum2 和 Flum3,要求:Flum2和Flum3的数据一模一样.

Flume NetCat

(1). 使用Flume监听一个端口,收集端口数据,并打印到控制台(2). 创建配置文件目录

Flume 自定义Interceptor

(1). 需求

Flume安装

(1). 下载Flume 省略,自行去官网下载(http://archive.apache.org/dist/flume)

Flink StateBackend

(1). StateBackend 在默认情况下,State会保存在TaskManager的内存中,Checkpoint会存储在JobManager的内存中,State和Checkpoint的存储位置取决于StateBackend的配置,Fli...

Flink CheckPoint

(1). Checkpoint开启和时间间隔指定 开启检查点,并且指定检查点时间间隔为1000ms. env.enableCheckpointing(1000); (2). exactly-ance和at-least-once语义选择

Flink WordCount

(1).JDK版本lixin-macbook:~ lixin$ java -versionjava version "1.8.0_251"Java(TM) SE Runtime Environment (build 1.8.0_251-b08)J...

Flink学习 从Kafka读取数据

(1).pom.xml配置```<?xml version=”1.0” encoding=”UTF-8”?> 4.0.0 help.lixin.wc flink-wordcount 1.0-SNAPSHOT

Flink学习 Java WrodCount

(1).pom.xml配置```<?xml version=”1.0” encoding=”UTF-8”?> 4.0.0 help.lixin.flink.example flink-java-example ...

MySQL主从同步(Docker)

(1).Docker创建容器 基于mysql:5.7.9镜像,创建master容器

MySQL主从同步验证,并剖析Binlog内容(一)

(1).需求 一定要打开这个参数(log_slave_updates=true),否则salve,看不到binlog信息. Slave向Master发起dump请求. Master返回binlong给Slave. Sl...