void function ( ) { try { LOG . info ( "srini_string" ) ; this . commands . flush ( ) ; LOG . info ( "srini_string" ) ; this . conn . commit ( ) ; } catch ( Exception loc0 ) { this . failed = true ; throw new RuntimeException ( loc0 ) ; } }
flushes jdbcwritercommands and commit . concode_field_sep long recordWrittenCount concode_elem_sep Connection conn concode_elem_sep String databaseName concode_elem_sep State state concode_elem_sep boolean failed concode_elem_sep JdbcWriterCommands commands concode_elem_sep Logger LOG concode_elem_sep String tableName concode_field_sep long bytesWritten concode_elem_sep void cleanup concode_elem_sep long recordsWritten concode_elem_sep Connection createConnection concode_elem_sep void write concode_elem_sep void close