#NEWLINE# def __init__( self , trowset , schema ) : #NEWLINE# #INDENT# log . debug ( 'RBatch: input TRowSet: %s' , row ) #NEWLINE# self . schema = schema #NEWLINE# self . rows = [ ] #NEWLINE# for trow in trowset . rows : #NEWLINE# #INDENT# row = [ ] #NEWLINE# for ( i , col_val ) in enumerate ( trow . colVals ) : #NEWLINE# #INDENT# type_ = schema [ i ] [ 1 ] #NEWLINE# value = _TTypeId_to_TColumnValue_getters [ type_ ] ( col_val ) . value #NEWLINE# if ( type_ == 'TIMESTAMP' ) : #NEWLINE# #INDENT# value = _parse_timestamp ( value ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( type_ == 'DECIMAL' ) : #NEWLINE# #INDENT# if value : #NEWLINE# #INDENT# value = Decimal ( value ) #NEWLINE# #UNINDENT# #UNINDENT# #UNINDENT# row . append ( value ) #NEWLINE# #UNINDENT# self . rows . append ( tuple ( row ) )