DROP TABLE IF EXISTS journal;
CREATE TABLE IF NOT EXISTS journal (
ordering SERIAL,
persistence_id VARCHAR(255) NOT NULL,
sequence_number BIGINT NOT NULL,
deleted BOOLEAN DEFAULT FALSE,
tags VARCHAR(255) DEFAULT NULL,
message BLOB NOT NULL,
PRIMARY KEY(persistence_id, sequence_number)
);
DROP TABLE IF EXISTS snapshot;
CREATE TABLE IF NOT EXISTS snapshot (
persistence_id VARCHAR(255) NOT NULL,
sequence_number BIGINT NOT NULL,
created BIGINT NOT NULL,
snapshot BLOB NOT NULL,
PRIMARY KEY (persistence_id, sequence_number)
);
没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
基于scala 、akka实现了一个简单的报表工具。该项目是个玩具项目,用于个人学习scala和akka。使用scala语言开发,基于akka-http, akka-stream,akka-cluster等新技术构建。支持多核并发,异步无阻赛 (akka)。每个用户、每张报表均作为独立的actor, 通过akka Persistence持久化各个节点的状态,并额外获得一个可自动更新的分布式缓存。对长时间未使用的节点 可以自动下线,以释放系统资源。高可用,可横向扩展至多节点。完全去中心化,无单点故障。失败可异地恢复 (akka-cluster)。使用kryo序列化消息。流控 Back-Pressure, 避免OutOfMemory(akka-stream).
资源推荐
资源详情
资源评论
收起资源包目录
biplatform-master.zip (97个子文件)
biplatform-master
.travis.yml 86B
doc
api.md 12KB
designer.png 45KB
src
universal
conf
application.ini 200B
test
resources
db.migration
V1__create_schema.sql 262B
V2__add_values.sql 69B
main
resources
akka.conf 1KB
env.conf 25B
local.conf 738B
kryo.conf 7KB
schema
mysql-schema.sql 556B
log4j.properties 310B
cluster.conf 799B
db
migration
V1__create_schema.sql 262B
V2__add_values.sql 69B
scala
akka
stream
jdbc
JdbcSettings.scala 230B
scaladsl
JDBCStream.scala 516B
impl
JDBCSource.scala 1KB
JDBCPublish.scala 4KB
com.souo.biplatform
serializer
JodaDateTimeSerializer.scala 646B
SomeSerializer.scala 470B
KryoSerializerInit.scala 357B
tools
SwaggerTools.scala 4KB
H2ShellConsole.scala 463B
H2BrowserConsole.scala 484B
queryrouter
DataRow.scala 425B
api.scala 232B
QueryBuilder.scala 1KB
ExecutionEngine.scala 267B
jdbc
JDBCEngine.scala 2KB
QueryBuilder.scala 2KB
QueryCompiler.scala 3KB
services
cube
CubeRoutes.scala 3KB
RequestParams.scala 636B
user
UserService.scala 330B
UserRuleDao.scala 1KB
UsersRouters.scala 3KB
ds
DataSourceRoutes.scala 5KB
RequestParams.scala 411B
designer
DashBoardRoutes.scala 3KB
ReportsRoutes.scala 4KB
ExecuteRoutes.scala 1KB
DesignerRoutes.scala 377B
RequestParams.scala 535B
DownLoadRoutes.scala 2KB
SystemEnv.scala 375B
Routes.scala 671B
DependencyWiring.scala 668B
common
sql
SqlDatabase.scala 2KB
DatabaseConfig.scala 1KB
api
Response.scala 568B
SessionSupport.scala 988B
CirceCodec.scala 3KB
RoutesRequestWrapper.scala 2KB
RoutesSupport.scala 2KB
DefaultTimeOut.scala 195B
util
IntParam.scala 207B
ServerConfig.scala 427B
model
User.scala 255B
report.scala 1KB
cube.scala 1KB
DashBoard.scala 126B
Swagger.scala 2KB
datasource.scala 4KB
filters.scala 630B
Session.scala 432B
package.scala 941B
HttpService.scala 2KB
system
UserNode.scala 846B
QueryRouteNode.scala 2KB
CubeNode.scala 4KB
Node.scala 2KB
cluster
ShardUsers.scala 512B
Roles.scala 113B
ClusterListen.scala 1KB
CubeNodeSingleton.scala 767B
UserNodeShard.scala 719B
DesignerActorSystem.scala 656B
ClusterMain.scala 3KB
LocalMain.scala 688B
ReportNode.scala 4KB
DashBoardManagerProxy.scala 1KB
ReportManager.scala 6KB
ReportManagerProxy.scala 1KB
DashBoardManager.scala 5KB
DataSourceNode.scala 3KB
LocalUsers.scala 1KB
DashBoardNode.scala 2KB
SleepAbleNode.scala 705B
build.sbt 4KB
.gitignore 21B
script
run.sh 213B
scalastyle-config.xml 6KB
untitled.html 518B
project
build.properties 21B
plugins.sbt 569B
Dependencies.scala 4KB
共 97 条
- 1
资源评论
Java程序员-张凯
- 粉丝: 1w+
- 资源: 7451
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- T型3电平逆变器,lcl滤波器滤波器参数计算,半导体损耗计算,逆变电感参数设计损耗计算 mathcad格式输出,方便修改 同时支持plecs损耗仿真,基于plecs的闭环仿真,电压外环,电流内环
- 毒舌(解锁版).apk
- 显示HEX、S19、Bin、VBF等其他汽车制造商特定的文件格式
- 8bit逐次逼近型SAR ADC电路设计成品 入门时期的第三款sarADC,适合新手学习等 包括电路文件和详细设计文档 smic0.18工艺,单端结构,3.3V供电 整体采样率500k,可实现基
- 操作系统实验 ucorelab4内核线程管理
- 脉冲注入法,持续注入,启动低速运行过程中注入,电感法,ipd,力矩保持,无霍尔无感方案,媲美有霍尔效果 bldc控制器方案,无刷电机 提供源码,原理图
- Matlab Simulink#直驱永磁风电机组并网仿真模型 基于永磁直驱式风机并网仿真模型 采用背靠背双PWM变流器,先整流,再逆变 不仅实现电机侧的有功、无功功率的解耦控制和转速调节,而且能实
- 157389节奏盒子地狱模式第三阶段7.apk
- 操作系统实验ucore lab3
- DG储能选址定容模型matlab 程序采用改进粒子群算法,考虑时序性得到分布式和储能的选址定容模型,程序运行可靠 这段程序是一个改进的粒子群算法,主要用于解决电力系统中的优化问题 下面我将对程序进行详
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功