#NEWLINE# def _convert_to_rdd( obj ) : #NEWLINE# #INDENT# 'Accepts a dict or a list of dicts and converts it to a  \n    RecursiveDefaultDict.' #NEWLINE# if isinstance ( obj , dict ) : #NEWLINE# #INDENT# rdd = RecursiveDefaultDict ( ) #NEWLINE# for ( k , v ) in obj . items ( ) : #NEWLINE# #INDENT# rdd [ k ] = _convert_to_rdd ( v ) #NEWLINE# #UNINDENT# return rdd #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if isinstance ( obj , list ) : #NEWLINE# #INDENT# rddlst = [ ] #NEWLINE# for ob in obj : #NEWLINE# #INDENT# rddlst . append ( _convert_to_rdd ( ob ) ) #NEWLINE# #UNINDENT# return rddlst #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# return obj