У меня потоковая RDD и я применил java POJO к ней, теперь есть inputRDD, она содержит id, .. другие...