|
@@ -46,15 +46,13 @@ public class Mapping extends AbstractConfigModel {
|
|
|
private String metaId;
|
|
|
|
|
|
// 批量读取
|
|
|
- private int readNum = 10000;
|
|
|
+ private int readNum = 20000;
|
|
|
|
|
|
// 单次写入
|
|
|
private int batchNum = 1000;
|
|
|
|
|
|
- /**
|
|
|
- * 线程数
|
|
|
- */
|
|
|
- private int threadNum = Runtime.getRuntime().availableProcessors() * 2;
|
|
|
+ // 线程数
|
|
|
+ private int threadNum = 10;
|
|
|
|
|
|
public String getSourceConnectorId() {
|
|
|
return sourceConnectorId;
|