我有一个项目，为电信公司创建一个单一的观点
这个过程是，我每1分钟就有一个通话记录作为.csv文件
我使用kafka和pyspark的实时流，然后将数据存储在hbase中。
解决方案是，我有一个带有column family cdr call的表，并且行id是clientid，因此我想在单元格中添加.csv文件中的行，该行包含rowid和column family以及列限定符之间的交互
我的问题是：如果hbase中的单元格支持struct作为数据类型？
如果是，我们如何实施解决方案？