Browse Source

support datax custom config

pull/2/head
张世鸣 5 years ago
parent
commit
8c4ba3a557
  1. 35
      dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/datax/DataxParameters.java

35
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/datax/DataxParameters.java

@ -87,6 +87,22 @@ public class DataxParameters extends AbstractParameters {
*/ */
private int jobSpeedRecord; private int jobSpeedRecord;
public Integer getCustomConfig() {
return customConfig;
}
public void setCustomConfig(Integer customConfig) {
this.customConfig = customConfig;
}
public String getJson() {
return json;
}
public void setJson(String json) {
this.json = json;
}
public String getDsType() { public String getDsType() {
return dsType; return dsType;
} }
@ -167,21 +183,6 @@ public class DataxParameters extends AbstractParameters {
this.jobSpeedRecord = jobSpeedRecord; this.jobSpeedRecord = jobSpeedRecord;
} }
public Integer getCustomConfig() {
return customConfig;
}
public void setCustomConfig(Integer customConfig) {
this.customConfig = customConfig;
}
public String getJson() {
return json;
}
public void setJson(String json) {
this.json = json;
}
@Override @Override
public boolean checkParameters() { public boolean checkParameters() {
@ -203,7 +204,9 @@ public class DataxParameters extends AbstractParameters {
@Override @Override
public String toString() { public String toString() {
return "DataxParameters{" + return "DataxParameters{" +
"dsType='" + dsType + '\'' + "customConfig=" + customConfig + '\'' +
", json=" + json + '\'' +
", dsType='" + dsType + '\'' +
", dataSource=" + dataSource + ", dataSource=" + dataSource +
", dtType='" + dtType + '\'' + ", dtType='" + dtType + '\'' +
", dataTarget=" + dataTarget + ", dataTarget=" + dataTarget +

Loading…
Cancel
Save