没有合适的资源?快使用搜索试试~ 我知道了~
Freshet-Old:用于 Apache Samza 的基于 CQL 的 Clojure DSL
共116个文件
java:48个
clj:18个
md:13个
需积分: 9 0 下载量 147 浏览量
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-activity-test-data.csv 52KB
wikipedia-actvities-2014-11-04T00:26:14.32.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
IStreamOperator.java 1KB
RStreamOperator.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
- 粉丝: 816
- 资源: 4571
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- catia使用VB进行二次开发的帮助文件,可以用于查询开发的api.zip
- PYTHON神经网络实现鸢尾花分类.zip
- 基于Visual C++(VC)开发的演示程序,主要针对DTU(Data Transfer Unit,数据传输单元)进行模拟测试.rar
- 基于VaadinFlow+SpringBoot的宿舍管理系统.zip
- 用于三菱PLC与INTOUCH之间通过以太往模块进行通讯,简单便捷.zip
- 枝切法相位解缠matlab代码包括了预处理函数、枝切图构建、路径搜索、代价计算、剪枝和验证等模块.zip
- PressUG V6.1 汽车模设计插件(REV015)_20171114.rar
- 朗科u208修复工具(专用).rar
- 娃娃机STM32F103+UCOSIII移植+PS2遥控.rar
- pfc5.0 2D 法向力循环加卸载,切向力循环加卸载,监测裂纹数量,裂纹长度,能量
- 经典CCD的对位方法的教程PPT
- 基于matlab的FFT滤波,可以实现对simulink模型中示波器的波形数据或者外部mat数据、csv数据进行谐波分析(FFT)和自定义频段清除,对已有数据特定频段的数据进行提取也可以 优点是滤波
- 单相桥式全控整流电路仿真实验报告
- 第六组供应链大报告.docx
- GAMS:代码采样鲁棒无功优化算法代码 2测试系统为IEEE39节点系统,编程平台MATLAB+GAMS 3方法可迁移,用在别的不确定性优化问题
- 全自动贴标签检测(sw18可编辑+bom)全套技术资料100%好用.zip
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功
评论0