Added missing cql type

priyanshu-ctds · priyanshu-ctds · commit 40d446b7260a · 2025-12-23T12:40:14.000+05:30
diff --git a/connector/src/main/java/com/datastax/oss/pulsar/source/converters/AbstractGenericConverter.java b/connector/src/main/java/com/datastax/oss/pulsar/source/converters/AbstractGenericConverter.java
@@ -100,6 +100,7 @@ public boolean isSupportedCqlType(DataType dataType) {
             case ProtocolConstants.DataType.FLOAT:
             case ProtocolConstants.DataType.INET:
             case ProtocolConstants.DataType.UDT:
+            case ProtocolConstants.DataType.TUPLE:
                 return true;
         }
         return false;

Original file line number	Diff line number	Diff line change
`@@ -100,6 +100,7 @@ public boolean isSupportedCqlType(DataType dataType) {`
`100`	`100`	`case ProtocolConstants.DataType.FLOAT:`
`101`	`101`	`case ProtocolConstants.DataType.INET:`
`102`	`102`	`case ProtocolConstants.DataType.UDT:`
	`103`	`+ case ProtocolConstants.DataType.TUPLE:`
`103`	`104`	`return true;`
`104`	`105`	`}`
`105`	`106`	`return false;`