XAP enrichment for DStream (not working because Spark checks that serialized tasks bloated)