diff --git a/cloud-etl-server/src/main/java/com/muyu/abstracts/DataEngineValueActuator.java b/cloud-etl-server/src/main/java/com/muyu/abstracts/DataEngineValueActuator.java index aab2c67..1a9e628 100644 --- a/cloud-etl-server/src/main/java/com/muyu/abstracts/DataEngineValueActuator.java +++ b/cloud-etl-server/src/main/java/com/muyu/abstracts/DataEngineValueActuator.java @@ -20,6 +20,6 @@ public abstract class DataEngineValueActuator implements BasicEngine this.remove(); } - public abstract void run(); + public abstract DataValue run(); } diff --git a/cloud-etl-server/src/main/java/com/muyu/abstracts/PwoerEngine.java b/cloud-etl-server/src/main/java/com/muyu/abstracts/PwoerEngine.java index a6ebafd..1a66487 100644 --- a/cloud-etl-server/src/main/java/com/muyu/abstracts/PwoerEngine.java +++ b/cloud-etl-server/src/main/java/com/muyu/abstracts/PwoerEngine.java @@ -1,22 +1,20 @@ -//package com.muyu.abstracts; -//import com.muyu.abstracts.DataEngineValueActuator; -//import com.muyu.abstracts.DataValue; -// -///** -// * @Author: qdm -// * @date: 2024/09/10 09:40:42 -// * @Description: -// * @Version: 1.0 -// */ -//public class PwoerEngine extends DataEngineValueActuator{ -// @Override -// public DataValue run () { -// DataValue dataValue = get(); -// if(dataValue.getValue()==null || dataValue.getValue().equals("")){ -// System.out.println("数据为空,需要丢弃"); -// }else{ -// System.out.println("数据非空:"+dataValue.getValue()); -// } -// return dataValue; -// } -//} +package com.muyu.abstracts; + +/** + * @Author: qdm + * @date: 2024/09/10 09:40:42 + * @Description: + * @Version: 1.0 + */ +public class PwoerEngine extends DataEngineValueActuator{ + @Override + public DataValue run () { + DataValue dataValue = get(); + if(dataValue.getValue()==null || dataValue.getValue().equals("")){ + System.out.println("数据为空,需要丢弃"); + }else{ + System.out.println("数据非空:"+dataValue.getValue()); + } + return dataValue; + } +} diff --git a/cloud-etl-server/src/main/java/com/muyu/abstracts/generate.java b/cloud-etl-server/src/main/java/com/muyu/abstracts/generate.java index efa5db4..9b3aeda 100644 --- a/cloud-etl-server/src/main/java/com/muyu/abstracts/generate.java +++ b/cloud-etl-server/src/main/java/com/muyu/abstracts/generate.java @@ -3,8 +3,9 @@ package com.muyu.abstracts; public class generate extends DataEngineValueActuator { @Override - public void run() { + public DataValue run() { + return null; } } diff --git a/cloud-etl-server/src/main/java/com/muyu/engine/value/ENGINE_VALUE_VFD1000_V1.java b/cloud-etl-server/src/main/java/com/muyu/engine/value/ENGINE_VALUE_VFD1000_V1.java index 5a8bbc7..274d3bd 100644 --- a/cloud-etl-server/src/main/java/com/muyu/engine/value/ENGINE_VALUE_VFD1000_V1.java +++ b/cloud-etl-server/src/main/java/com/muyu/engine/value/ENGINE_VALUE_VFD1000_V1.java @@ -5,11 +5,12 @@ import com.muyu.abstracts.DataValue; public class ENGINE_VALUE_VFD1000_V1 extends DataEngineValueActuator { @Override - public void run() { + public DataValue run() { DataValue dataValue = get(); if (dataValue.getValue() == null) { System.out.println("数据为空"); } + return dataValue; } } diff --git a/cloud-etl-server/src/main/java/com/muyu/engine/value/ENGINE_phone_zzzzz_V9.java b/cloud-etl-server/src/main/java/com/muyu/engine/value/ENGINE_phone_zzzzz_V9.java index 705892b..9df5f00 100644 --- a/cloud-etl-server/src/main/java/com/muyu/engine/value/ENGINE_phone_zzzzz_V9.java +++ b/cloud-etl-server/src/main/java/com/muyu/engine/value/ENGINE_phone_zzzzz_V9.java @@ -5,10 +5,11 @@ import com.muyu.abstracts.DataValue; public class ENGINE_phone_zzzzz_V9 extends DataEngineValueActuator { @Override - public void run() { + public DataValue run() { DataValue dataValue = get(); if (dataValue.getValue() == null) { System.out.println("数据为空"); } + return dataValue; } }