| 共 5 篇文章 |
|
-- Use this dependency if you are using the DataSet API --><dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.1.4</version></dependency><dependency> <groupId>org.apache.flink</groupId> <artifactId>fl... 阅80 转2 评0 公众公开 17-08-14 18:07 |
删除到单词的末尾（?键为Fn+Delete）?? 删除到单词的开头?+ / ?- 展开 / 折叠代码块?F1 在错误或警告处显示具体描述信息??L 格式化代码??O 优化import?? 开始新的一行??? 自动结束代码，行末自动添加分号?I 实现方法（实现接口中的方法）?F6 重命名文件或者变量?N, ??, ?N 生成代码（getter、setter、构造函数、hashCode/equals,toString）?P ... 阅35 转0 评0 公众公开 17-03-03 14:38 |
Java代码 Kryo kryo = new Kryo(); kryo.setReferences(false); kryo.setRegistrationRequired(false); kryo.setInstantiatorStrategy(new StdInstantiatorStrategy()); output.setOutputStream(new FileOutputStream("file.bin")); kryo.writeClassAndObject(output, Simple.getSimple()); output.flush();这意味着如果该类... 阅53 转0 评0 公众公开 17-01-11 21:17 |
大家已经非常熟悉这套架构，现在一般的互联网应用，互联网系统都会采用这样的分层架构，业务上分层，通过分布式中间件进行远程消息传递、远程服务调用，中间提供一层共享中心，把公共业务逻辑抽象成平台，抽象成服务中心，不直接对用户暴露接口，提供一种服务能力，中间会有缓存，底层有存储集群，这是非常常见的架构，在2008年整个架构演变到... 阅390 转2 评0 公众公开 17-01-05 20:34 |
RocketMQ大数据畅想 | 阿里中间件团队博客。为了直观地证明batch对于RocketMQ的功效，笔者在Kafka Broker做了一层代理，大致结构图如下：Kafka Broker收到Kafka Client的Batch Data后，不存储在本地，而是把消息转发到RocketMQ，等待RocketMQ返回结果后，再返回给Kafka Client。这个结果与上面关于Kafka的结果相互印证，既证明了Kakfa大数据的... 阅106 转1 评0 公众公开 17-01-05 20:34 |
