| .. |
|
datasources
|
13d0688972
refactor(dw_base): HDFSDataSource 支持 hadoopConfig
|
3 сар өмнө |
|
plugins
|
d6622d6015
fix(datax): PG reader 加 socketTimeout+tcpKeepAlive，防连接被掐后死等
|
2 долоо хоног өмнө |
|
__init__.py
|
8d2ade5330
feat: 项目初始化
|
3 сар өмнө |
|
batch.py
|
04c3f6a119
feat(datax): 新增 batch 模块（批量展开 + 串/并行调度）
|
3 сар өмнө |
|
cli.py
|
a597c15a7a
fix(datax): json_path 加 start_date_stop_date 后缀防并发覆盖（修 raw_his_o 数据错位根因）
|
2 сар өмнө |
|
datax_constants.py
|
8d2ade5330
feat: 项目初始化
|
3 сар өмнө |
|
entry.py
|
a7ba435e51
refactor(datax): 分区 dt 改用 start_date(业务日)，与 ADR-03 raw 48h 宽窗对齐
|
3 сар өмнө |
|
job_config_generator.py
|
a523562f03
fix(datax): job.setting.speed 只留 channel，恢复多通道并发
|
2 долоо хоног өмнө |
|
mask.py
|
b791d049d9
feat(datax): 新增 mask 模块 + PG 5 典型脱敏（3 静态 + 2 动态）
|
3 сар өмнө |
|
partition.py
|
a7ba435e51
refactor(datax): 分区 dt 改用 start_date(业务日)，与 ADR-03 raw 48h 宽窗对齐
|
3 сар өмнө |
|
path_utils.py
|
a597c15a7a
fix(datax): json_path 加 start_date_stop_date 后缀防并发覆盖（修 raw_his_o 数据错位根因）
|
2 сар өмнө |
|
runner.py
|
34aecd381d
fix(datax): datax.py 显式 -Xmx6g，避免多通道 ORC 写 GC 风暴/OOM
|
2 долоо хоног өмнө |
|
tuning.py
|
453d79d56c
refactor(datax): tuning 时段基准 strict→relaxed（解决跨午夜表达问题）
|
3 сар өмнө |
|
worker.py
|
83c918509b
feat(datax): 新增 worker 模块（workers.ini 加载 + 加权随机选）
|
3 сар өмнө |
tianyu.chu
d6622d6015
fix(datax): PG reader 加 socketTimeout+tcpKeepAlive，防连接被掐后死等