From d3f8da2b62b13be28c4133980067942cec2a5faf Mon Sep 17 00:00:00 2001
From: Anil Kumar Batchu <akumarb2010@gmail.com>
Date: Mon, 27 Nov 2017 18:44:55 -0800
Subject: DRILL-4779: Kafka storage plugin (Kamesh Bhallamudi & Anil Kumar
 Batchu)

closes #1052
---
 .../src/main/java/org/apache/drill/exec/proto/UserBitShared.java | 9 +++++++++
 .../java/org/apache/drill/exec/proto/beans/CoreOperatorType.java | 4 +++-
 protocol/src/main/protobuf/UserBitShared.proto                   | 1 +
 3 files changed, 13 insertions(+), 1 deletion(-)

(limited to 'protocol')

diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/UserBitShared.java b/protocol/src/main/java/org/apache/drill/exec/proto/UserBitShared.java
index 9a3b1d942..51cdab7d3 100644
--- a/protocol/src/main/java/org/apache/drill/exec/proto/UserBitShared.java
+++ b/protocol/src/main/java/org/apache/drill/exec/proto/UserBitShared.java
@@ -517,6 +517,10 @@ public final class UserBitShared {
      * <code>PCAP_SUB_SCAN = 37;</code>
      */
     PCAP_SUB_SCAN(37, 37),
+    /**
+    * <code>KAFKA_SUB_SCAN = 38;</code>
+    */
+    KAFKA_SUB_SCAN(38, 38),
     ;
 
     /**
@@ -671,6 +675,10 @@ public final class UserBitShared {
      * <code>PCAP_SUB_SCAN = 37;</code>
      */
     public static final int PCAP_SUB_SCAN_VALUE = 37;
+    /**
+     * <code>KAFKA_SUB_SCAN = 38;</code>
+     */
+    public static final int KAFKA_SUB_SCAN_VALUE = 38;
 
 
     public final int getNumber() { return value; }
@@ -715,6 +723,7 @@ public final class UserBitShared {
         case 35: return NESTED_LOOP_JOIN;
         case 36: return AVRO_SUB_SCAN;
         case 37: return PCAP_SUB_SCAN;
+        case 38: return KAFKA_SUB_SCAN;
         default: return null;
       }
     }
diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/beans/CoreOperatorType.java b/protocol/src/main/java/org/apache/drill/exec/proto/beans/CoreOperatorType.java
index a795f5501..8ad38a588 100644
--- a/protocol/src/main/java/org/apache/drill/exec/proto/beans/CoreOperatorType.java
+++ b/protocol/src/main/java/org/apache/drill/exec/proto/beans/CoreOperatorType.java
@@ -59,7 +59,8 @@ public enum CoreOperatorType implements com.dyuproject.protostuff.EnumLite<CoreO
     WINDOW(34),
     NESTED_LOOP_JOIN(35),
     AVRO_SUB_SCAN(36),
-    PCAP_SUB_SCAN(37);
+    PCAP_SUB_SCAN(37),
+    KAFKA_SUB_SCAN(38);
     
     public final int number;
     
@@ -115,6 +116,7 @@ public enum CoreOperatorType implements com.dyuproject.protostuff.EnumLite<CoreO
             case 35: return NESTED_LOOP_JOIN;
             case 36: return AVRO_SUB_SCAN;
             case 37: return PCAP_SUB_SCAN;
+            case 38: return KAFKA_SUB_SCAN;
             default: return null;
         }
     }
diff --git a/protocol/src/main/protobuf/UserBitShared.proto b/protocol/src/main/protobuf/UserBitShared.proto
index 52b3c63ed..086b98a07 100644
--- a/protocol/src/main/protobuf/UserBitShared.proto
+++ b/protocol/src/main/protobuf/UserBitShared.proto
@@ -309,6 +309,7 @@ enum CoreOperatorType {
   NESTED_LOOP_JOIN = 35;
   AVRO_SUB_SCAN = 36;
   PCAP_SUB_SCAN = 37;
+  KAFKA_SUB_SCAN = 38;
 }
 
 /* Registry that contains list of jars, each jar contains its name and list of function signatures.
-- 
cgit v1.2.3