diff --git a/piflow-bundle/src/main/scala/cn/piflow/bundle/microorganism/BioSampleParse.scala b/piflow-bundle/src/main/scala/cn/piflow/bundle/microorganism/BioSampleParse.scala index f14bde1..d35b852 100644 --- a/piflow-bundle/src/main/scala/cn/piflow/bundle/microorganism/BioSampleParse.scala +++ b/piflow-bundle/src/main/scala/cn/piflow/bundle/microorganism/BioSampleParse.scala @@ -8,7 +8,7 @@ import java.util.regex.Pattern import cn.piflow.bundle.microorganism.util.BioProject import cn.piflow.conf.bean.PropertyDescriptor import cn.piflow.conf.util.{ImageUtil, MapUtil} -import cn.piflow.conf.{ConfigurableStop, PortEnum, StopGroupEnum} +import cn.piflow.conf.{ConfigurableStop, PortEnum, StopGroup} import cn.piflow.{JobContext, JobInputStream, JobOutputStream, ProcessContext} import org.apache.spark.sql.{Row, SparkSession} import org.elasticsearch.spark.sql.EsSparkSQL @@ -144,7 +144,7 @@ class BioSampleParse extends ConfigurableStop{ } override def getGroup(): List[String] = { - List(StopGroupEnum.MicroorganismGroup.toString) + List(StopGroup.MicroorganismGroup.toString) } def initialize(ctx: ProcessContext): Unit = { diff --git a/piflow-bundle/src/main/scala/cn/piflow/bundle/microorganism/TaxonomyParse.scala b/piflow-bundle/src/main/scala/cn/piflow/bundle/microorganism/TaxonomyParse.scala index 92c6fef..a81c5f0 100644 --- a/piflow-bundle/src/main/scala/cn/piflow/bundle/microorganism/TaxonomyParse.scala +++ b/piflow-bundle/src/main/scala/cn/piflow/bundle/microorganism/TaxonomyParse.scala @@ -4,7 +4,7 @@ import java.io._ import cn.piflow.conf.bean.PropertyDescriptor import cn.piflow.conf.util.{ImageUtil, MapUtil} -import cn.piflow.conf.{ConfigurableStop, PortEnum, StopGroupEnum} +import cn.piflow.conf.{ConfigurableStop, PortEnum, StopGroup} import cn.piflow.{JobContext, JobInputStream, JobOutputStream, ProcessContext} import org.apache.spark.sql.{DataFrame, Row, SparkSession} import org.elasticsearch.spark.sql.EsSparkSQL @@ -271,7 +271,7 @@ class TaxonomyParse extends ConfigurableStop{ } override def getGroup(): List[String] = { - List(StopGroupEnum.MicroorganismGroup.toString) + List(StopGroup.MicroorganismGroup.toString) } def initialize(ctx: ProcessContext): Unit = {