goldData Parse

This commit is contained in:
yanggang 2018-11-22 19:28:08 +08:00
parent f8f34a4cee
commit 95316d516d
1 changed files with 4 additions and 4 deletions

View File

@ -58,10 +58,10 @@ class GoldDataParse extends ConfigurableStop{
override def getPropertyDescriptor(): List[PropertyDescriptor] = { override def getPropertyDescriptor(): List[PropertyDescriptor] = {
var descriptor : List[PropertyDescriptor] = List() var descriptor : List[PropertyDescriptor] = List()
val es_nodes = new PropertyDescriptor().name("es_nodes").displayName("REDIS_HOST").defaultValue("").required(true) val es_nodes = new PropertyDescriptor().name("es_nodes").displayName("es_nodes").defaultValue("").required(true)
val port = new PropertyDescriptor().name("port").displayName("PORT").defaultValue("").required(true) val port = new PropertyDescriptor().name("port").displayName("port").defaultValue("").required(true)
val es_index = new PropertyDescriptor().name("es_index").displayName("ES_INDEX").defaultValue("").required(true) val es_index = new PropertyDescriptor().name("es_index").displayName("es_index").defaultValue("").required(true)
val es_type = new PropertyDescriptor().name("es_type").displayName("ES_TYPE").defaultValue("").required(true) val es_type = new PropertyDescriptor().name("es_type").displayName("es_type").defaultValue("").required(true)
descriptor = es_nodes :: descriptor descriptor = es_nodes :: descriptor