没有合适的资源?快使用搜索试试~ 我知道了~
streamer:streamer 实时计算引擎
共207个文件
java:92个
scss:26个
js:19个
需积分: 11 0 下载量 198 浏览量
2021-05-13
16:56:13
上传
评论
收藏 1.81MB ZIP 举报
温馨提示
Streamer流计算引擎 介绍 Streamer流计算引擎是一个基于Apache Calcite的实时计算框架,没有采用大家熟知的Spark和Flink,自研的Kafka消费者,来处理 Kafka的数据,实现实时计算的目的。 通过Calcite实现了Kafka和JDBC数据源的JOIN,可以很方便的把Kafka中的数据,当作一张无边界的表来使用。 特性 - 目前只支持Kafka的数据源,后面考虑支持更多。 - 支持JDBC的维度表,来实现某个维度的去重,比如某日的UV。 - 支持 Console 、JDBC 、Redis和企业微信的SINK。 用法举例 CREATE TABLE kafkaTable( context.device.did:did string, context.device.factory:factory string, context.device.
资源推荐
资源详情
资源评论
收起资源包目录
streamer:streamer 实时计算引擎 (207个子文件)
bootstrap.css 153KB
bootstrap.min.css 122KB
font-awesome.css 37KB
font-awesome.min.css 30KB
bootstrap-grid.css 28KB
bootstrap-grid.min.css 21KB
sb-admin.css 11KB
codemirror.css 8KB
dataTables.bootstrap4.css 5KB
bootstrap-reboot.css 4KB
bootstrap-reboot.min.css 4KB
fontawesome-webfont.eot 162KB
.gitignore 55B
index.html 8KB
add.html 7KB
index.html 6KB
index.html 5KB
log.html 4KB
log.html 4KB
login.html 2KB
RedisResultSet.java 32KB
RedisDatabaseMetaData.java 30KB
RedisPreparedStatement.java 15KB
StreamJobCrontroller.java 13KB
RedisConnection.java 11KB
AppServiceImpl.java 7KB
RedisInputStream.java 7KB
WorkwechatSink.java 7KB
ExecutorCrontroller.java 6KB
JdbcSide.java 6KB
CoreUtils.java 6KB
StringFunctions.java 6KB
RedisStatement.java 6KB
RedisCommand.java 5KB
KafkaStreamBroker.java 5KB
InsertSqlParser.java 5KB
StreamerApplication.java 5KB
WorkerApplication.java 5KB
SlsSink.java 5KB
KafkaStreamJob.java 4KB
ConsoleConverter.java 4KB
JdbcSink.java 4KB
AbstractKafkaStreamFactory.java 4KB
SideTableFactory.java 4KB
PrettyTable.java 4KB
KafkaEnumerator.java 3KB
RpcServiceImpl.java 3KB
RedisResultSetMetaData.java 3KB
RedisDriver.java 3KB
WebController.java 3KB
CreateTableParser.java 2KB
CreateSideParser.java 2KB
RESPDecoder.java 2KB
SqlTree.java 2KB
PaginationView.java 2KB
KafkaMessageTable.java 2KB
TableInfo.java 2KB
LogViewer.java 2KB
CreateFuncParser.java 2KB
CreateSinkParser.java 2KB
SqlParser.java 2KB
Watcher.java 2KB
ConsoleSink.java 1KB
SideFunctionLoader.java 1KB
Spliter.java 1KB
RedisCursorResultSet.java 1KB
JdbcConnectionPool.java 1KB
ScalarFunctionLoader.java 1KB
AppService.java 1KB
JsonParser.java 1KB
PaginationIndex.java 1KB
SessionInterceptor.java 1KB
StreamerConstant.java 1KB
KafkaMessage.java 1KB
RedisSocketIO.java 1KB
Watcher.java 1KB
RedisCommandProcessor.java 981B
JsonFunctions.java 972B
RedisAbstractStatement.java 933B
TimeFunctions.java 809B
RedisScanResponse.java 749B
WebUtils.java 692B
TableColumn.java 683B
JobSatus.java 630B
PlainConsoleConverter.java 628B
RedisArrayResponse.java 614B
Row.java 607B
StreamerSinkFactory.java 606B
ApiResponse.java 603B
StreamerRole.java 600B
StreamerEnvironment.java 597B
LocalServiceImpl.java 552B
RedisSimpleResponse.java 538B
SideType.java 483B
PaginationResult.java 456B
RedisShutdownResponse.java 444B
IParser.java 339B
RpcService.java 310B
StreammerException.java 307B
BaseSink.java 285B
共 207 条
- 1
- 2
- 3
资源评论
花菌子
- 粉丝: 28
- 资源: 4578
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功