Я экономлю DStream Кассандре.В Кассандре есть столбец с типом данных map<text, text>
вот мой код, который используется для извлечения контента и метаданных, к сожалению, этот код...