The following parameters configure a new recovery mechanism, that can be used, if the database connection is temporarily unavailable (still under progress and may change).
sink = DATABASESINK({ connection = 'con1', table = 'testTable2', primarykeys = ['ts'], batchsize = 100, drop = false, recoverystoretype = 'FileStore', recoveryenabled = false, recoveryoptions = [ ['filename','g:/tmp/testTable1Recovery.store'] ] }, input ) |
Further examples can be found under Database Feature
You could use a Map operator before the database sink if you need to map the input to a database schema or a prepared statement.