From a4e92c03e782cfa7005b56d13f35dd461ac99e19 Mon Sep 17 00:00:00 2001
From: chaoc <liangchao@geedgenetworks.com>
Date: Mon, 14 Aug 2023 10:50:02 +0800
Subject: [PATCH] style: use enum type

---
 .../java/com/zdjizhi/flink/voip/functions/DoNothingSink.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/it/java/com/zdjizhi/flink/voip/functions/DoNothingSink.java b/src/it/java/com/zdjizhi/flink/voip/functions/DoNothingSink.java
index 6877f83..6a6e573 100644
--- a/src/it/java/com/zdjizhi/flink/voip/functions/DoNothingSink.java
+++ b/src/it/java/com/zdjizhi/flink/voip/functions/DoNothingSink.java
@@ -1,7 +1,6 @@
 package com.zdjizhi.flink.voip.functions;
 
 import com.zdjizhi.flink.voip.records.Record;
-import com.zdjizhi.flink.voip.records.SchemaType;
 import org.apache.flink.api.common.functions.RuntimeContext;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.metrics.MeterView;
@@ -31,7 +30,7 @@ public class DoNothingSink extends RichSinkFunction<ObjectNode> {
     @Override
     public void invoke(ObjectNode obj, Context context) throws Exception {
         Record record = new Record(obj);
-        switch (SchemaType.of(record.getSchemaType())) {
+        switch (record.getSchemaType()) {
             case RTP:
                 numRTPRecordsPreSecond.markEvent();
                 break;