void function ( AzExecMessage arg0 ) { List < LineageRecord > loc0 = extractLineage ( arg0 ) ; for ( LineageRecord loc1 : loc0 ) { arg0 . databaseWriter . append ( loc1 ) ; } logger . debug ( "srini_string" + loc0 . size ( ) + "srini_string" + arg0 . toString ( ) ) ; arg0 . databaseWriter . flush ( ) ; }
extract and write to database concode_field_sep Logger logger concode_field_sep List<LineageRecord> extractLineage