format

edp963 · Mar 6, 2019 · 4869efd · 4869efd
1 parent 69784fb
commit 4869efd
Showing 1 changed file with 2 additions and 7 deletions.
diff --git a/ums/src/main/scala/edp/wormhole/ums/UmsSchemaDefinition.scala b/ums/src/main/scala/edp/wormhole/ums/UmsSchemaDefinition.scala
@@ -170,28 +170,23 @@ object UmsProtocolType extends Enumeration {
  val DIRECTIVE_HDFSLOG_FLOW_STOP = Value("directive_hdfslog_flow_stop")
  val DIRECTIVE_ROUTER_FLOW_START = Value("directive_router_flow_start")
  val DIRECTIVE_ROUTER_FLOW_STOP = Value("directive_router_flow_stop")
+ val DIRECTIVE_UDF_ADD = Value("directive_udf_add")
 
  val FEEDBACK_DATA_BATCH_TERMINATION = Value("feedback_data_batch_termination")
  val FEEDBACK_DATA_INCREMENT_HEARTBEAT = Value("feedback_data_increment_heartbeat")
  val FEEDBACK_DATA_INCREMENT_TERMINATION = Value("feedback_data_increment_termination")
  val FEEDBACK_FLOW_START_DIRECTIVE = Value("feedback_flow_start_directive")
+ val FEEDBACK_FLINKX_FLOW_ERROR = Value("feedback_flinkx_flow_error")
 
  @Deprecated
  val FEEDBACK_DIRECTIVE = Value("feedback_directive")
  val FEEDBACK_SPARKX_FLOW_ERROR = Value("feedback_sparkx_flow_error")
  val FEEDBACK_SPARKX_FLOW_STATS = Value("feedback_sparkx_flow_stats")
-
- @Deprecated
  val FEEDBACK_FLOW_ERROR = Value("feedback_flow_error")
-
- @Deprecated
  val FEEDBACK_FLOW_STATS = Value("feedback_flow_stats")
  val FEEDBACK_STREAM_BATCH_ERROR = Value("feedback_stream_batch_error")
  val FEEDBACK_STREAM_TOPIC_OFFSET = Value("feedback_stream_topic_offset")
 
- val DIRECTIVE_UDF_ADD = Value("directive_udf_add")
-
- val FEEDBACK_FLINKX_FLOW_ERROR = Value("feedback_flinkx_flow_error")
 
  def umsProtocolType(s: String) = UmsProtocolType.withName(s.toLowerCase)
 }