2828import io .trino .spi .connector .ConnectorInsertTableHandle ;
2929import io .trino .spi .connector .ConnectorOutputTableHandle ;
3030import io .trino .spi .connector .ConnectorPageSink ;
31+ import io .trino .spi .connector .ConnectorPageSinkId ;
3132import io .trino .spi .connector .ConnectorPageSinkProvider ;
3233import io .trino .spi .connector .ConnectorSession ;
3334import io .trino .spi .connector .ConnectorTransactionHandle ;
@@ -43,14 +44,14 @@ public RediSearchPageSinkProvider(RediSearchSession rediSearchSession) {
4344
4445 @ Override
4546 public ConnectorPageSink createPageSink (ConnectorTransactionHandle transactionHandle , ConnectorSession session ,
46- ConnectorOutputTableHandle outputTableHandle ) {
47+ ConnectorOutputTableHandle outputTableHandle , ConnectorPageSinkId pageSinkId ) {
4748 RediSearchOutputTableHandle handle = (RediSearchOutputTableHandle ) outputTableHandle ;
4849 return new RediSearchPageSink (rediSearchSession , handle .getSchemaTableName (), handle .getColumns ());
4950 }
5051
5152 @ Override
5253 public ConnectorPageSink createPageSink (ConnectorTransactionHandle transactionHandle , ConnectorSession session ,
53- ConnectorInsertTableHandle insertTableHandle ) {
54+ ConnectorInsertTableHandle insertTableHandle , ConnectorPageSinkId pageSinkId ) {
5455 RediSearchInsertTableHandle handle = (RediSearchInsertTableHandle ) insertTableHandle ;
5556 return new RediSearchPageSink (rediSearchSession , handle .getSchemaTableName (), handle .getColumns ());
5657 }
0 commit comments