文件名称:java8stream源码-io.tusk:io.tusk
文件大小:2.51MB
文件格式:ZIP
更新时间:2024-06-24 10:55:21
系统开源
java8流源码#DataStream 通过函数式编程为大数据提供动力 大数据总是很棒。 但是使用mapper、reducer组合器编写hadoop很糟糕。 为什么我们不让我们的分布式 hadoop 生活更轻松,并将权力交还给 java 开发人员? 受推特烫伤的启发, scala 是一种很好的语言,但没有被 Java 开发社区广泛采用。 Datatream 的目的是尝试利用 java8 函数式编程特性,让您的大数据生活更轻松。 数据流基于级联框架 有关详细信息,请发送电子邮件给我,因为该项目仍处于早期阶段,我需要与团队合作以使其完美。 界面打算在这里改变。 我希望我们能在几个月内发布第一个小版本 这是使数据流在本地运行的示例。 :) DataStream< StreamData > stream = builder . source( new URI ( " data/input/sample.csv " )) . build(); stream . mapTo( " county " , " OtherCountry " , x - > x + " :newData " ) . wr
【文件预览】:
io.tusk-master
----.gitignore(152B)
----README.md(1KB)
----pom.xml(2KB)
----set_jdk.sh(63B)
----LICENSE(11KB)
----src()
--------test()
--------main()
----data()
--------output()
--------input()