开发环境：spark：2.2.0 工具：IDEA OS:Windows 数据文件： 本次所有示例的函数有： Start 注：在使用函数的时候最好要导入org.apache.spark.sql.functions._这个包 import ssc.implicits._（这个包在实际写sql的时候将其导 ...
分类：
数据库 时间：
2018-09-20 01:05:57
阅读次数：
903
Quartz是实现定时任务的利器，Quartz主要有四个组成部分，分别是： 1. Job(任务)：包含具体的任务逻辑； 2. JobDetail(任务详情）：是对Job的一种详情描述； 3. Trigger(触发器)：负责管理触发JobDetail的机制； 4. Scheduler(调度器)：负责J ...
分类：
编程语言 时间：
2018-09-17 17:47:59
阅读次数：
259
在 java.util.concurrent 包中的 ExecutorService 的实现就是壹個线程池的实现 任务的委托（Task Delegation） 壹旦线程把任务委托给 ExecutorService，该线程就会继续执行与运行任务无关的其它任务。 Executor框架的两级调度模型 在H ...
分类：
编程语言 时间：
2018-09-14 18:28:01
阅读次数：
166
HDFS是Hadoop大数据平台中的分布式文件系统，为上层应用或其他大数据组件提供数据存储，如Hive，Mapreduce，Spark，HBase等。
分类：
其他好文 时间：
2018-09-14 11:55:55
阅读次数：
201
1、相关类 Executors ExecutorService Callable ThreadPool Future 2、相关接口 Executor Executor接口的使用： ExecutorService接口的使用：（继承Executor接口） *submit方法（执行runnble、call ...
分类：
编程语言 时间：
2018-09-11 14:17:55
阅读次数：
264
/* * pending:初始化成功 * fulfilled:成功 * rejected：失败 * */ function Promise(executor) {// 执行器 this.status = 'pending'; this.value = undefined; this.reason =... ...
分类：
Web程序 时间：
2018-09-09 21:04:39
阅读次数：
176
例子1：延迟3秒后，只执行1次 运行结果： 调用的ThreadPoolExecutor： corePoolSize=5，maximumPoolSize=Integer.MAX_VALUE keepAliveTime=0纳秒 allowCoreThreadTimeout=false（默认） 采用延迟队 ...
分类：
编程语言 时间：
2018-09-07 19:14:55
阅读次数：
1708
? 问题发布 ? HTML/敏感词过滤 ? 多线程 ? 问题发布 1：增加提问； @RequestMapping(value = "/question/add", method = {RequestMethod.POST}) @ResponseBody public String addQuesti ...
分类：
编程语言 时间：
2018-09-06 02:41:11
阅读次数：
250
1. Future的应用场景 在并发编程中，我们经常用到非阻塞的模型，在之前的多线程的三种实现中，不管是继承thread类还是实现runnable接口，都无法保证获取到之前的执行结果。通过实现Callback接口，并用Future可以来接收多线程的执行结果。 Future表示一个可能还没有完成的异步 ...
分类：
编程语言 时间：
2018-09-05 17:48:49
阅读次数：
171
1.Plugin MyBatis 允许使用插件来拦截的方法调用包括： ? Executor (update, query, flushStatements, commit, rollback, getTransaction, close, isClosed) ? ParameterHandler ( ...
分类：
其他好文 时间：
2018-09-05 13:59:30
阅读次数：
237
