in cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/CdcEventUtils.java [77:97]
public static OperationType getOperationType(CdcEvent event)
{
switch (event.getKind())
{
case INSERT:
return OperationType.INSERT;
case UPDATE:
return OperationType.UPDATE;
case DELETE:
case ROW_DELETE:
return OperationType.DELETE;
case COMPLEX_ELEMENT_DELETE:
return OperationType.COMPLEX_ELEMENT_DELETE;
case RANGE_DELETE:
return OperationType.DELETE_RANGE;
case PARTITION_DELETE:
return OperationType.DELETE_PARTITION;
default:
throw new IllegalStateException("Unknown CDC event kind: " + event.getKind());
}
}