TreeData
/
cloud-etl-engine
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

--9--10

master
Qin Dong Ming 2024-09-10 10:24:28 +08:00
parent 8189b22dc1
commit 56aa6fcf57
5 changed files with 27 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cloud-etl-server/src/main/java/com/muyu/abstracts/DataEngineValueActuator.java
View File

@ -20,6 +20,6 @@ public abstract class DataEngineValueActuator implements BasicEngine<DataValue>
this.remove(); this.remove();
} }
public abstract void run(); public abstract DataValue run();
} }

42
cloud-etl-server/src/main/java/com/muyu/abstracts/PwoerEngine.java
View File

@ -1,22 +1,20 @@
//package com.muyu.abstracts; package com.muyu.abstracts;
//import com.muyu.abstracts.DataEngineValueActuator;
//import com.muyu.abstracts.DataValue; /**
// * @Author: qdm
///** * @date: 2024/09/10 09:40:42
// * @Author: qdm * @Description:
// * @date: 2024/09/10 09:40:42 * @Version: 1.0
// * @Description: */
// * @Version: 1.0 public class PwoerEngine extends DataEngineValueActuator{
// */ @Override
//public class PwoerEngine extends DataEngineValueActuator{ public DataValue run () {
// @Override DataValue dataValue = get();
// public DataValue run () { if(dataValue.getValue()==null || dataValue.getValue().equals("")){
// DataValue dataValue = get(); System.out.println("数据为空,需要丢弃");
// if(dataValue.getValue()==null || dataValue.getValue().equals("")){ }else{
// System.out.println("数据为空,需要丢弃"); System.out.println("数据非空："+dataValue.getValue());
// }else{ }
// System.out.println("数据非空："+dataValue.getValue()); return dataValue;
// } }
// return dataValue; }
// }
//}

3
cloud-etl-server/src/main/java/com/muyu/abstracts/generate.java
View File

@ -3,8 +3,9 @@ package com.muyu.abstracts;
public class generate extends DataEngineValueActuator { public class generate extends DataEngineValueActuator {
@Override @Override
public void run() { public DataValue run() {
return null;
} }
} }

3
cloud-etl-server/src/main/java/com/muyu/engine/value/ENGINE_VALUE_VFD1000_V1.java
View File

@ -5,11 +5,12 @@ import com.muyu.abstracts.DataValue;
public class ENGINE_VALUE_VFD1000_V1 extends DataEngineValueActuator { public class ENGINE_VALUE_VFD1000_V1 extends DataEngineValueActuator {
@Override @Override
public void run() { public DataValue run() {
DataValue dataValue = get(); DataValue dataValue = get();
if (dataValue.getValue() == null) { if (dataValue.getValue() == null) {
System.out.println("数据为空"); System.out.println("数据为空");
} }
return dataValue;
} }
} }

3
cloud-etl-server/src/main/java/com/muyu/engine/value/ENGINE_phone_zzzzz_V9.java
View File

@ -5,10 +5,11 @@ import com.muyu.abstracts.DataValue;
public class ENGINE_phone_zzzzz_V9 extends DataEngineValueActuator { public class ENGINE_phone_zzzzz_V9 extends DataEngineValueActuator {
@Override @Override
public void run() { public DataValue run() {
DataValue dataValue = get(); DataValue dataValue = get();
if (dataValue.getValue() == null) { if (dataValue.getValue() == null) {
System.out.println("数据为空"); System.out.println("数据为空");
} }
return dataValue;
} }
} }