fix spelling mistakes

This commit is contained in:
judy0131 2019-03-21 16:48:33 +08:00
parent 30a2b5c936
commit 4080568461
9 changed files with 11 additions and 10 deletions

View File

@ -14,6 +14,7 @@ class EmailClean extends ConfigurableStop{
val description: String = "Clean email format data."
val inportList: List[String] = List(PortEnum.DefaultPort.toString)
val outportList: List[String] = List(PortEnum.DefaultPort.toString)
var columnName:String=_
def perform(in: JobInputStream, out: JobOutputStream, pec: JobContext): Unit = {

View File

@ -1,4 +1,4 @@
package cn.piflow.bundle.memcache
package cn.piflow.bundle.memcached
import cn.piflow.{JobContext, JobInputStream, JobOutputStream, ProcessContext}
import cn.piflow.conf.{ConfigurableStop, PortEnum, StopGroup}

View File

@ -1,4 +1,4 @@
package cn.piflow.bundle.memcache
package cn.piflow.bundle.memcached
import cn.piflow.{JobContext, JobInputStream, JobOutputStream, ProcessContext}
import cn.piflow.conf.{ConfigurableStop, PortEnum, StopGroup}

View File

@ -1,4 +1,4 @@
package cn.piflow.bundle.memcache
package cn.piflow.bundle.memcached
import cn.piflow.{JobContext, JobInputStream, JobOutputStream, ProcessContext}
import cn.piflow.conf.{ConfigurableStop, PortEnum, StopGroup}

View File

@ -17,13 +17,13 @@ object StopGroup {
val RedisGroup = "Redis"
val SolrGroup = "Solr"
val ESGroup = "ElasticSearch"
val MLGroup = "Mechine Learning"
val MLGroup = "Machine Learning"
val RDFGroup = "RDF"
val HdfsGroup = "Hdfs"
val MicroorganismGroup = "Microorganism"
val MicroorganismGroup = "BioInformatics"
val Spider = "Spider"
val Mongodb = "MongoDB"
val Memcache = "Memcache"
val Memcache = "Memcached"
val GraphX = "GraphX"
val ExcelGroup = "Excel"
val HbaseGroup = "Hbase"

View File

@ -1,4 +1,4 @@
package cn.piflow.bundle.memcache
package cn.piflow.bundle.memcached
import cn.piflow.Runner
import cn.piflow.conf.bean.FlowBean

View File

@ -1,4 +1,4 @@
package cn.piflow.bundle.memcache
package cn.piflow.bundle.memcached
import cn.piflow.Runner
import cn.piflow.conf.bean.FlowBean

View File

@ -1,4 +1,4 @@
package cn.piflow.bundle.memcache
package cn.piflow.bundle.memcached
import cn.piflow.Runner
import cn.piflow.conf.bean.FlowBean

View File

@ -9,7 +9,7 @@ import org.h2.tools.Server
object H2Util {
val QUERY_TIME = 30
val QUERY_TIME = 300
val CREATE_FLOW_TABLE = "create table if not exists flow (id varchar(255), pid varchar(255), name varchar(255), state varchar(255), startTime varchar(255), endTime varchar(255))"
val CREATE_STOP_TABLE = "create table if not exists stop (flowId varchar(255), name varchar(255), state varchar(255), startTime varchar(255), endTime varchar(255))"
val CREATE_THOUGHPUT_TABLE = "create table if not exists thoughput (flowId varchar(255), stopName varchar(255), portName varchar(255), count long)"