diff options
| author | Anil Kumar Batchu <akumarb2010@gmail.com> | 2017-11-27 18:44:55 -0800 |
|---|---|---|
| committer | Arina Ielchiieva <arina.yelchiyeva@gmail.com> | 2017-11-28 11:27:18 +0200 |
| commit | d3f8da2b62b13be28c4133980067942cec2a5faf (patch) | |
| tree | 1e30b03ad2f0fe1f4c0a20ed3d8225e61cbcd2e5 /protocol | |
| parent | 05d8b3c2c078c5cf89fcbe05a9a6cf555a21d303 (diff) | |
DRILL-4779: Kafka storage plugin (Kamesh Bhallamudi & Anil Kumar Batchu)
closes #1052
Diffstat (limited to 'protocol')
3 files changed, 13 insertions, 1 deletions
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. |