<?xml version="1.0" encoding="UTF-8"?> <settings xmlns="http://maven.apache.org/SETTINGS/1.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" ...
分类:
其他好文 时间:
2020-06-27 09:19:58
阅读次数:
1531
一、简介 Apache Flume 是一个分布式,高可用的数据收集系统,可以从不同的数据源收集数据,经过聚合后发送到分布式计算框架或者存储系统中。Spark Straming 提供了以下两种方式用于 Flume 的整合。 二、推送式方法 在推送式方法 (Flume-style Push-based ...
分类:
Web程序 时间:
2020-06-27 00:19:37
阅读次数:
77
一、案例引入 这里先引入一个基本的案例来演示流的创建:获取指定端口上的数据并进行词频统计。项目依赖和代码实现如下: <dependency> <groupId>org.apache.spark</groupId> <artifactId>spark-streaming_2.12</artifactI ...
分类:
其他好文 时间:
2020-06-27 00:14:44
阅读次数:
62
Jmeter安装后初次启动报错Invalid maximum heap size: -Xmx4096m 解决办法: 找到jmeter包的目录文件,如: E:\ST_test\jmeter\apache-jmeter-3.1\bin,编辑jmeter.bat文件,找到设置堆内存大小地方: set HE ...
分类:
其他好文 时间:
2020-06-26 23:53:02
阅读次数:
136
名词: commitLog : 消息存储的地方,持久化到磁盘中,保存着生产者发送的完整消息。 consumerqueue: 逻辑消费队列,每一个队列中维护着commitLog 文件中的消息偏移量进行消费。 index: 索引文件。 初始化: 在Broker 启动的时候,org.apache.rock ...
分类:
其他好文 时间:
2020-06-26 21:48:18
阅读次数:
63
高并发模拟测试工具 postman apache bench(AB) JMeter (1) 使用postman创建并发模拟测试 据说这种方式的并发测试看看就行了, 没用, 使用的是串行不是并发 填入并发和延迟, 基本完成了 (2) apache bench(ab) 需要安装apache 通过上面的方 ...
分类:
其他好文 时间:
2020-06-26 18:16:23
阅读次数:
71
一、简单聚合 1.1 数据准备 // 需要导入 spark sql 内置的函数包 import org.apache.spark.sql.functions._ val spark = SparkSession.builder().appName("aggregations").master("lo ...
分类:
数据库 时间:
2020-06-26 18:03:35
阅读次数:
58
一、工程目录 二、SqlMapConfig.xml <?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.o ...
分类:
其他好文 时间:
2020-06-26 16:17:27
阅读次数:
41
1: 相关图片 2:项目配置 1: pom.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/ ...
分类:
编程语言 时间:
2020-06-26 14:47:23
阅读次数:
74
Docker 是一个开源项目,诞生于 2013 年初,初是 dotCloud 公司内部的一个业余项目。它基于 Google 公司推 出的 Go 语言实现。 项目后来加入了 Linux 基金会,遵从了 Apache 2.0 协议,项目代码在 GitHub 上进行维护。 Docker 自开源后受到广泛的 ...
分类:
其他好文 时间:
2020-06-26 14:17:45
阅读次数:
93