Merge remote-tracking branch 'origin/master'
This commit is contained in:
commit
88def74fa1
Binary file not shown.
After Width: | Height: | Size: 31 KiB |
|
@ -214,11 +214,11 @@ class spider extends ConfigurableStop{
|
|||
}
|
||||
|
||||
override def getIcon(): Array[Byte] = {
|
||||
ImageUtil.getImage("hive.jpg")
|
||||
ImageUtil.getImage("spider.jpg")
|
||||
}
|
||||
|
||||
override def getGroup(): List[String] = {
|
||||
List(StopGroupEnum.spider.toString)
|
||||
List(StopGroupEnum.Spider.toString)
|
||||
}
|
||||
|
||||
override def initialize(ctx: ProcessContext): Unit = {}
|
||||
|
|
|
@ -166,7 +166,7 @@ class ComplementByMemcache extends ConfigurableStop {
|
|||
}
|
||||
|
||||
override def getGroup(): List[String] = {
|
||||
List(StopGroupEnum.memcache.toString)
|
||||
List(StopGroupEnum.Memcache.toString)
|
||||
}
|
||||
|
||||
override def initialize(ctx: ProcessContext): Unit = {
|
||||
|
|
|
@ -164,7 +164,7 @@ class GetMemcache extends ConfigurableStop{
|
|||
}
|
||||
|
||||
override def getGroup(): List[String] = {
|
||||
List(StopGroupEnum.memcache.toString)
|
||||
List(StopGroupEnum.Memcache.toString)
|
||||
}
|
||||
|
||||
override def initialize(ctx: ProcessContext): Unit = {
|
||||
|
|
|
@ -120,7 +120,7 @@ class PutMemcache extends ConfigurableStop{
|
|||
}
|
||||
|
||||
override def getGroup(): List[String] = {
|
||||
List(StopGroupEnum.memcache.toString)
|
||||
List(StopGroupEnum.Memcache.toString)
|
||||
}
|
||||
|
||||
override def initialize(ctx: ProcessContext): Unit = { }
|
||||
|
|
|
@ -132,7 +132,7 @@ class GetMongo extends ConfigurableStop{
|
|||
}
|
||||
|
||||
override def getGroup(): List[String] = {
|
||||
List(StopGroupEnum.mongodb.toString)
|
||||
List(StopGroupEnum.Mongodb.toString)
|
||||
}
|
||||
|
||||
override def initialize(ctx: ProcessContext): Unit = { }
|
||||
|
|
|
@ -99,7 +99,7 @@ class PutMongo extends ConfigurableStop{
|
|||
}
|
||||
|
||||
override def getGroup(): List[String] = {
|
||||
List(StopGroupEnum.mongodb.toString)
|
||||
List(StopGroupEnum.Mongodb.toString)
|
||||
}
|
||||
|
||||
override def initialize(ctx: ProcessContext): Unit = { }
|
||||
|
|
|
@ -23,8 +23,8 @@ object StopGroupEnum extends Enumeration {
|
|||
val UrlGroup= Value("UrlGroup")
|
||||
val HdfsGroup= Value("HdfsGroup")
|
||||
val MicroorganismGroup= Value("MicroorganismGroup")
|
||||
val spider= Value("spider")
|
||||
val mongodb= Value("mongodb")
|
||||
val memcache= Value("memcache")
|
||||
val Spider= Value("Spider")
|
||||
val Mongodb= Value("Mongodb")
|
||||
val Memcache= Value("Memcache")
|
||||
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue