importjava.io.BufferedReader;importjava.io.FileInputStream;importjava.io.InputStreamReader;publicclassT{publicstaticvoidmain(Stringargs

packagecom.hans.controller;importjava.io.File;importjava.io.FileInputStream;importjava.io.IOException;importjava.io.InputStream;importjava.text.DecimalFormat;

BIO:同步阻塞IONIO:同步非阻塞IOAIO:异步非阻塞IO先弄清楚同步、异步，阻塞、非阻塞概念。io操作分为两部分，发起io请求，和io数据读写。阻塞、非阻塞主要是针对线程发起io请求后，是否立即返回来定义的，立即返回称为非阻塞io，否则称为阻塞io。同步、异步主要针对io数据读写来定义的，读写数据过程中不阻塞线程称为异步io

java调用bat、shell脚本通用类，工作记录。packagetest;importjava.io.BufferedReader;importjava.io.BufferedWriter;importjava.io.IOException;importjava.io.InputStr

JavaNIO之Buffer　　Java传统的I/O模型是面向单个字节的，它将输入输出抽象为字节流或字符流。这种单个字节的读取或写入模型的效率比较低，而且不符合操作系统的I/O特点。操作系统的IO是面向字节块的，通常是直接从磁盘中读取一块数据到内存或写入一块数据到磁盘。JavaNIO提供了缓冲区来实现字节块的读写。

package com.locator.encryption;import java.io.ByteArrayInputStream;import java.io.ByteArrayOutputStream;import java.io.File;import java.io.FileInputStr

TridentAPIOverviewTrident的核心数据模型是“流”（Stream），进行数据处理的时候，将数据作为一系列的batch(批)来进行。流被分割成多个partition分布在集群中的不同节点上来运行，而且对流的操作也是在流的各个partition上并行运行的。Trident中有五类操作

packageapi;importjava.io.BufferedReader;importjava.io.InputStreamReader;importjava.io.IOException;importjava.io.InputStream;importorg.apache.log4j.\;import

1importjava.io.IOException;2importjava.io.InputStream;3importjava.io.OutputStream;4importjava.io.PrintWriter;5importjava.net.ServerSo

_摘要：_ 实际问题我们知道在流计算场景中，数据是源源不断的流入的，数据流永远不会结束，那么计算就永远不会结束，如果计算永远不会结束的话，那么计算结果何时输出呢？本篇将介绍ApacheFlink利用持续查询来对流计算结果进行持续输出的实现原理。实际问题我们知道在流计算场景中，数据是源源不断的流入的，数据流永远不会结束，那么计算就永远不会