一·使用File类操作文件。 其主要操作操作包括文件的创建，文件的删除，对文件的修改（主要体现在对文件代码的修改） 实现字节流，字符流在Java.IO的具体操作 No.1通过File类创建一个文件 。 No.2通过字节流，字符流的子类指定到所需位置。 No.3对文本文档进行读写操作。 No.4关闭输 ...
分类：
其他好文 时间：
2019-11-02 20:16:14
阅读次数：
98
设置一个开关为分页节流做处理（不节流回一次加载多个page次数） 在methods中做分页处理： 分页的节流：设置一个开关，如果为false时进入触发page++，执行List（），并且触发前设置开关为true，并且在List（）函数里设置开关为false，（开关为true不能执行分页，为false ...
分类：
其他好文 时间：
2019-11-01 12:34:34
阅读次数：
123
通过前面几篇文章，我们可以从整体上看到zk是如何处理网络数据的宏观架构。 本文我们从细节着手，看一下一个tcp的包是如何转换到内部的数据流处理的。 一、监听用户请求socket 基于NIO的端口监听，获取tcp数据流。 二、从连接中解析数据 接上一个nio提交过来的连接后，由 SelectorThr ...
分类：
其他好文 时间：
2019-10-29 13:57:20
阅读次数：
72
实时流处理系统反压机制（BackPressure）综述 https://blog.csdn.net/qq_21125183/article/details/80708142 2018-06-15 19:05:37 MasterT-J 阅读数 4808更多 分类专栏： 实时流处理 实时流处理系统反压机 ...
分类：
其他好文 时间：
2019-10-24 09:26:40
阅读次数：
97
Fink Flink主页在其顶部展示了该项目的理念：“Apache Flink是为分布式、高性能、随时可用以及准确的流处理应用程序打造的开源流处理框架”。 Apache Flink是一个框架和分布式处理引擎，用于对无界和有界数据流进行有状态计算。Flink被设计在所有常见的集群环境中运行，以内存执行 ...
分类：
其他好文 时间：
2019-10-21 16:07:31
阅读次数：
106
1、Apache Flink 是一个面向分布式数据流处理和批量数据处理的开源计算平台，它能够基于同一个Flink运行时，提供支持流处理和批处理两种类型应用的功能。 现有的开源计算方案，会把流处理和批处理作为两种不同的应用类型，因为他们所提供的SLA(Service-Level-Aggreement， ...
分类：
其他好文 时间：
2019-10-20 21:36:40
阅读次数：
152
Flink 的 API 大体上可以划分为三个层次：处于最底层的 ProcessFunction、中间一层的 DataStream API 和最上层的 SQL/Table API，这三层中的每一层都非常依赖于时间属性。时间属性是流处理中最重要的一个方面，是流处理系统的基石之一，贯穿这三层 API。在 ...
分类：
其他好文 时间：
2019-10-16 13:13:50
阅读次数：
95
一、概念 1、什么是kafka Kafka是由Apache软件基金会开发的一个开源的分布式流处理平台，由Scala和Java编写。Kafka是一个分布式、分区的、多副本的、多订阅者，基于zookeeper协调的分布式日志系统（也可以当做MQ系统），它可以处理消费者在网站中的所有动作流数据。 Kafk ...
分类：
其他好文 时间：
2019-10-15 09:57:16
阅读次数：
70
1、界面 status: 可以看见apache druid的版本号，现在是0.16.0，里面有9个扩展项 datasource: 监控数据源：我提交了两次索引服务，所以现在有两个2个DataSource segment： 监控segment：里面有9个Segment，每个Datasource由多个s ...
分类：
Web程序 时间：
2019-10-12 11:05:07
阅读次数：
1054
1、前言 从druid的0.11版本开始，我就开始关注它，每一次的版本的更新，druid都会使用户体验、性能更好，从以前手写配置文件到可视化的界面操作，从实时节点进行任务提交到现在的索引服务等 流处理： 日志监控（Flume/Airflow） > 消息中间件（kafka、MQ） > 流处理（spar ...
分类：
Web程序 时间：
2019-10-11 18:03:32
阅读次数：
122
