Skip to content

Commit 33f4d30

Browse files
More vector test types
1 parent 1428f4c commit 33f4d30

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

  • cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/endtoend

cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/endtoend/DataTypeTests.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -196,9 +196,12 @@ public void testVectorTuple(CassandraBridge bridge)
196196

197197
private static Gen<CqlField.NativeType> vectorSupportedTypes(CassandraBridge bridge)
198198
{
199-
List<CqlField.NativeType> supportedTypes = List.of(bridge.aInt(), bridge.bigint(), bridge.aFloat(),
200-
bridge.aDouble(), bridge.smallint(), bridge.tinyint(),
201-
bridge.decimal());
199+
// TODO: Vector of durations fail, because we cannot replace DurationSerializer with
200+
// AnalyticsDurationSerializer across all serializers used by VectorType.
201+
// TODO: Fix for CASSANDRA-20979 required.
202+
List<CqlField.NativeType> supportedTypes = bridge.supportedTypes().stream()
203+
.filter(t -> !t.equals(bridge.date()) && !t.equals(bridge.time()) && !t.equals(bridge.duration()))
204+
.collect(Collectors.toList());
202205
return arbitrary().pick(supportedTypes);
203206
}
204207

0 commit comments

Comments
 (0)