public JDBCAppendTableSink build ( ) { Preconditions . checkNotNull ( parameterTypes , "Types of the query parameters are not specified." + " Please specify types using the setParameterTypes() method." ) ; JDBCOutputFormat format = JDBCOutputFormat . buildJDBCOutputFormat ( ) . setUsername ( username ) . setPassword ( password ) . setDBUrl ( dbURL ) . setQuery ( query ) . setDrivername ( driverName ) . setBatchInterval ( batchSize ) . setSqlTypes ( parameterTypes ) . finish ( ) ; return new JDBCAppendTableSink ( format ) ; }
Finalizes the configuration and checks validity .