《剑指大数据——Flink学习精要（Java版）》（最终修订版）.pdf
《剑指大数据——Flink学习精要（Java版）》（最终修订版）.docx
《大数据技术之Flink(Java版)》.doc
2022-06-19 09:09:43
29.55MB
为了解决大数据流式计算平台中存在计算负载波动上升，但集群无法有效应对负载变化的问题，提出了基于流网络的 Flink 平台弹性资源调度策略（FAR-Flink）。该策略首先建立流网络模型并通过构建算法计算每条边的容量值，其次通过弹性资源调度算法确定集群性能瓶颈并制定动态资源调度计划，最后通过基于数据分簇和分桶管理的状态数据迁移算法，实施调度计划并完成节点间的高效数据迁移。实验结果表明，该策略在状态数据复杂的应用场景中有较好的优化效果，在满足计算时延约束的前提下提高了集群的吞吐量，缩短了状态数据迁移的时间。由此可见，FAR-Flink策略有效提升了集群对负载波动的响应能力。
2022-06-16 11:08:22
1.54MB
1
Flink JDBC Connector 支持Oracle ， Flink 1.13.6 支持Oracle 11.2.0.4
2022-06-14 19:08:14
247KB
1
架构：flink+hbase+kafka+phoenix
项目功能：实时同步业务系统数据库数据，并做实时统计报表分析
2022-06-10 14:05:39
584KB
2022-06-02 18:07:17
41.45MB
1
flink sql读写phoenix所使用到的连接器依赖包：
flink-sql-connector-phoenix-1.14-1.0.jar
使用示例：
create table tab2(
ID STRING,
NAME STRING,
PRIMARY KEY (ID) NOT ENFORCED
)WITH(
'connector' = 'phoenix-jdbc',
'driver'='org.apache.phoenix.jdbc.PhoenixDriver',
'org.apache.flink.connector.phoenix.schema.isNamespaceMappingEnabled'='true',
'org.apache.flink.connector.phoenix.schema.mapSystemTablesToNamespace'='true',
'url' = 'jdbc:phoenix:192.168.71.00:2181/hbase',
'table-name' = 'ODS.TEST1'
)
有问题随时给我私信~
2022-06-02 14:06:06
172KB