| .. |
|
datasources
|
13d0688972
refactor(dw_base): HDFSDataSource 支持 hadoopConfig
|
2 settimane fa |
|
plugins
|
468b3bffbf
fix(datax): postgresql_writer 去 writeMode（DataX pg writer 不支持）
|
1 settimana fa |
|
__init__.py
|
8d2ade5330
feat: 项目初始化
|
2 settimane fa |
|
batch.py
|
04c3f6a119
feat(datax): 新增 batch 模块（批量展开 + 串/并行调度）
|
1 settimana fa |
|
cli.py
|
952754b4db
feat(datax): 新增 cli 模块（python -m dw_base.datax.cli gen-json）+ 单测
|
1 settimana fa |
|
datax_constants.py
|
8d2ade5330
feat: 项目初始化
|
2 settimane fa |
|
datax_utils.py
|
8d2ade5330
feat: 项目初始化
|
2 settimane fa |
|
entry.py
|
5e10a82151
feat(datax): 补齐 3 项老入口功能（阶段 print + 串行 tee / HDFS 源 check / 默认日期）+ kb/94 标 ✅
|
1 settimana fa |
|
job_config_generator.py
|
8d2ade5330
feat: 项目初始化
|
2 settimane fa |
|
mask.py
|
b791d049d9
feat(datax): 新增 mask 模块 + PG 5 典型脱敏（3 静态 + 2 动态）
|
1 settimana fa |
|
partition.py
|
5fe9c80f52
feat(datax): 新增 partition 模块（parse_ddl 搬迁 + hive ALTER 执行）
|
1 settimana fa |
|
path_utils.py
|
a40619649c
feat(datax): 新增 path_utils 模块（纯函数路径拼接）
|
1 settimana fa |
|
runner.py
|
5e10a82151
feat(datax): 补齐 3 项老入口功能（阶段 print + 串行 tee / HDFS 源 check / 默认日期）+ kb/94 标 ✅
|
1 settimana fa |
|
worker.py
|
83c918509b
feat(datax): 新增 worker 模块（workers.ini 加载 + 加权随机选）
|
1 settimana fa |
tianyu.chu
5e10a82151
feat(datax): 补齐 3 项老入口功能（阶段 print + 串行 tee / HDFS 源 check / 默认日期）+ kb/94 标 ✅