Как обработать входной DStream, разделив его на RDD для печати сообщений Kafka?

Я опубликовал простой сценарий оболочки для сброса баз данных:

https://github.com/Pixplicity/humpty-dumpty-android

Он выполняет два разных метода, описанных здесь:

1. Сначала он пытается сделать файл доступным для других пользователей и пытается вытащить его с устройства.
2. Если это не удается, оно передает содержимое файла через терминал на локальный компьютер. Он выполняет дополнительный трюк, чтобы удалить символы \r, которые некоторые устройства выводят в оболочку.

Здесь вы можете использовать различные приложения CLI или GUI SQLite, такие как sqlite3 или sqlitebrowser, чтобы просмотреть содержимое базы данных.