public static < T > TableSink < T > findAndCreateTableSink ( Descriptor descriptor ) { Map < String , String > properties = descriptor . toProperties ( ) ; TableSink tableSink ; try { tableSink = TableFactoryService . find ( TableSinkFactory . class , properties ) . createTableSink ( properties ) ; } catch ( Throwable t ) { throw new TableException ( "findAndCreateTableSink failed." , t ) ; } return tableSink ; }
Returns a table sink matching the descriptor .