У меня есть проект по созданию точки зрения для телекоммуникационной компании
хорошо, процесс состоит в том, что у меня есть запись вызовов каждые 1 мин в виде файла .csv
Я использую потоковую передачу в реальном времени с kafka и pyspark, затем сохраняю данные в Hbase.
решение состоит в том, что у меня есть таблица с cdr-вызовом семейства colomn, а id строки - это clientId, поэтому я хочу добавить строку из файла .csv в ячейку, в которой происходит взаимодействие между rowid и colomnFamily и квалификатор столбца
мой вопрос: если ячейки в hbase поддерживают struct как dataType?
если да, как мы можем реализовать решение?