java8 Streams可以反向遍历集合吗

rivers；streams；current；water flow

完整的LINQ分以下几部分，缺一不可：Lambda ExpressionQuery ExpressionExtension MethodsExpression TreeAnonymous TypesJava除了第一个后面都没有。你可以认为Java的Streams API是一个：无法用Monad形式（没有Query Expression）难以扩展的（没有Extension Methods）无法表达语句结构及动态编译函数（没有Expression Tree）无法借助临时结构减少计算或增强表达能力（没有Anonymous Types）的LINQ。此外，这套API不是加在标准的Iterator和Iterable模型上的（在C#叫IEnumerator和IEnumerable），导致又多了一套Streams模型出来，而又和IO的Stream容易产生混淆，真不知道设计者是怎么想的，搞个Extension Methods出来多好，不光对LINQ有用，简直方便之至。总而言之，Java 8这套给我的感觉就是因为不愿意搞出和C#一样的设计而引入的半吊子东西。当年Lambda表达式的草案是和C#以及Scala一样使用“=>”符号的，结果最后硬要改为“->”真是生怕别人不知道要故意跟C#不同。

Data guard ==> 全库的复制 灾备 、 高可用、 读写分离， 除了Active Data Guard外 都是免费的，性能好，对网络的要求高Streams==》　支持单向或双向的流复制，多种粒度:表 Schema DB ， 免费 ， Bug较多 管理难度较大，性能较差，对网络的要求较高Goldengate ==> 支持单向或双向的同步复制， 多种粒度， 收费昂贵，管理难度一般，性能较好，对网络的要求较低。

inastream、instreams都可使用，这要视乎不同句子的情况。inastream在某一条河流中instreams在河流中（泛指所有河流）但inastreams应是错误的，因为a/an与复数词不可并列使用。

stream.h吧，你可以下载一个，然后放了安装文件的一个文件夹里

本文由郭历成[博客]翻译自nshipster中的Multipeer Connectivity一节。 Multipeer connectivity是一个使附近设备通过Wi-Fi网络、P2P Wi-Fi以及蓝牙个人局域网进行通信的框架。互相链接的节点可以安全地传递信息、流或是其他文件资源，而不用通过网络服务。Advertising & Discovering通信的第一步是让大家互相知道彼此，我们通过广播(Advertising)和发现(discovering)服务来实现。广播作为服务器搜索附近的节点，而节点同时也去搜索附近的广播。在许多情况下，客户端同时广播并发现同一个服务，这将导致一些混乱，尤其是在client-server模式中。所以，每一个服务都应有一个类型（标示符），它是由ASCII字母、数字和“-”组成的短文本串，最多15个字符。通常，一个服务的名字应该由应用程序的名字开始，后边跟“-”和一个独特的描述符号。(作者认为这和 com.apple.*标示符很像)，就像下边：static NSString * const XXServiceType = @"xx-service"; 一个节点有一个唯一标示MCPeerID对象，使用展示名称进行初始化，它可能是用户指定的昵称，或是单纯的设备名称。MCPeerID *localPeerID = [[MCPeerID alloc] initWithDisplayName:[[UIDevice currentDevice] name]]; 节点使用NSNetService或者Bonjour C API进行手动广播和发现，但这是一个特别深入的问题，关于手动节点管理可具体参见MCSession文档。Advertising服务的广播通过MCNearbyServiceAdvertiser来操作，初始化时带着本地节点、服务类型以及任何可与发现该服务的节点进行通信的可选信息。发现信息使用Bonjour TXT records encoded（according to RFC 6763）发送。MCNearbyServiceAdvertiser *advertiser = [[MCNearbyServiceAdvertiser alloc] initWithPeer:localPeerID discoveryInfo:nil serviceType:XXServiceType]; advertiser.delegate = self; [advertiser startAdvertisingPeer]; 相关事件由advertiser的代理来处理，需遵从MCNearbyServiceAdvertiserDelegate协议。在下例中，考虑到用户可以选择是否接受或拒绝传入连接请求，并有权以拒绝或屏蔽任何来自该节点的后续请求选项。#pragma mark - MCNearbyServiceAdvertiserDelegate - (void)advertiser:(MCNearbyServiceAdvertiser *)advertiser didReceiveInvitationFromPeer:(MCPeerID *)peerID withContext:(NSData *)context invitationHandler:(void(^)(BOOL accept, MCSession *session))invitationHandler { if ([self.mutableBlockedPeers containsObject:peerID]) { invitationHandler(NO, nil); return; } [[UIActionSheet actionSheetWithTitle:[NSString stringWithFormat:NSLocalizedString(@"Received Invitation from %@", @"Received Invitation from {Peer}"), peerID.displayName] cancelButtonTitle:NSLocalizedString(@"Reject", nil) destructiveButtonTitle:NSLocalizedString(@"Block", nil) otherButtonTitles:@[NSLocalizedString(@"Accept", nil)] block:^(UIActionSheet *actionSheet, NSInteger buttonIndex) { BOOL acceptedInvitation = (buttonIndex == [actionSheet firstOtherButtonIndex]); if (buttonIndex == [actionSheet destructiveButtonIndex]) { [self.mutableBlockedPeers addObject:peerID]; } MCSession *session = [[MCSession alloc] initWithPeer:localPeerID securityIdentity:nil encryptionPreference:MCEncryptionNone]; session.delegate = self; invitationHandler(acceptedInvitation, (acceptedInvitation ? session : nil)); }] showInView:self.view]; } 为了简单起见，本例中使用了一个带有block的actionsheet来作为操作框，它可以直接给invitationHandler传递信息，用以避免创建和管理delegate造成的过于凌乱的业务逻辑，以避免创建和管理自定义delegate object造成的过于凌乱的业务逻辑。这种方法可以用category来实现，或者改编任何一个CocoaPods里有效的实现。Creating a Session在上面的例子中，我们创建了session，并在接受邀请连接时传递到节点。一个MCSession对象跟本地节点标识符、securityIdentity以及encryptionPreference参数一起进行初始化。MCSession *session = [[MCSession alloc] initWithPeer:localPeerID securityIdentity:nil encryptionPreference:MCEncryptionNone]; session.delegate = self; securityIdentity是一个可选参数。通过X.509证书，它允许节点安全识别并连接其他节点。当设置了该参数时,第一个对象应该是识别客户端的SecIdentityRef，接着是一个或更多个用以核实本地节点身份的SecCertificateRef objects。encryptionPreference参数指定是否加密节点之间的通信。MCEncryptionPreference枚举提供的三种值是:MCEncryptionOptional:会话更喜欢使用加密,但会接受未加密的连接。MCEncryptionRequired:会话需要加密。MCEncryptionNone:会话不应该加密。启用加密会显著降低传输速率，所以除非你的应用程序很特别，需要对用户敏感信息的处理，否则建议使用MCEncryptionNone。MCSessionDelegate协议将会在发送和接受信息的部分被覆盖.Discovering客户端使用MCNearbyServiceBrowser来发现广播，它需要local peer标识符，以及非常类似MCNearbyServiceAdvertiser的服务类型来初始化：MCNearbyServiceBrowser *browser = [[MCNearbyServiceBrowser alloc] initWithPeer:localPeerID serviceType:XXServiceType]; browser.delegate = self; 可能会有很多节点广播一个特定的服务，所以为了方便用户（或开发者），MCBrowserViewController将提供一个内置的、标准的方式来呈现链接到广播节点：MCBrowserViewController *browserViewController = [[MCBrowserViewController alloc] initWithBrowser:browser session:session]; browserViewController.delegate = self; [self presentViewController:browserViewController animated:YES completion: ^{ [browser startBrowsingForPeers]; }]; 当browser完成节点连接后，它将使用它的delegate调用browserViewControllerDidFinish:，以通知展示视图控制器--它应该更新UI以适应新连接的客户端。Sending & Receiving Information一旦节点彼此相连，它们将能互传信息。Multipeer Connectivity框架区分三种不同形式的数据传输：Messages是定义明确的信息，比如端文本或者小序列化对象。Streams 流是可连续传输数据（如音频，视频或实时传感器事件）的信息公开渠道。Resources是图片、电影以及文档的文件。MessagesMessages使用-sendData:toPeers:withMode:error::方法发送。NSString *message = @"Hello, World!"; NSData *data = [message dataUsingEncoding:NSUTF8StringEncoding]; NSError *error = nil; if (![self.session sendData:data toPeers:peers withMode:MCSessionSendDataReliable error:&error]) { NSLog(@"[Error] %@", error); } 通过MCSessionDelegate方法 -sessionDidReceiveData:fromPeer:收取信息。以下是如何解码先前示例代码中发送的消息：#pragma mark - MCSessionDelegate - (void)session:(MCSession *)session didReceiveData:(NSData *)data fromPeer:(MCPeerID *)peerID { NSString *message = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding]; NSLog(@"%@", message); } 另一种方法是发送NSKeyedArchiver编码的对象：id <NSSecureCoding> object = // ...; NSData *data = [NSKeyedArchiver archivedDataWithRootObject:object]; NSError *error = nil; if (![self.session sendData:data toPeers:peers withMode:MCSessionSendDataReliable error:&error]) { NSLog(@"[Error] %@", error); } #pragma mark - MCSessionDelegate - (void)session:(MCSession *)session didReceiveData:(NSData *)data fromPeer:(MCPeerID *)peerID { NSKeyedUnarchiver *unarchiver = [[NSKeyedUnarchiver alloc] initForReadingWithData:data]; unarchiver.requiresSecureCoding = YES; id object = [unarchiver decodeObject]; [unarchiver finishDecoding]; NSLog(@"%@", object); } 为了防范对象替换攻击,设置requiresSecureCoding为YES是很重要的，这样如果根对象类没有遵从<NSSecureCoding>，就会抛出一个异常。欲了解更多信息，请参阅[NSHipster article on NSSecureCoding]。StreamsStreams 使用 -startStreamWithName:toPeer:创建：NSOutputStream *outputStream = [session startStreamWithName:name toPeer:peer]; stream.delegate = self; [stream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode]; [stream open]; // ... Streams通过MCSessionDelegate的方法session:didReceiveStream:withName:fromPeer:来接收：#pragma mark - MCSessionDelegate - (void)session:(MCSession *)session didReceiveStream:(NSInputStream *)stream withName:(NSString *)streamName fromPeer:(MCPeerID *)peerID { stream.delegate = self; [stream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode]; [stream open]; } 输入和输出的streams必须安排好并打开，然后才能使用它们。一旦这样做，streams就可以被读出和写入。ResourcesResources 发送使用 -sendResourceAtURL:withName:toPeer:withCompletionHandler::NSURL *fileURL = [NSURL fileURLWithPath:@"path/to/resource"]; NSProgress *progress = [self.session sendResourceAtURL:fileURL withName:[fileURL lastPathComponent] toPeer:peer withCompletionHandler:^(NSError *error) { NSLog(@"[Error] %@", error); }]; 返回的NSProgress对象可以是通过KVO(Key-Value Observed)来监视文件传输的进度，并且它提供取消传输的方法：-cancel。接收资源实现MCSessionDelegate两种方法：-session:didStartReceivingResourceWithName:fromPeer:withProgress: 和 -session:didFinishReceivingResourceWithName:fromPeer:atURL:withError:#pragma mark - MCSessionDelegate - (void)session:(MCSession *)session didStartReceivingResourceWithName:(NSString *)resourceName fromPeer:(MCPeerID *)peerID withProgress:(NSProgress *)progress { // ... } - (void)session:(MCSession *)session didFinishReceivingResourceWithName:(NSString *)resourceName fromPeer:(MCPeerID *)peerID atURL:(NSURL *)localURL withError:(NSError *)error { NSURL *destinationURL = [NSURL fileURLWithPath:@"/path/to/destination"]; NSError *error = nil; if (![[NSFileManager defaultManager] moveItemAtURL:localURL toURL:destinationURL error:&error]) { NSLog(@"[Error] %@", error); } } 再次说明，在传输期间NSProgress parameter in -session:didStartReceivingResourceWithName:fromPeer:withProgress:允许接收节点来监控文件传输进度。在-session:didFinishReceivingResourceWithName:fromPeer:atURL:withError:中,delegate的责任是从临时localURL移动文件至永久位置。Multipeer是突破性的API，其价值才刚刚开始被理解。虽然完整的支持功能比如AirDrop目前仅限于最新的设备，你应该会看到它将成为让所有人盼望的功能。

Java 8 中的 Stream 是对集合（Collection）对象功能的增强，它专注于对集合对象进行各种非常便利、高效的聚合操作（aggregate operation），或者大批量数据操作 (bulk data operation)。Stream API 借助于同样新出现的 Lambda 表达式，极大的提高编程效率和程序可读性。同时它提供串行和并行两种模式进行汇聚操作，并发模式能够充分利用多核处理器的优势，使用 fork/join 并行方式来拆分任务和加速处理过程。通常编写并行代码很难而且容易出错, 但使用 Stream API 无需编写一行多线程的代码，就可以很方便地写出高性能的并发程序。所以说，Java 8 中首次出现的 java.util.stream 是一个函数式语言+多核时代综合影响的产物。 （摘自某博客）Stream 就如同一个迭代器（Iterator），单向，不可往复，数据只能遍历一次Stream不是ORM （对象关系映射）linq有自己的语法，和lambda表达式不同。LINQ，语言集成查询（Language Integrated Query）是一组用于c#和Visual Basic语言的扩展，然后linq能访问多种类型的对象lin的运用有多种：linq to 集合，linqtoxml，txt，doc，sql。。。等等，（ORM组件）然后Stream中的lambda和.net里面的lambda有点类似

意思是：流电影和音乐重点词汇：stream英［stri：m］释义：n.溪流；流动；潮流；光线；（数据）流vi.流；涌进；飘扬vt.流出；涌出；使飘动［复数：streams；第三人称单数：streams；现在分词：streaming；过去式：streamed；过去分词：streamed］短语：stream cipher［计］流密码；密文流；序列密码扩展资料：词语使用变化：musicn.（名词）1、music是抽象名词，不可数，可作“音乐，乐曲”解。泛指“音乐”时不与冠词连用，特指“乐曲”时或music前有形容词最高级修饰时，可与定冠词、物主代词、指示代词等连用。“一首乐曲”是a piece of music，“几首乐曲”是several pieces of music。2、music也可用于指“音乐学科”，这时须用零冠词（不加冠词）。3、music还可作“乐谱”解，还可喻指“和谐悦耳的声音”。

Oracle备份功能包括：高级复制（Advanced Replication）流复制（Streams Replication）备库（Dataguard）一 dataguard：dataguard在高可用及容灾方面一般是dba的首选，毕竟dataguard在这方面 存在压倒性的优势，不管是物理备用库（physical standby database）还是逻辑备用库（logical standby database），它们都具有一些共同的待征。配置和管理方面的成本：dataguard比stream replication简单方便；安全与稳定方面的成本：dataguard比stream replication稳定可靠。对对于一个24x7的系统来说，这些是非常重要的，系统宕机时间的增加不仅影响着公司的形象，还会影响公司的效益；采用dataguard，数据的安全性相当有保障，物理备用库可以在最短的时间完成故障切换，逻辑备用库在保障数据安全的同时， 也可以承担大量的报表等业务；由于dataguard的配置与管理比较简单，同理也降低了dba的工作强度；二 流复制：适用于如下情况：1、局部复制 stream可以只复制某些表或某些模式2、异构环境 充分利用现有的设备与技术3、远程容灾 stream对网络的要求较dataguard低stream replication有灵活的复制策略，不仅可以配置只复制某些表，还可以配置仅复制某些表上的ddl或dml，相比dataguard必须整个数据库复制而言，可以节省相当的存储投资，毕竟对于某些海量数据而言，有许多是不必要复制的。如果在异构环境，即不同的操作系统，那dataguard将会束手无策，非stream replication莫属，这样可以充分利用现有的环境，配置高用可方案，在异构环境，stream replication将会是advanced replication的强劲对手。stream replication传播的是经过logmnr挖掘并包装的逻辑改变记录（LCRs），相比dataguard传送archived redo log、advanced replication的mview log与mview刷新的方式，stream replication对网络的需求降低了很多，在远程异地容灾的过程中，租用网络带宽是一笔较高的费用，stream replication可以适当地降低这笔费用。三 高级复制：advanced replication相对于dataguard，缺点是：配置与管理较复杂、安全与稳定性不够；优点：局部复制、异构环境等。advanced replication是一种相当成熟的技术，在许多关键系统中得到成功的运用，相对于9iR2推出的stream replication而言，双方适用的环境虽然相当，比如都可以进行局部复制、异构复制、远程容灾等，advanced replication目前在稳定性与安全性方面更经得起考验。对比stream replication与advanced replication底层的实现技术，stream replication在实时性、稳定性、高效率、低消耗（较少的cpu/network资源）等方面更有优势，但凡一些新推出的功能，都或多或少存在一些不确定的因素。在10gR1中，oracle针对目前stream replication存在的弱点进行了增强，不仅提供了从advanced replication迁移到stream replication的脚本，还提供了stream replication的配置与监控工具，stream replication在配置与管理方面必将智能化、简单化，担负起与shareplex争夺企业数据复制市场的重任。四 高级复制与流复制区别高级复制与Streams Replication的原理是完全不同的，Streams Replication可以到表，用户，数据库级别，但高级复制似乎只能到表一级。Streams Replication不是高级复制的升级版。异构环境下，oracle的高可用和容灾有高级复制和stream 复制两种，两种的异同点如下：1.高级复制是基于触发器（trigger）原理，而stream是基于日志挖掘原理，因此stream复制对源数据库的性能影响更小，但实时性不如高级复制。2.高级复制复制的对象是基于数据库目标（object）的，如表、索引和存储过程，而stream复制可以针对表、方案（schema）和整个数据库，因此如果出于容灾整个数据库的考虑，stream复制的配置相对简单。3.高级复制是一种相当成熟的技术，在许多关键系统中得到成功的运用，相对于9iR2推出的stream复制，高级复制目前在稳定性与安全性方面更经得起考验。4.从发展的角度看，流的应用会越来越多，从oracle10g，oracle公司提供了从高级复制向流复制移植的工具，可以看出，oracle公司会更偏重于基于流的新技术。5.由于高级复制是基于触发器的，因此所有的复制对象结构（ddl）的改变，都必须通过oracle提供的复制包来实施，和应用结合的比较紧，更适合于开发者使用，而流复制则更适合dba来实施。6. 流复制支持双向数据复制，而高级复制会有冲突；7. 流复制支持异构数据库复制，而没有资料说明高级复制也有相同功能；两种实际使用来看，streams复制需要更少的带宽，2m带宽，如果 streams复制不行，高级复制大概更没戏，但是用streams最好别网络断线时间过长，不知道是bug还是oracle没考虑这种情况，如果复制停 顿一段时间，再恢复正常，大概是队列表中消息太多了，入队出队都很慢，非线性增长啊，这样就需要不短的一段时间来同步数据，高级复制就没这种状况。bug，反正10，2，0，1有一些，看你碰的到碰不到了，严重的能让你删掉队列表重建才行，意味着基本是重建整个复制了，不过想重复一下又不出现了；还有使用negative rule如果站点多了遇到大的更新事务速度就变得极慢，站点多了要先设计好结构；会不停在有apply进程的站点udump目录下生成trc文件，虽然还算不上很成熟，不过streams复制真是好东西，以后必定会取代高级复制，建议打10.2.0.3补丁，据说修正了不少bug.stream对系统的设计与维护方要有相当的对stream技术的把控能力，而大多数系分与 DBA对这个东西都没有经验，所以难以推广；dataguard胜在维护简单可靠，一般dba都可以维护。stream以后会的前景会非常广阔！ 尤其是双向复制，解决了很多实际问题。

我曾经历过一些很可怕的事情，它真真实实地发生过。

中国海洋大学外国语学院硕士生导师兼外事处首席翻译邹卫宁老师从青岛千里驰电到广东云浮，和我商谈海大校训（motto）“海纳百川，取则行远”的英译。后来，我交给他的“答卷”是： 　　Vast ocean embraces streams to its tide; Norms received promise one far and wide. 　　邹老师很客气，回函说：I think your translation of the "mission statement" of our university is quite "faithful, expressive and elegant". 译文是怎样组织出来的呢？ 　　“海纳百川”好理解，“取则行远”的“则”字却一时未知其解。邹老师说，“则”乃“规则”。网上搜索，亦得其义。《科讯网》2003年11月3 日在《春光唱彻方无憾──写在王蒙文学创作50周年之际》一文中有这样的语句：“海大校训‘海纳百川，取则行远"就是王蒙先生所题。由此可见，王蒙先生对 ‘则"的重视和尊重。在办学思路上，王蒙先生同样体现了的‘取则行远"思想。”由此可见，“则”作名词。青岛市王修林副市长寄语中国海洋大学2003届毕业生的时候说：“海大经过近八十年的历史，形成了自身的特点，现在又提出了自己的新校训‘海纳百川，取则行远"，含义非常的深刻。这就要求毕业生要吸收各方面的知识，吸收各方面的锻炼，用以往的经验和常识经锻炼见风雨，在成就自己的本身，也成就社会。”我根据自己的理解，试作三译如下： 　　1、 Vast ocean embraces streams to its tide; Norms received promise one far and wide.（易读指数：90.9；难度系数：2.3） 　　2、 Vast ocean embraces streams to its tide; Norms received promise well and wide.（易读指数：90.9；难度系数：2.3） 　　3、 Vast ocean embraces streams to its tide; Proper norms help one go far and wide.（易读指数：100；难度系数：0.8） 　　“海纳百川”较好翻译。Embrace有表示“亲热的拥抱”、“热忱热切的接受”、“高兴地接受, 采纳”，有“主动接纳”的意思。“百”是虚数，实意为“多”，“百川”可用streams译之。to its tide表示接纳到大海本身那汹涌的波涛之中，成为大海自己的东西。Vast ocean embraces streams to its tide，寓意海大人应虚怀若谷，胸襟宽广，容人容事；海大园能吸纳多科知识，能容纳多路群英。 　　译“取则行远”，就费点心思了。“则”乃“规则”，兹以norm译之。norm有“标准, 规范准则”，“准则”，“行为标准”等含义。例如，“法律规范”是legal norm，“国际法规范”是norm of international law,“社会规范”是social norm，“行为准则”是norms of conduct，“生活方式的准则”是the norm in the style of life, 等等。“取”不必直译，也不必实译，用权且称为“暗译”或“虚译”的方法，将received放在norm的后面。norms received是普遍公认的准则。英语诗词写作，因音韵要求的需要，修饰词可放在其修饰的中心词之后，成为“后置定语”。而received,原意本身就有“接取”之意。 　　为何用promise呢？promise 有“给人予……指望”之意。从an enterprise that promises well （一定有发展前途的企业），of great /high promise (前程远大的)和promise well（前景很好）等表达可知，用promise one well and wide 是从习惯用法上的well与promise搭配，意思是“使人有远大的发展前途”。Norms received promise one well and wide就是“采用普遍公认的准则行事，就有远大的发展前途”。然而，人们习惯用far and wide 这个组合搭配比较固定的词组。 　　我写出上面的前两种译法，向来适逢莅临云浮考察的世界500强公司之一的Emerson(美国艾默生集团)的首席营运官爱德华·孟瑟先生和其子公司——雅达国际电子有限公司在菲律宾的区域总部物料副总裁麦克·威尔斯请教。两位美国客人认为读了那两种译文，都可明其寓意，而用far and wide会好些。 　　第一、二种译法，两个句子各有九个音节，整齐，押韵，符合诗的基本要求。第一种译法是我本人至今能想到的的书面译文。但是，我还是有惶惶然之感，不知其可乎？第三种译法，照字面意思直译的成分较大，口译时容易理解，保留了原文的“含蓄美”。 　　附：关于“易读指数”和“难度系数” 　　启动 “可读性统计信息”程序查译文的易读性指数(Flesch Reading Ease)或难度级数(Flesch-Kincaid Grade Level)，作为参考，可选择适用的表达。 　　易读性指数用百分制表示，在一定程度上反映了“深入浅出，通俗易懂”的程度，“分数越高，表示越容易理解”，多数标准文章，大约在60至70分。 　　难度级数根据美国学校年级的水平来评定（如，8.0分表示八年级学生可看懂查阅的译文，相当于易读性指数60至70分）。 　　难度级数越低，表示越容易看懂。如要让人听懂，易读性指数就应相对地高一些，或难度级数低一些。其实，二者是同时显示的。 　　后记：英语有云：“There are translations and translations(有各种各样的翻译)”。以上文字，承蒙中国海洋大学国际合作与交流处的推荐和该校校报的错爱，全文刊登在2004年3月25日第1375期《中国海洋大学报》第四版《浪花》副刊上。（报上介绍本人时，将“中国译协理事、广东省译协常务理事”误移成“中国译协常务理事”，本人应作更正；正文最后一段“第二种译法是我本人至今能想到的的书面译文”中的“第二种译法”则应为“第一种译法”。另外，本人不敢冒称“权威”。——笔者注）文章发表以后，笔者知道，对“海大校训”会有各种各样的翻译出来，形成百花齐放，万紫千红的局面。邹卫宁老师跟青岛大学孔祥军教授谈起我的译文时，孔教授在上述译文的基础上，“减肥”有术，改成另有一番韵味的译文： 　　Vast Ocean Embraces Streams; Norms Promise One‘s Dreams. 　　有道是：文章是改出来的。其实，译文也是改出来的。如果中国海洋大学采用上译，我和孔祥军教授就是共同作者了。我仍期待着更好的译品。然而，现在，我要感谢邹卫宁老师和孔祥军教授，感谢《中国海洋大学报》！

【本文翻译自 Value Streams 】 价值流代表了一个组织用于实施 解决方案 的一系列步骤，这些解决方案为客户提供持续的价值流。 SAFe投资组合包含一个或多个价值流，每个价值流专用于建立和支持一套解决方案，即交付给客户的产品、服务或系统，无论是用在企业内部还是外部。 在采用精益-敏捷实践之前，许多企业将人员按照职能划分为一个个的功能筒仓，这带来了许多挑战（图1）： 围绕价值进行组织，促使人们重新思考如何开发和部署解决方案。 价值流是SAFe中理解、组织和交付价值的主要结构。每个价值流都是用于创造价值的一系列长期步骤。某个触发器启动了价值的流动，并最终实现了某种形式的货币化或价值交付。中间的步骤是用来开发或交付价值的活动。 SAFe定义了两种类型的价值流，如图2所示。 我们围绕价值流组织人员的原因很简单。我们希望加快实现价值（或推向市场）的时间。我们通过优化整个系统的价值流来实现这一目标。毕竟，一个企业如果不清楚自己能交付什么以及如何交付，就无法改进它。 （ 译者注： 彼得德鲁克说过一句类似的话：你如果无法度量它，就无法管理它。） 为此，围绕价值流组织SAFe的投资组合，可以可视化产生解决方案的工作流，它提供了以下好处 ： 每个价值流中的 敏捷发布列车(ART) 开发运营价值流所使用的业务解决方案。ART是跨职能的，其拥有定义、实施、测试、部署、发布以及在适用的情况下运营解决方案所需的所有能力（软件、硬件、固件等等）。 值得注意的是，SAFe中的价值流结构取代了围绕项目组织人员的需求。 定义开发价值流和设计ART是实施SAFe的最关键步骤之一，在 识别价值流和ART 一文中对此进行了详细描述。 此外，一旦确定了价值流，还需要进行额外的分析，以确定开发价值流的边界、人员、可交付成果、潜在的ART和其他数据。图3提供了一个 开发价值流画布（Development Value Stream Canvas） ，这是一个简单的工具，利益相关者可以用来捕捉他们的新想法[1]。 识别开发价值流并了解组织内的流程是改善价值交付的一个重要步骤。它还为实施 精益预算 提供了机会，精益预算可以大幅降低经费和摩擦，并进一步加快流程。 每个开发价值流都有一个经批准的预算（图4）， 精益投资组合管理（LPM） 遵循精益-敏捷预算原则进行管理，并随着时间的推移，根据业务条件的变化进行调整。 每个开发价值流都是企业的一项实质性投资。因此，为谨慎起见，应采用一些合理的治理办法，以评估价值流在实现其预期业务成果方面的表现。为此，每个价值流都定义了一组关键绩效指标（KPI），可用于评估对特定价值流的持续投资。KPI是 价值流KPI 一文的主题。 价值流在设计上应尽可能独立。然而，可能需要进行一些协调，以确保企业的每个价值流都与企业和投资组合的目标保持一致。价值流协调是 协调 一文的主题。 最后，识别价值流并围绕价值流组织发布列车还有一个重要的好处。每个价值流都为客户提供了可识别和可衡量的流动的价值。因此，可以使用价值流图来系统地对其进行测量和改进，以提高交付速度和质量——这是一个分析过程，团队可以首先使用该模型来理解价值流，然后尝试缩短上市时间。通过将价值流图与根本原因分析相结合，成熟的精益企业可以系统地、持续地缩短产品上市时间，为企业带来利益。减少价值流中的延迟始终是缩短产品上市时间的最快方法。 [1] 感谢SAFe研究员 Mark Richards 提出的价值流画布概念。 [2] Martin, Karen, and Mike Osterling. Value Stream Mapping. McGraw Hill, 2014 [3] Poppendieck，Mary，and Tom. 精益软件开发管理之道。机械工业出版社华章公司，2011年。 [4] Ward, Allen. Lean Product and Process Development. Lean Enterprise Institute, 2014 [5] https://en.wikipedia.org/wiki/Value-stream_mapping

位于对流层上层或平流层中的强而窄的气流。一般长几千公里，宽几百公里，厚几公里。急流中心的长轴称为急流轴，它近于水平。在急流轴线附近，风速的切变很强，铅直切变约为每公里5～10米/秒，水平切变约达每百公里5米/秒。按世界气象组织的规定，急流轴线上的风速下限为30米/秒。急流迂回曲折，环绕整个半球，急流轴线上的风速并不均匀，有一个或多个风速极大值中心。在风速小于30米/秒处中断。一般情况下,急流的中心风速为50～80米/秒，有时可达100～150米/秒，在冬季偶尔可达150～180米/秒。急流轴线在有的地区出现分支，有的地区两支急流汇合。从对流层顶附近的等压面（如200百帕）和平均纬向风速分布图上(见大气环流),可看出急流的分布和结构。由于急流同大气热量和角动量的输送有关，是全球大气环流的重要环节。急流又往往同锋区相联系，因此和天气系统的发生、发展有着密切的关系。急流是天气学中重要的研究课题之一。第二次世界大战末期，美国飞行员在日本上空的对流层顶附近向西飞行时，遇到了一股高速气流，难于航行，后经气象学家研究，发现这就是高空西风急流。随着高空探测网的建立，又在其他地区上空发现了高空急流的存在。但以东亚沿岸和日本上空的西风急流最为强大，由于急流的风速有时很大，而且其铅直和水平切变很强，当飞机在急流区附近沿着急流飞行或处于强风速切变区时，容易造成飞行事故(见航空气象学)。因此,常要求及时提供准确的急流位置和强度的情报和预报。根据急流的形成区域和结构不同可分为极锋急流、副热带急流、热带东风急流和极夜急流。关于对流层下部的低空急流则是另一种性质的急流。

数据流读取错误 可能是魔术手里面的一些控件出现问题 或者是系统兼容性的问题。stream read error 数据流读取错误;stream英[stri:m]美[strim]n.河流，小河，川，溪; 潮流，趋势，倾向; （事件等的） 连续，（财富等的）滚滚而来; 流出，流注，一连串;vt.流，流动;vi.飘扬; 招展; 鱼贯而行; 一个接一个地移动;[例句]There was a small stream at the end of the garden.花园的尽头有一条小河。[其他]第三人称单数：streams 复数：streams 现在分词：streaming 过去式：streamed 过去分词：streamed

My family went to Sanjiang together.The air was clear there.The rivulet was clear.We were swimming in the rivulet.There were a lot of stars in the sky.We enjoy ourselves!

revenue streamsn.[经] 收益源( revenue stream的名词复数 ); 以上结果来自金山词霸例句:1.He also vowed to find new revenue streams in comics, television, films and toys. 他也曾发誓要在动画、电视、电影和玩具等领域寻找新的收入来源。2.As business owners know, multiple revenue streams are the key to financial stability. 每一位企业主都知道，多个收入来源是财政稳定的关键所在

配置上hosts，通过zk连接kafka要保证zk端口通，并且kafka也要通；同时zk中配置的kafka的主机名要与hosts的一致。

安装个turbomeeting就可以实现了，而且清晰流畅。

首先在Redis-cli中使用XADD命令插入一条数据 查看对象编码 可以看到对象的数据类型为stream，返回的streamID 的基本结构为 "{timestamp}-{sequence}" 使用XINFO命令查看该 stream Key 的基本信息 可以看到stream中使用了一种 "radix-tree" 数据结构。 Radix树对上述单词的存储 当插入first时 相比于普通的字典树，Radix树会将单节点树枝压缩为一个节点，以节省存储空间，提高搜索的效率。在Streams结构中，默认生成的StreamID为 时间戳+自增序列号 的形式，当消息的时间分布紧凑时，这种存储结构多个StreamID复用的前缀将很长，可以将存储空间压缩得很小，这对于内存使用内存存储数据的Redis很重要。Radix树的另一个优点是解决了hash冲突的问题。对于一般的hash结构，当遇到hash冲突的情况，一般采用链地址法的方式解决冲突。这样一个hash槽中的链可能会很长，如果采用扩容的方式，执行效率一般也不是很高。采用树结构索引数据解决了hash冲突的问题。当然，Radix树在遇到新插入的数据时也会遇到数据节点拆分的问题。 stream 是一种 append-only 的数据结构，只有 del 命令可以删除对应的Key。 指定添加数据的最大长度（~表示只在节点删除时清除数据，能保证数据个数的最大长度不小于 LENGTH 个，不需要每次调整Radix树，性能相对较好） 阻塞式，获取最新1条的数据（阻塞单位：ms） 根据Streams支持的命令，要使用Streams作为多消费队列，主要有以下几点： 官网介绍 中文官网命令介绍 图解Redis数据结构，讲的比较好 知乎上基于Redis消息队列方案介绍

随着编程语言生态系统的气候不断变化以及技术的革新，经历20余年的发展，Java逐渐演变成长为Java8。相比之前只是单纯的面向对象编程语言，Java8增加了很多新特性。Java 8对于程序员的主要好处在于它提供了更多的编程工具和概念，能以更为简洁、更易于维护的方式解决新的或现有的编程问题。在Java 8中有两个著名的改进：一个是Lambda表达式，一个是Stream。Lambda表达式是什么？Lambda表达式，也可称为闭包，它允许把函数作为一个方法的参数（函数作为参数传递进方法中）。使用Lambda表达式可以使代码变的更加简洁紧凑，Lambda表达式的语法格式：(parameters) -> expression或(parameters) ->{ statements; }Lambda表达式的重要特征:可选类型声明：不需要声明参数类型，编译器可以统一识别参数值。可选的参数圆括号：一个参数无需定义圆括号，但多个参数需要定义圆括号。可选的大括号：如果主体包含了一个语句，就不需要使用大括号。可选的返回关键字：如果主体只有一个表达式返回值则编译器会自动返回值，大括号需要指定明表达式返回了一个数值。使用Lambda表达式需要注意以下两点：Lambda表达式主要用来定义行内执行的方法类型接口，例如，一个简单方法接口。在上面例子中，我们使用各种类型的Lambda表达式来定义MathOperation接口的方法。然后我们定义了sayMessage的执行。Lambda表达式免去了使用匿名方法的麻烦，并且给予Java简单但是强大的函数化的编程能力。Stream是什么？Stream就是一个流，它的主要作用就是对集合数据进行查找过滤等操作。Java 8中的 Stream是对集合（Collection）对象功能的增强，它专注于对集合对象进行各种非常便利、高效的聚合操作（aggregate operation），或者大批量数据操作(bulk data operation)。对于基本数值型，目前有三种对应的包装类型Stream：IntStream、LongStream、DoubleStream。当然我们也可以用Stream<Integer>、Stream<Long> >、Stream<Double>，但是boxing和 unboxing会很耗时，所以特别为这三种基本数值型提供了对应的Stream。Java 8中还没有提供其它数值型Stream，因为这将导致扩增的内容较多。而常规的数值型聚合运算可以通过上面三种Stream进行。Stream上的操作分为两类：中间操作和结束操作。中间操作只是一种标记，只有结束操作才会触发实际计算。中间操作又可以分为无状态的(Stateless)和有状态的(Stateful)，无状态中间操作是指元素的处理不受前面元素的影响，而有状态的中间操作必须等到所有元素处理之后才知道最终结果，比如排序是有状态操作，在读取所有元素之前并不能确定排序结果。结束操作又可以分为短路操作和非短路操作，短路操作是指不用处理全部元素就可以返回结果，比如找到第一个满足条件的元素。之所以要进行如此精细的划分，是因为底层对每一种情况的处理方式不同。想要永远处于优势地位，就要不断的完善自身、更新技术。

"Let us run with patience" (Heb. 12:1) 让我们边忍耐边奔跑。 O run with patience is a very difficult thing. Running is apt to suggest the absence of patience, the eagerness to reach the goal. We commonly associate patience with lying down. We think of it as the angel that guards the couch of the invalid. Yet, I do not think the invalid"s patience the hardest to achieve. 边忍耐边奔跑是非常困难的。奔跑，在常人看来，就是缺乏耐心、急于求成的表现。我们通常觉得，所谓耐心，就是躺下来什么都不做。我们以为它是守护弱者病榻的天使。然而，我并不认为弱者的忍耐是最难做到的。 There is a patience which I believe to be harder--the patience that can run. To lie down in the time of grief, to be quiet under the stroke of adverse fortune, implies a great strength; but I know of something that implies a strength greater still: It is the power to work under a stroke; to have a great weight at your heart and still to run; to have a deep anguish in your spirit and still perform the daily task. It is a Christlike thing! 有一种耐心，我认为更难做到，即一边奔跑一边忍耐。在悲伤的时候躺下来，在遭遇不幸的时候保持平静，这的确是一种力量；但我知道还有一种更强大的力量：背负不幸仍坚持工作、心有重负仍坚持奔跑，痛不堪言仍要完成义务。这是与基督一样的精神！ Many of us would nurse our grief without crying if we were allowed to nurse it. The hard thing is that most of us are called to exercise our patience, not in bed, but in the street. We are called to bury our sorrows, not in lethargic quiescence, but in active service━in the exchange, in the workshop, in the hour of social intercourse, in the contribution to another"s joy. There is no burial of sorrow so difficult as that; it is the "running with patience.” 如果可以，我们中的许多人都能默默忍受悲哀。然而对于大多数人来说，更难的一点，不是在床上忍耐，而是在街上。我们需要将悲伤埋葬在积极的工作中，而不是懒洋洋的休眠里。我们要与人交流、好好工作、参与社交，关心他人的快乐。最难的是以这种方式去掩埋悲伤，这就是“一边忍耐一边奔跑”。 This was Thy patience, O Son of man! It was at once a waiting and a running—a waiting for the goal, and a doing of the lesser work meantime. I see Thee at Cana turning the water into wine lest the marriage feast should be clouded. I see Thee in the desert feeding a multitude with bread just to relieve a temporary want. All, all the time, Thou wert bearing a mighty grief, unshared, unspoken. Men ask for a rainbow in the cloud; but I would ask more from Thee. I would be, in my cloud, myself a rainbow—a minister to others" joy. My patience will be perfect when it can work in the vineyard. ━George Matheson 这是你的耐心，人类之子。你要一边等待一边奔跑 — —等待目标的实现，同时做着琐碎的日常工作。我看到你在迦拿小城酿水为酒，以防婚宴不能正常进行。我看到你在沙漠里分发食物给众人，让他们不再挨饿。做这些事情的时候，你都独自默默承受着巨大的悲伤，不与人分享。我，在我的乌云里，将化身一道彩虹——成为给予他人快乐的牧师。唯有能使我继续在葡萄园中劳作的耐心，才是真正的耐心。 “When all our hopes are gone, "Tis well our hands must keep toiling on For others " sake: For strength to bear is found in duty done; And he is best indeed who learns to make The joy of others cure his own heartache. ” “当我们失去了希望， 我们的双手仍要辛勤劳动， 为了他人。 完成职责才能证明忍耐的力量； 唯有学会以他人的快乐度自己的心痛， 才是至善至美之人。”

struts 用的是fileupload 这个组件默认的文件上传表单最大值是2M,超过了会抛出异常如果是struts的话,要配置一下文件上传的最大值在struts.xml中加入 <constant name="struts.multipart.maxSize" value="10485760"/> 10MB

stream的意思是：流动。读音：英［striu02d0m]，美［striu02d0m]。释义：n.溪流；流动；潮流；光线；（数据）流。vi.流；涌进；飘扬。vt.流出；涌出；使飘动。例句：The limpid stream flows northward.这条清澈的小溪流流向了北方。变形：过去式streamed，过去分词streamed，现在分词streaming，第三人称单数streams，复数streams。短语：mountain stream山涧。sun streams太阳光线。in streams连续不断，川流不息。近义词brook读音：英［bru028ak]，美［bru028ak]。释义：n. 溪；小河；小川；vt. (不）允许（某事）；例句：God told him to go hide himself by the Brook Cherith.神告诉他去藏在约但河东边的基立溪旁。变形：第三人称单数brooks，复数brooks，现在分词brooking，过去式brooked，过去分词brooked。用法：brook是正式用语，通常用于否定句或疑问句。brook用作名词的意思是“小溪”，是文学用词，指发源于山泉的溪流，一般说来，比creek和stream小。

stream 英 [stri:m]美 [strim]n. 河流，小河，川，溪;潮流，趋势，倾向; （事件等的） 连续，（财富等的）滚滚而来;流出，流注，一连串;vt. 流，流动;vi. 飘扬;招展;鱼贯而行;一个接一个地移动;[例句]The bare bed of a dry stream 干涸小河裸露的河床[其他] 第三人称单数：streams 复数：streams 现在分词：streaming 过去式：streamed 过去分词：streamed 形近词： streak scream

stream的读音：英 [striu02d0m]，美 [striu02d0m] 　 　n. (小)河；水流；(人；车；气)流；组v. 流动；流出；飘动；将(学生)按能力分组形容词: streamy 过去式: streamed 过去分词: streamed 现在分词: streaming 第三人称单数: streamsstream的基本意思是“流动”，指受限制的流动，如通过一定的路线或出口。也可指大量不断地流动。引申可指“飘动”。stream既可用作及物动词，也可用作不及物动词。用作及物动词时，可接名词或代词作宾语。例句1、On either bank of the stream stand rows of willow trees.小河两岸柳树成行。2、Sand and leaves trapped the water in the stream.沙子和树叶堵住了小河的水流。3、Visitors to the exhibition came in an endless stream.参观展览会的人络绎不绝。4、Cars stream along the highway.汽车在公路上流水般地行驶。

registeredphpstreams的中文翻译_百度翻译registeredphpstreams全部释义和例句>>注册PHP流

stream[英][stri:m][美][strim]n.河流，小河，川，溪; 潮流，趋势，倾向; （事件等的）连续，（财富等的）滚滚而来; 流出，流注，一连串; vt.& vi.流，流动; vi.飘扬; 招展; 鱼贯而行; 一个接一个地移动; vt.按能力分班（或分组）; 按能力分班（或分组）; 第三人称单数：streams过去分词：streamed复数：streams现在进行时：streaming过去式：streamed

里面就是一些标准IO的函数声明，和我们自己定义的头文件都是差不多的。

数据流读取错误 可能是魔术手里面的一些控件出现问题 或者是系统兼容性的问题。stream read error 数据流读取错误;stream 英[stri:m]美[strim]n. 河流，小河，川，溪; 潮流，趋势，倾向; （事件等的） 连续，（财富等的）滚滚而来; 流出，流注，一连串;vt. 流，流动;vi. 飘扬; 招展; 鱼贯而行; 一个接一个地移动;[例句]There was a small stream at the end of the garden.花园的尽头有一条小河。[其他] 第三人称单数：streams 复数：streams 现在分词：streaming 过去式：streamed 过去分词：streamed

歌曲名:Tiny Streams歌手:Psychotic Waltz专辑:Into The EverflowMorning sun begins the dayMothers child has gone awayLocked inside the game that they taught him all to playCloset city sleeping pretty tired from the dayAnd if he leaves the tiny porch light dimHe"ll keep the dogs at baySnotty little brat he playsNever puts his toys awayBreaks the ones he"s used if they don"t sparkle anymoredollies in the playhouse kissingPsychotic WaltzAll their little heads are missingChop their tiny hands with this thingThat"s what daddy bought them forRed and White"s turned blue todayI laugh to dry the tear awaySitting in my ceilings faceThis boiling rainbow webbing placeSmiles soft anger feeling shapesOf mouths and hands in sonic scapesFingers spanning psychic burningBlack Sabbath record turningPools of vision, understandingClimb the walls, half inside themOther side, air is thin thereFriends inside pull me to themCannot keep from laughing, laughingRipples from the portholes making contactCenter bending circlesGrowing echoes of each otherFloat reflections of this covered consciousnessInside this eggshellMasterpieces scattered not well spokenYet still undertakenTiny streams of orchestrationFlow into this fisheye car rideLeaning close to catch his good sideTiny streams of orchestrationhttp://music.baidu.com/song/14155812

由Oracle Streams 特性使用的一块内存区域。Oracle Streams也叫Oracle流，可以使一个数据库中的数据，事物处理和事件在本数据库内部传递，也可以使它们从一个数据库传递到另一个数据库中。流可以将被发布的信息传递到订阅它的目的地。简而言之Oracle Streams 就是满足了大部分的数据移动，事物处理传播以及事件管理的需要。

不一定要个OUTlook吧，明天帮你调试下，原理是你登陆邮件服务器，实现邮件发送，C#有专门的方法和类型，你自己找找看，不行的话，HI我，我把我自己写的邮件发送给你，你看看，很简陋，但是一般功能都有！

Multipeer connectivity是一个使附近设备通过Wi-Fi网络、P2P Wi-Fi以及蓝牙个人局域网进行通信的框架。互相链接的节点可以安全地传递信息、流或是其他文件资源，而不用通过网络服务。Advertising & Discovering通信的第一步是让大家互相知道彼此，我们通过广播(Advertising)和发现(discovering)服务来实现。广播作为服务器搜索附近的节点，而节点同时也去搜索附近的广播。在许多情况下，客户端同时广播并发现同一个服务，这将导致一些混乱，尤其是在client-server模式中。所以，每一个服务都应有一个类型（标示符），它是由ASCII字母、数字和“-”组成的短文本串，最多15个字符。通常，一个服务的名字应该由应用程序的名字开始，后边跟“-”和一个独特的描述符号。(作者认为这和 com.apple.*标示符很像)，就像下边：static NSString * const XXServiceType = @"xx-service"; 一个节点有一个唯一标示MCPeerID对象，使用展示名称进行初始化，它可能是用户指定的昵称，或是单纯的设备名称。MCPeerID *localPeerID = [[MCPeerID alloc] initWithDisplayName:[[UIDevice currentDevice] name]]; 节点使用NSNetService或者Bonjour C API进行手动广播和发现，但这是一个特别深入的问题，关于手动节点管理可具体参见MCSession文档。Advertising服务的广播通过MCNearbyServiceAdvertiser来操作，初始化时带着本地节点、服务类型以及任何可与发现该服务的节点进行通信的可选信息。发现信息使用Bonjour TXT records encoded（according to RFC 6763）发送。MCNearbyServiceAdvertiser *advertiser = [[MCNearbyServiceAdvertiser alloc] initWithPeer:localPeerID discoveryInfo:nil serviceType:XXServiceType]; advertiser.delegate = self; [advertiser startAdvertisingPeer]; 相关事件由advertiser的代理来处理，需遵从MCNearbyServiceAdvertiserDelegate协议。在下例中，考虑到用户可以选择是否接受或拒绝传入连接请求，并有权以拒绝或屏蔽任何来自该节点的后续请求选项。#pragma mark - MCNearbyServiceAdvertiserDelegate - (void)advertiser:(MCNearbyServiceAdvertiser *)advertiser didReceiveInvitationFromPeer:(MCPeerID *)peerID withContext:(NSData *)context invitationHandler:(void(^)(BOOL accept, MCSession *session))invitationHandler { if ([self.mutableBlockedPeers containsObject:peerID]) { invitationHandler(NO, nil); return; } [[UIActionSheet actionSheetWithTitle:[NSString stringWithFormat:NSLocalizedString(@"Received Invitation from %@", @"Received Invitation from {Peer}"), peerID.displayName] cancelButtonTitle:NSLocalizedString(@"Reject", nil) destructiveButtonTitle:NSLocalizedString(@"Block", nil) otherButtonTitles:@[NSLocalizedString(@"Accept", nil)] block:^(UIActionSheet *actionSheet, NSInteger buttonIndex) { BOOL acceptedInvitation = (buttonIndex == [actionSheet firstOtherButtonIndex]); if (buttonIndex == [actionSheet destructiveButtonIndex]) { [self.mutableBlockedPeers addObject:peerID]; } MCSession *session = [[MCSession alloc] initWithPeer:localPeerID securityIdentity:nil encryptionPreference:MCEncryptionNone]; session.delegate = self; invitationHandler(acceptedInvitation, (acceptedInvitation ? session : nil)); }] showInView:self.view]; } 为了简单起见，本例中使用了一个带有block的actionsheet来作为操作框，它可以直接给invitationHandler传递信息，用以避免创建和管理delegate造成的过于凌乱的业务逻辑，以避免创建和管理自定义delegate object造成的过于凌乱的业务逻辑。这种方法可以用category来实现，或者改编任何一个CocoaPods里有效的实现。Creating a Session在上面的例子中，我们创建了session，并在接受邀请连接时传递到节点。一个MCSession对象跟本地节点标识符、securityIdentity以及encryptionPreference参数一起进行初始化。MCSession *session = [[MCSession alloc] initWithPeer:localPeerID securityIdentity:nil encryptionPreference:MCEncryptionNone]; session.delegate = self; securityIdentity是一个可选参数。通过X.509证书，它允许节点安全识别并连接其他节点。当设置了该参数时,第一个对象应该是识别客户端的SecIdentityRef，接着是一个或更多个用以核实本地节点身份的SecCertificateRef objects。encryptionPreference参数指定是否加密节点之间的通信。MCEncryptionPreference枚举提供的三种值是:MCEncryptionOptional:会话更喜欢使用加密,但会接受未加密的连接。MCEncryptionRequired:会话需要加密。MCEncryptionNone:会话不应该加密。启用加密会显著降低传输速率，所以除非你的应用程序很特别，需要对用户敏感信息的处理，否则建议使用MCEncryptionNone。MCSessionDelegate协议将会在发送和接受信息的部分被覆盖.Discovering客户端使用MCNearbyServiceBrowser来发现广播，它需要local peer标识符，以及非常类似MCNearbyServiceAdvertiser的服务类型来初始化：MCNearbyServiceBrowser *browser = [[MCNearbyServiceBrowser alloc] initWithPeer:localPeerID serviceType:XXServiceType]; browser.delegate = self; 可能会有很多节点广播一个特定的服务，所以为了方便用户（或开发者），MCBrowserViewController将提供一个内置的、标准的方式来呈现链接到广播节点：MCBrowserViewController *browserViewController = [[MCBrowserViewController alloc] initWithBrowser:browser session:session]; browserViewController.delegate = self; [self presentViewController:browserViewController animated:YES completion: ^{ [browser startBrowsingForPeers]; }]; 当browser完成节点连接后，它将使用它的delegate调用browserViewControllerDidFinish:，以通知展示视图控制器--它应该更新UI以适应新连接的客户端。Sending & Receiving Information一旦节点彼此相连，它们将能互传信息。Multipeer Connectivity框架区分三种不同形式的数据传输：Messages是定义明确的信息，比如端文本或者小序列化对象。Streams 流是可连续传输数据（如音频，视频或实时传感器事件）的信息公开渠道。Resources是图片、电影以及文档的文件。MessagesMessages使用-sendData:toPeers:withMode:error::方法发送。NSString *message = @"Hello, World!"; NSData *data = [message dataUsingEncoding:NSUTF8StringEncoding]; NSError *error = nil; if (![self.session sendData:data toPeers:peers withMode:MCSessionSendDataReliable error:&error]) { NSLog(@"[Error] %@", error); } 通过MCSessionDelegate方法 -sessionDidReceiveData:fromPeer:收取信息。以下是如何解码先前示例代码中发送的消息：#pragma mark - MCSessionDelegate - (void)session:(MCSession *)session didReceiveData:(NSData *)data fromPeer:(MCPeerID *)peerID { NSString *message = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding]; NSLog(@"%@", message); } 另一种方法是发送NSKeyedArchiver编码的对象：id <NSSecureCoding> object = // ...; NSData *data = [NSKeyedArchiver archivedDataWithRootObject:object]; NSError *error = nil; if (![self.session sendData:data toPeers:peers withMode:MCSessionSendDataReliable error:&error]) { NSLog(@"[Error] %@", error); } #pragma mark - MCSessionDelegate - (void)session:(MCSession *)session didReceiveData:(NSData *)data fromPeer:(MCPeerID *)peerID { NSKeyedUnarchiver *unarchiver = [[NSKeyedUnarchiver alloc] initForReadingWithData:data]; unarchiver.requiresSecureCoding = YES; id object = [unarchiver decodeObject]; [unarchiver finishDecoding]; NSLog(@"%@", object); } 为了防范对象替换攻击,设置requiresSecureCoding为YES是很重要的，这样如果根对象类没有遵从<NSSecureCoding>，就会抛出一个异常。欲了解更多信息，请参阅[NSHipster article on NSSecureCoding]。StreamsStreams 使用 -startStreamWithName:toPeer:创建：NSOutputStream *outputStream = [session startStreamWithName:name toPeer:peer]; stream.delegate = self; [stream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode]; [stream open]; // ... Streams通过MCSessionDelegate的方法session:didReceiveStream:withName:fromPeer:来接收：#pragma mark - MCSessionDelegate - (void)session:(MCSession *)session didReceiveStream:(NSInputStream *)stream withName:(NSString *)streamName fromPeer:(MCPeerID *)peerID { stream.delegate = self; [stream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode]; [stream open]; } 输入和输出的streams必须安排好并打开，然后才能使用它们。一旦这样做，streams就可以被读出和写入。ResourcesResources 发送使用 -sendResourceAtURL:withName:toPeer:withCompletionHandler::NSURL *fileURL = [NSURL fileURLWithPath:@"path/to/resource"]; NSProgress *progress = [self.session sendResourceAtURL:fileURL withName:[fileURL lastPathComponent] toPeer:peer withCompletionHandler:^(NSError *error) { NSLog(@"[Error] %@", error); }]; 返回的NSProgress对象可以是通过KVO(Key-Value Observed)来监视文件传输的进度，并且它提供取消传输的方法：-cancel。接收资源实现MCSessionDelegate两种方法：-session:didStartReceivingResourceWithName:fromPeer:withProgress: 和 -session:didFinishReceivingResourceWithName:fromPeer:atURL:withError:#pragma mark - MCSessionDelegate - (void)session:(MCSession *)session didStartReceivingResourceWithName:(NSString *)resourceName fromPeer:(MCPeerID *)peerID withProgress:(NSProgress *)progress { // ... } - (void)session:(MCSession *)session didFinishReceivingResourceWithName:(NSString *)resourceName fromPeer:(MCPeerID *)peerID atURL:(NSURL *)localURL withError:(NSError *)error { NSURL *destinationURL = [NSURL fileURLWithPath:@"/path/to/destination"]; NSError *error = nil; if (![[NSFileManager defaultManager] moveItemAtURL:localURL toURL:destinationURL error:&error]) { NSLog(@"[Error] %@", error); } } 再次说明，在传输期间NSProgress parameter in -session:didStartReceivingResourceWithName:fromPeer:withProgress:允许接收节点来监控文件传输进度。在-session:didFinishReceivingResourceWithName:fromPeer:atURL:withError:中,delegate的责任是从临时localURL移动文件至永久位置。Multipeer是突破性的API，其价值才刚刚开始被理解。虽然完整的支持功能比如AirDrop目前仅限于最新的设备，你应该会看到它将成为让所有人盼望的功能。

stream read error流读取错误stream[英][stri:m][美][strim]n.河流，小河，川，溪; 潮流，趋势，倾向; （事件等的）连续，（财富等的）滚滚而来; 流出，流注，一连串; vt.& vi.流，流动; vi.飘扬; 招展; 鱼贯而行; 一个接一个地移动; vt.按能力分班（或分组）; 按能力分班（或分组）; 第三人称单数：streams过去分词：streamed复数：streams现在进行时：streaming过去式：streamed易混淆单词：Stream例句:A nearby stream supplies fresh drinking water. 附近的一条小溪供应新鲜的饮用水

How to setup Oracle Streams Bi-Directionalhttp://www.askmaclean.com/archives/how-setup-oracle-bi-directional-streams.html

—— 英文：Only User Streams running 仅用户流在运行。

河湖纵横交错，汇织成网。

Along the banks of the stream wandered a countless multitude . 沿河两岸数不尽的人群在漫游。 From the gorge came the noise of the stream in the boulders . 峡谷里传来溪水流过圆石间的淙淙声。 The noise of the stream could not drown the discussion with a turbulence . 涛声掩盖不住激烈的争论。 The genesis of valley deposits is intimately associated with the history of the stream by which they were formed . 河谷沉积物的成因实质上与河流形成的历史相联系。 It is across this open country, down into the next valley and above the timber at the head of the stream . 穿过这片空地，走下前面那个山谷，到这小溪源头那片树林高处就是。 The sinuosity or sinuosity ratio of a stream is expressed as the ratio of the length along the center pne of the stream to the length along the valley . 一条河流的弯曲率或弯曲比，是以沿该河中心线与沿其河谷长度之比来表示的。 Or - 1 if at the end of the stream 的无符号字节，或者如果到达流的末尾，则为- 1 。 Don " t change horses in the middle of the stream 不要在艰难的征途当中换人马。 Reads the remainder of the stream and returns it as a 读取流的其余部分，并以 Or - 1 if reading from the end of the stream 的字节，或者如果从流的末尾读取则为- 1 。 The contents of the stream and the input buffer of the 对象的流和输入缓冲区的内容。 Numerical analysis of the streaming potential in bone tissue 骨组织流动电势数值分析 The new size of the stream as a number of bytes 流的新大小以字节数表示。 A pointer to the internal data of the stream object 一个指向流对象的内部数据的指针。 A long value representing the length of the stream in bytes 用字节表示流长度的长值。 Specifies the new size of the stream as a number of bytes 将流的新大小指定为字节数。 The length of the stream data can be obtained from the 流数据的长度可以从 Value is larger than the maximum size of the stream 值大于流的最大大小。 Seeking is attempted before the beginning of the stream 试图在流的开始位置之前查找。 The current position is larger than the capacity of the stream 当前位置大于流的容量。 Method will return zero only if the end of the stream is reached 仅当到达流的末尾时， That indicates the state of the stream during seriapzation 在序列化期间指示流的状态的 Only one of the streams in this area ever panned out 这个地区只有一条河曾经淘出过金。 Streams will only return zero at the end of the stream 流仅在到达流的结尾处时才返回零。 Sets the current position of the stream to the given value 将流的当前位置设置为给定值。 Value that specifies the length of the stream 值，该值指定流的长度。 A pointer to the internal buffer of the stream object 一个指向流对象的内部缓冲区的指针。 Or - 1 if the end of the stream has been reached 的字节；或者如果已到达流的末尾，则为- 1 。 Method , instead , put all of the stream cleanup logic in the 方法，而应将所有流清理逻辑放入 The noise of the stream had a pleasantly somnolent effect 小河潺潺的流水声有宜人的催眠效果An attempt was made to seek before the beginning of the stream 尝试在流的开始位置之前查找。 Gets the length in bytes of the stream 获取用字节表示的流长度。 The noise of the stream have a pleasantly somnolent effect 小河潺潺的流水声有宜人的催眠效果。 Gets the length of the stream in bytes 获取用字节表示的流长度。 She lay on the bank , pstening to the ripple of the stream 她躺在河岸上,听著小河的潺潺流水声。 The mystic token apghted on the hither verge of the stream 那神秘的标志落在离小溪不远的地方。 Or returns - 1 if reading from the end of the stream 的该字节；或者如果从流的末尾读取则返回- 1 。 She pe on the bank , pstening to the ripple of the stream 她躺在河岸上，听著小河的潺潺流水声。 Stabipzation of the stream bank and streambed 稳定河岸和河床 Specifies the size in bytes of the stream or byte array 指定流或字节数组的大小（以字节为单位） 。 The length of the stream in bytes 流的长度（以字节为单位） 。 The end of the stream is reached before 之前到达了流的末尾。 Specifies the size , in bytes , of the stream or byte array 指定流或字节数组的大小（以字节为单位） 。 Changes the size of the stream object 更改流对象的大小。 If the current stream position is at the end of the stream ; otherwise 如果当前的流位置在流的末尾，则为 The apppcation of the streaming media technology in the higher education 流媒体技术在高等教育中的应用 Is larger than the current length of the stream , the stream is expanded 大于流的当前长度，则流被扩展。 Changes the configuration of the stream - -变更流的配置 The water quapty of the stream used to be excellent and crystal clear 以往的东涌河水质优良，河水清澈。 Keep us out into the centre of the stream or we " ll run us aground 把船开到河中心去，否则我们就要搁浅了。 推荐阅读： 苗族节日：开年节（中国传统节日） 我国很早就有了穿木屐的相关记载，例如东晋诗人谢灵运发明的“谢公屐”，它在当时的用途是： 作家＂地名说＂、＂歌谣说＂力证嫦娥故乡在湖南岳阳

streams.h 写错了 iostream.h

刚开始学习这一块的内容。请指教

需要pdfbox和log4j的包举个例子：import org.pdfbox.pdfparser.*;import org.pdfbox.util.PDFTextStripper;import java.io.*;/** * 测试pdfbox * @author kingfish * @version 1.0 */public class TestPdf { public static void main(String[] args) throws Exception{ FileInputStream fis = new FileInputStream("c://intro.pdf"); PDFParser p = new PDFParser(fis); p.parse(); PDFTextStripper ts = new PDFTextStripper(); String s = ts.getText(p.getPDDocument()); System.out.println(s); fis.close(); }}--------------------------------------------------------------------------------import java.io.*;import java.util.*;import com.etymon.pj.*;import com.etymon.pj.object.*;import com.etymon.pj.exception.*;/*** This is a wrapper for the Pj PDF parser*/public class PjWrapper {Pdf pdf;PjCatalog catalog;PjPagesNode rootPage;public PjWrapper(String PdfFileName,String TextFileName)throwsIOException, PjException {pdf = new Pdf(PdfFileName);// hopefully the catalog can never be a reference...catalog = (PjCatalog) pdf.getObject(pdf.getCatalog());// root node of pages tree is specified by a reference in the catalogrootPage = (PjPagesNode) pdf.resolve(catalog.getPages());}public static void main (String [] args) throws IOException, PjException{/*PjWrapper testWrapper = new PjWrapper(args[0]);LinkedList textList = testWrapper.getAllText();*/}/*** Returns as much text as we can extract from the PDF.* This currently includes:** NOTE: Pj does not support LZW, so some text in some PDF"s may not* be indexable*/public LinkedList getAllText() throws PjException {LinkedList stringList = new LinkedList();Iterator streamIter = getAllContentsStreams().iterator();PjStream stream;String streamData;String streamText;boolean moreData;int textStart, textEnd;//System.out.println("Going through streams...");while(streamIter.hasNext()) {//System.out.println("Getting next stream");stream = (PjStream) streamIter.next();//System.out.println("Adding text from stream with filter: "+getFilterString(stream);stream = stream.flateDecompress();//System.out.println("Adding text from stream with filterafterdecompress: " + getFilterString(stream));streamData = new String(stream.getBuffer());streamText = new String();moreData = true;textStart = textEnd = 0;while(moreData) {if ((textStart = streamData.indexOf("(", textEnd + 1)) < 0) {moreData = false;break;}if ((textEnd = streamData.indexOf(")", textStart + 1)) < 0) {moreData = false;break;}try {streamText +=PjString.decodePdf(streamData.substring(textStart,textEnd + 1));} catch (Exception e) {System.out.println("malformed string: " +streamData.substring(textStart, textEnd + 1));}}//if(streamText.equals("inserted text"))System.out.println(streamText);if (streamText.length() > 0)stringList.add(streamText);}return stringList;}public static String getFilterString(PjStream stream) throws PjException{String filterString = new String();PjObject filter;//System.out.println("getting filter from dictionary");if ((filter = stream.getStreamDictionary().getFilter()) == null) {//System.out.println("Got null filter");return "";}//System.out.println("got it");// filter should either be a name or an array of namesif (filter instanceof PjName) {//System.out.println("getting filter string from simple name");filterString = ((PjName) filter).getString();} else {//System.out.println("getting filter string from array of names");Iterator nameIter;Vector nameVector;if ((nameVector = ((PjArray) filter).getVector()) == null) {//System.out.println("got null vector for list of names");return "";}nameIter = nameVector.iterator();while (nameIter.hasNext()) {filterString += ((PjName) nameIter.next()).getString();if (nameIter.hasNext())filterString += " ";}}//System.out.println("got filter string");return filterString;}/*** Performs a post-order traversal of the pages tree* from the root node and gets all of the contents streams* @returns a list of all the contents of all the pages*/public LinkedList getAllContentsStreams() throwsInvalidPdfObjectException {return getContentsStreams(getAllPages());}/*** Get contents streams from the list of PjPage objects* @returns a list of all the contents of the pages*/public LinkedList getContentsStreams(LinkedList pages) throwsInvalidPdfObjectException {LinkedList streams = new LinkedList();Iterator pageIter = pages.iterator();PjObject contents;while(pageIter.hasNext()) {contents = pdf.resolve(((PjPage)pageIter.next()).getContents());// should only be a stream or an array of streams (or refs tostreams)if (contents instanceof PjStream)streams.add(contents);else{Iterator streamsIter = ((PjArray)contents).getVector().iterator();while(streamsIter.hasNext())streams.add(pdf.resolve((PjObject)streamsIter.next()));}}return streams ;}/*** Performs a post-order traversal of the pages tree* from the root node.* @returns a list of all the PjPage objects*/public LinkedList getAllPages() throws InvalidPdfObjectException {LinkedList pages = new LinkedList();getPages(rootPage, pages);return pages;}/*** Performs a post-order traversal of the pages tree* from the node passed to it.* @returns a list of all the PjPage objects under node*/public void getPages(PjObject node, LinkedList pages) throwsInvalidPdfObjectException {PjPagesNode pageNode = null;// let"s hope pdf"s don"t have pointers to pointersif (node instanceof PjReference)pageNode = (PjPagesNode) pdf.resolve(node);elsepageNode = (PjPagesNode) node;if (pageNode instanceof PjPage) {pages.add(pageNode);return;}// kids better be an array and not a reference to oneIterator kidIterator = ((PjArray) ((PjPages)pageNode).getKids()).getVector().iterator();while(kidIterator.hasNext()) {getPages((PjObject) kidIterator.next(), pages);}}public Pdf getPdf() {return pdf;}}

Each color should be in full bloomDon"t let the sun behind only black and whiteEveryone has a right to expectLove on the palm of the hand with me.This is the best futureWe make the perfect present with loveThousands of streams into the seaEach flower as the surging wavesEach dream is worth irrigationTears into rain will fallEvery child should be lovedThey are our futureThis is the best futureWe make the perfect present with loveThousands of streams into the seaEach flower as the surging wavesThis is the best futureRegardless of you and me be deeply attached to each other each otherNumerous hills and streams convey careHappiness and love.Each dream is worth irrigationTears into rain will fallEvery child should be lovedThey are our futureThe same correlation with under the skyThis is the best for the future每种色彩都应该盛开 别让阳光背后只剩下黑白 每一个人都有权利期待 爱放在手心跟我来 这是最好的未来 我们用爱筑造完美现在 千万溪流汇聚成大海 每朵浪花一样澎湃 每个梦想都值得灌溉 眼泪变成雨水就能落下来 每个孩子都应该被宠爱 他们是我们的未来 这是最好的未来 我们用爱筑造完美现在 千万溪流汇聚成大海 每朵浪花一样澎湃 这是最好的未来 不分你我彼此相亲相爱 千山万水传递着关怀 幸福永远与爱同在 每个梦想都值得灌溉 眼泪变成雨水就能落下来 每个孩子都应该被宠爱 他们是我们的未来 同一天空底下相关怀 这就是最好的未来

　　Oracle中的传输表空间功能 用来将一个实例中的表空间和数据文件移到另一个实例中 执行起来方便 快捷 但是要使用该功能有一些限制 需要两个平台一致 必须有相同的字符集和多语言字符集 　　要求两个实例的db block size 大小相等 如不相等则需要兼容 以上等 　　具体步骤如下 　　SQL> example表空间试验 SQL> connect sys/system as sysdba Connected to Oracle Database g Enterprise Edition Release Connected as SYS SQL> execute dbms_tts transport_set_check( EXAMPLE TRUE); PL/SQL procedure successfully pleted SQL> SELECT * FROM TRANSPORT_SET_VIOLATIONS; VIOLATIONS SQL> 如果上面的查询可以查到记录 则说明不适合表空间传输条件 需要根据实际 SQL> 情况将对象移到别的表空间; SQL> C:Documents and Settingshawk>exp userid= sys/system as sysdba transport_table space=y tablespaces=EXAMPLE file = d:a dmp ; Export: Release Production on 星期三 月 : : Copyright (c) Oracle All rights reserved 　　 　　连接到: Oracle Database g Enterprise Edition Release Production 　　With the Partitioning OLAP and Data Mining options 　　已导出 ZHS GBK 字符集和 AL UTF NCHAR 字符集 　　注: 将不导出表数据 (行) 　　即将导出可传输的表空间元数据 　　对于表空间 EXAMPLE 　　 　　 正在导出簇定义 正在导出表定义 正在导出表 REGIONS 正在导出表 COUNTRIES 正在导出表 LOCATIONS 正在导出表 DEPARTMENTS 正在导出表 JOBS 正在导出表 EMPLOYEES 正在导出表 JOB_HISTORY 正在导出表 CUSTOMERS 正在导出表 WAREHOUSES 正在导出表 ORDER_ITEMS 正在导出表 ORDERS 正在导出表 INVENTORIES 正在导出表 PRODUCT_INFORMATION 正在导出表 PRODUCT_DESCRIPTIONS 正在导出表 PROMOTIONS 正在导出表 ORDERS_QUEUETABLE 正在导出表 AQ$_ORDERS_QUEUETABLE_S 正在导出表 AQ$_ORDERS_QUEUETABLE_T 正在导出表 AQ$_ORDERS_QUEUETABLE_H 正在导出表 AQ$_ORDERS_QUEUETABLE_G 正在导出表 AQ$_ORDERS_QUEUETABLE_I 正在导出表 STREAMS_QUEUE_TABLE 正在导出表 AQ$_STREAMS_QUEUE_TABLE_S 正在导出表 AQ$_STREAMS_QUEUE_TABLE_T 正在导出表 AQ$_STREAMS_QUEUE_TABLE_H 正在导出表 AQ$_STREAMS_QUEUE_TABLE_G 正在导出表 AQ$_STREAMS_QUEUE_TABLE_I 正在导出表 TIMES 正在导出表 PRODUCTS 正在导出表 CHANNELS 正在导出表 PROMOTIONS 正在导出表 CUSTOMERS 正在导出表 COUNTRIES 正在导出表 SUPPLEMENTARY_DEMOGRAPHICS 正在导出表 CAL_MONTH_SALES_MV 正在导出表 FWEEK_PSCAT_SALES_MV 正在导出表 SALES 正在导出表 COSTS 正在导出表 MVIEW$_EXCEPTIONS 正在导出表 ONLINE_MEDIA 正在导出表 PRINT_MEDIA 正在导出引用完整性约束条件 正在导出触发器 结束导出可传输的表空间元数据 　　成功终止导出 没有出现警告 　　 　　 　　C:Documents and Settingshawk> C:Documents and Settingshawk> C:Documents and Settingshawk>copy D:systemora goradataora gEXAMPLE DB F d:EXAMPLE DBF 已复制 个文件 　　 　　C:Documents and Settingshawk>imp userid= sys/system as sysdba file= d:a dmp transport_tablespace=y datafiles= d:EXAMPLE DBF Import: Release Production on 星期三 月 : : Copyright (c) Oracle All rights reserved 连接到: Oracle Database g Enterprise Edition Release Production With the Partitioning OLAP and Data Mining options 　　经由常规路径由 EXPORT:V 创建的导出文件 　　即将导入可传输的表空间元数据 　　已经完成 ZHS GBK 字符集和 AL UTF NCHAR 字符集中的导入 　　 正在将 SYS 的对象导入到 SYS 　　IMP : 由于 ORACLE 错误 以下语句失败: 　　 BEGIN sys dbms_plugts beginImpTablespace( EXAMPLE SYS 　　 NULL NULL 　　 NULL); END; 　　IMP : 遇到 ORACLE 错误 　　ORA : 表空间 EXAMPLE 已存在 　　ORA : 在 SYS DBMS_PLUGTS line 　　ORA : 在 line 　　IMP : 未成功终止导入 　　 　　 因为测试是在同一个实例中进行 所以出现上面的表空间已存在错误 　　 　　SQL> alter tablespace example read write; 　　 　　Tablespace altered 　　 lishixinzhi/Article/program/Oracle/201311/18536

络绎不绝 in an endless stream

Each color should be in full bloomDon"t let the sun behind only black and whiteEveryone has a right to expectLove on the palm of the hand with me.This is the best futureWe make the perfect present with loveThousands of streams into the seaEach flower as the surging wavesEach dream is worth irrigationTears into rain will fallEvery child should be lovedThey are our futureThis is the best futureWe make the perfect present with loveThousands of streams into the seaEach flower as the surging wavesThis is the best futureRegardless of you and me be deeply attached to each other each otherNumerous hills and streams convey careHappiness and love.Each dream is worth irrigationTears into rain will fallEvery child should be lovedThey are our futureThe same correlation with under the skyThis is the best for the future每种色彩都应该盛开 别让阳光背后只剩下黑白 每一个人都有权利期待 爱放在手心跟我来 这是最好的未来 我们用爱筑造完美现在 千万溪流汇聚成大海 每朵浪花一样澎湃 每个梦想都值得灌溉 眼泪变成雨水就能落下来 每个孩子都应该被宠爱 他们是我们的未来 这是最好的未来 我们用爱筑造完美现在 千万溪流汇聚成大海 每朵浪花一样澎湃 这是最好的未来 不分你我彼此相亲相爱 千山万水传递着关怀 幸福永远与爱同在 每个梦想都值得灌溉 眼泪变成雨水就能落下来 每个孩子都应该被宠爱 他们是我们的未来 同一天空底下相关怀 这就是最好的未来

您是想说“quiet streams and trees and shade, and lazy afternoons by a pool,eating ice cream to feel cool”对吧？意思为“安静的流水，加上树木和影子，在池边度过一个慵懒的下午，吃着冰淇淋，感觉很凉爽”

public static void consumer(){Properties props = new Properties();props.put("zk.connect", "hadoop-2:2181");props.put("zk.connectiontimeout.ms", "1000000");props.put("groupid", "fans_group");// Create the connection to the clusterConsumerConfig consumerConfig = new ConsumerConfig(props);ConsumerConnector consumerConnector = Consumer.createJavaConsumerConnector(consumerConfig);Map<String, Integer> map = new HashMap<String, Integer>();map.put("fans", 1);// create 4 partitions of the stream for topic “test”, to allow 4 threads to consumeMap<String, List<KafkaStream<Message>>> topicMessageStreams = consumerConnector.createMessageStreams(map);List<KafkaStream<Message>> streams = topicMessageStreams.get("fans");// create list of 4 threads to consume from each of the partitionsExecutorService executor = Executors.newFixedThreadPool(1);long startTime = System.currentTimeMillis();// consume the messages in the threadsfor(final KafkaStream<Message> stream: streams) {executor.submit(new Runnable() {public void run() {ConsumerIterator<Message> it = stream.iterator();while (it.hasNext()){log.debug(byteBufferToString(it.next().message().payload()));}}});log.debug("use time="+(System.currentTimeMillis()-startTime));}}

streams of water flow over the areas that animals live in溪水流过动物居住的地方

科学家说，这条溪流大约有12到15英尺宽，大约300英尺或更长。

Well-being is the most beautiful places Ying Hu, Ying Hu Qing of the water very, very quiet, quiet like a mirror. Lake fish and shrimp is also the well-being is so special about the Han River and Han River"s products is very rich, we can only eat fish Han River, will be to build a house when the sand used in the Han River and Han River is the well-being of children Mother