在现实中我们会经常遇到这样的场景：有一个固定的数据源Source，我们希望按照程序运行状态来接驳任意数量的下游接收方subscriber、又或者我需要在程序运行时（runtime）把多个数据流向某个固定的数据流终端Sink推送。这就涉及到动态连接合并型Merge或扩散型Broadcast的数据流
从总体上看：akka-stream是由数据源头Source，流通节点Flow和数据流终点Sink三个框架性的流构件（stream components）组成的。这其中：Source和Sink是stream的两个独立端点，而Flow处于stream Source和Sink中间可能由多个通道式的
在数据流应用的现实场景中常常会遇到与外界系统对接的需求。这些外部系统可能是Actor系统又或者是一些其它类型的系统。与这些外界系统对接的意思是在另一个线程中运行的数据流可以接收外部系统推送的事件及做出行为改变的响应。
如果一个外界系统需要控制一个运行中数据流的功能环节GraphStage，首先
1.两独样本参数的非参数检验
1.1.Welcoxon秩和检验
先将两样本看成是单一样本（混合样本）然后由小到大排列观察值统一编秩。如果原假设两个独立样本来自相同的总体为真，那么秩将大约均匀分布在两个样本中，即小的、中等的、大的秩值应该大约被均匀分在两个样本中。如果备选假设两个独立样本来自不相同的总
scala 基本语法
1.声明变量
(1)val i = 1 使用val声明的变量值是不可变的，相当于java里final修饰的变量，推荐使用。
(2)var i = "hello" 使用var声明的变量值是可变的
(3)val s = "hi" scala编译器会自动推断变量的类型，必要的时候可以
在现实应用中akka-stream往往需要集成其它的外部系统形成完整的应用。这些外部系统可能是akka系列系统或者其它类型的系统。所以，akka-stream必须提供一些函数和方法来实现与各种不同类型系统的信息交换。在这篇讨论里我们就介绍几种通用的信息交换方法和函数。
akka-stre
scala在linux安装很简单，就是下载，解压，配置环境变量，source一下成功。
提君博客原创
>>提君博客原创 http://www.cnblogs.com/tijun/ <<
下面列举一下详细步骤和指令
第一步。下载
>>提君博客原创 http://www.cnblogs.com/tijun/ <<
提君博客原创
1.进入命令窗口
./bin/spark-shell
附上帮助指令，查看一些帮助信息
s
1.定义一个类
class Person{
//用val修饰的变量是只读属性，有getter但是没有setter
val id ="111"
//用var修饰的变量既有getter又有setter
var age:Int =18
//类私有字段，只能在类的内部使用，只有伴生对象内可以使用
priv
akka-stream是基于Actor模式的，所以也继承了Actor模式的“坚韧性（resilient）”特点，在任何异常情况下都有某种整体统一的异常处理策略和具体实施方式。在akka-stream的官方文件中都有详细的说明和示范例子。我们在这篇讨论里也没有什么更好的想法和范例，也只能略做一些
在以前的博文中我们介绍了Slick，它是一种FRM（Functional Relation Mapper）。有别于ORM，FRM的特点是函数式的语法可以支持灵活的对象组合（Query Composition）实现大规模的代码重复利用，但同时这些特点又影响了编程人员群体对FRM的接受程度，阻碍了
http://docs.scala-lang.org/tour/lower-type-bounds.html中有一段代码
trait Node[+B] {
def prepend(elem: B): Unit
}
case class ListNode[+B](h: B, t: Node
众所周知，Akka系统是基于Actor模式的分布式运算系统，非常适合构建大数据平台。所以，无可避免地会出现独立系统之间、与异类系统、与移动系统集成的需求。由于涉及到异类和移动系统，系统对接的方式必须在一套公开的标准之上进行，包括数据格式及数据传输标准。实际上针对标准的传输连接及标准数据编码、传输
Akka-http针对Connection的两头都提供了方便编程的Api，分别是Server-Side-Api和Client-Side-Api。通过这两个Api可以大大提高编程效率。当然，上期我们提到过，Http-Server是Akka-http的核心部分，所有系统集成功能都是在Server-Si
在上篇我们介绍了Akka-http Low-Level-Api。实际上这个Api提供了Server对进来的Http-requests进行处理及反应的自定义Flow或者转换函数的接入界面。我们看看下面官方文档给出的例子：
import akka.actor.ActorSystem
import
Route 是Akka-http routing DSL的核心部分，使用户能比较方便的从http-server的角度筛选http-request、进行server运算、构建回复的http-response。所谓筛选http-request主要目的是容许request进入下一内层Route，或者
一入大数据深似海，脑袋不够用了，先留下只言片语。
kafka api中给出2类直接获取流的接口：createStream和createDirectStream。
createStream比较简单，只需topic、groupid、zookeeper就可以直接获取流，brokers和offset都是黑盒
Akka-http routing DSL在Route运算中抛出的异常是由内向外浮出的：当内层Route未能捕获异常时，外一层Route会接着尝试捕捉，依次向外扩展。Akka-http提供了ExceptionHandler类来处理Route运算产生的异常：
trait ExceptionHan
在个人学习scala的过程中，产生了写一系列随笔的想法，这些随笔包括：翻译自官网、其他英文网站的文章以及自己的心得体会，本文章作为这个系列中的第一个。
由于本人能力所限，以及对scala还处于初级阶段，有任何错误或者问题，欢迎大家指正，多谢。
原文链接：http://docs.scala
Akka-http是一项系统集成工具。这主要依赖系统之间的数据交换功能。因为程序内数据表达形式与网上传输的数据格式是不相同的，所以需要对程序高级结构化的数据进行转换（marshalling or serializing）成为可在网上传输的数据格式。由于可能涉及到异类系统集成，网上传输数据格式是一
客服
