没有合适的资源?快使用搜索试试~ 我知道了~
Freshet-Old:用于 Apache Samza 的基于 CQL 的 Clojure DSL
共116个文件
java:48个
clj:18个
md:13个
需积分: 9 0 下载量 78 浏览量
2021-06-28
13:04:27
上传
评论
收藏 7.31MB ZIP 举报
温馨提示
新鲜 用于 Apache Samza 的基于的 Clojure DSL。 Freshet 是基于 SQL [1] 扩展支持连续查询的 Kappa 架构的完整实现的第一步。 Freshet 在 Apache Samza 之上实现了 CQL 的一个子集(选择、窗口化、聚合)。 Freshet 实现了RStream和IStream关系到流运算符,基于元组和时间的滑动窗口将流转换为关系,将基本关系转换为关系运算符以实现业务逻辑。 遵循 CQL,Freshet 使用插入/删除流来模拟瞬时关系。 Freshet 查询 DSL 定义流 ( defstream wikipedia-feed ( stream-fields [ :title :string :user :string :diff-bytes :inte
资源详情
资源评论
资源推荐
收起资源包目录
Freshet-Old:用于 Apache Samza 的基于 CQL 的 Clojure DSL (116个子文件)
samza.clj 9KB
core.clj 7KB
compiler.clj 6KB
expressioneval_test.clj 4KB
helpers.clj 4KB
core.clj 3KB
config.clj 2KB
project.clj 2KB
project.clj 1KB
expressions.clj 1KB
expressions.clj 1KB
project.clj 803B
streams.clj 779B
expressiondsl_test.clj 730B
config_test.clj 710B
core.clj 708B
project.clj 689B
expresssionserde_test.clj 560B
freshet.conf 95B
wikipedia-actvities-2014-11-04T00:26:14.32.csv 52KB
wikipedia-activity-test-data.csv 52KB
wikipedia-actvities-2014-11-04T00:24:19.1.csv 2KB
fshell 918B
.gitignore 169B
.gitignore 84B
.gitignore 84B
.gitignore 65B
.gitmodules 0B
grid 7KB
WikipediaActivityFeed.java 13KB
WikipediaFeed.java 10KB
ExpressionEvaluator.java 8KB
WindowOperator.java 7KB
FreshetOperator.java 5KB
KafkaMonitor.java 4KB
KVStorageBackedEvictingQueue.java 4KB
WikipediaFeedStreamTask.java 4KB
Constants.java 4KB
GroupByOperator.java 4KB
SelectOperator.java 3KB
StreamElement.java 3KB
WikipediaConsumer.java 3KB
DeserializeOperator.java 3KB
Expression.java 3KB
ExpressionSerde.java 2KB
AggregateOperator.java 2KB
AvroSerde.java 2KB
ParseWikipediaActivity.java 2KB
WikipediaSystemFactory.java 2KB
AggregateFunctionFactory.java 2KB
AvroSerdeFactory.java 2KB
StreamDefinition.java 2KB
StreamElementSerde.java 1KB
QueueNodeSerde.java 1KB
Sum.java 1KB
Average.java 1KB
Count.java 1KB
QueueNodeSerdeFactory.java 1KB
Max.java 1KB
Min.java 1KB
QueueNode.java 1KB
FreshetException.java 1KB
StreamElementSerdeFactory.java 1KB
RStreamOperator.java 1KB
IStreamOperator.java 1KB
ProjectOperator.java 1KB
AggregateFunction.java 1KB
Utilities.java 896B
PredicateType.java 824B
MaterializeOperator.java 783B
FreshetOperatorType.java 770B
AggregateType.java 758B
ExpressionType.java 741B
OperatorType.java 734B
ExpressionEvaluationTestUtils.java 694B
Constants.java 674B
package-info.java 639B
where-as-json.json 251B
LICENSE 11KB
LICENSE 11KB
LICENSE 11KB
LICENSE 11KB
notes.md 3KB
query-lang-data-models-papers.md 3KB
cql-to-samza.md 2KB
README.md 2KB
samples.md 904B
shell-design.md 536B
wikipedia-activity-collector.md 378B
README.md 284B
README.md 239B
README.md 235B
intro.md 111B
intro.md 110B
intro.md 109B
secret_vldbj13.pdf 2.69MB
art%3A10.1007%2Fs002360050095.pdf 590KB
bockermann_2014b.pdf 527KB
sacmat68-xing.pdf 2.14MB
rc25401.pdf 706KB
共 116 条
- 1
- 2
MaDaniel
- 粉丝: 688
- 资源: 4571
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- python爱心代码高级.txt
- Yolo for Android 和 iOS - 用 Kotlin 和 Swift 编写的实时移动深度学习对象检测.zip
- Yolnp 是一个基于 YOLO 检测车牌的项目.zip
- Unity Barracuda 上的 Tiny YOLOv2.zip
- Ultralytics YOLO iOS App 源代码可用于在你自己的 iOS 应用中运行 YOLOv8.zip
- 各种(西佳佳)小游戏 ≈ 代码
- Tensorrt YOLOv8 的简单实现.zip
- TensorFlow 中空间不变注意、推断、重复 (SPAIR) 的原始实现 .zip
- Tensorflow 中的 Tiny YOLOv2 变得简单!.zip
- 8ba1f8ab2c896fd7d5c62d0e5e9ecf46.JPG
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功
评论0