ADB to ADB Connector installation
To install ADB to ADB Connector, follow the steps:
-
Make sure that the ADB to ADB service is installed. For information on how to add services to ADB clusters, see Add services.
IMPORTANTThe ADB to ADB service should be installed in both ADB clusters between which you plan to transfer data.
-
Connect to the database via psql (or any other client program):
$ psql adb -
Check that the new extensions
adb_fdwandgp_parallel_retrieve_cursorare available — via the psql meta-command\dx:\dxThe output contains the
adb_fdwandgp_parallel_retrieve_cursorextensions:List of installed extensions Name | Version | Schema | Description -----------------------------+---------+------------+--------------------------------------------------------------------- adb_fdw | 1.0 | public | foreign-data wrapper for remote ADB servers arenadata_toolkit | 1.0 | public | extension is used for manipulation of objects created by adb-bundle dblink | 1.1 | public | connect to other PostgreSQL databases from within a database diskquota | 2.2 | public | Disk Quota Main Program gp_parallel_retrieve_cursor | 1.0 | pg_catalog | Retrieve results of cursor in parallel gptkh | 0.14 | public | gptkh kadb_fdw | 0.16 | kadb | Kafka-ADB foreign data wrapper plpgsql | 1.0 | pg_catalog | PL/pgSQL procedural language postgis | 2.5.4 | public | PostGIS geometry, geography, and raster spatial types and functions pxf | 2.0 | public | Extension which allows to access unmanaged data pxf_fdw | 1.0 | public | PXF Foreign Data Wrapper for Greenplum tkh_fdw | 1.0 | public | ClickHouse Foreign Data Wrapper for Greenplum (12 rows) -
You can also check that the new foreign data wrapper
adb_fdwis available using the following SQL query against thepg_catalog.pg_foreign_data_wrappersystem table:SELECT * FROM pg_catalog.pg_foreign_data_wrapper;The result:
fdwname | fdwowner | fdwhandler | fdwvalidator | fdwacl | fdwoptions ---------------+----------+------------+--------------+--------+-------------------------------------------------------------------------------------------- dblink_fdw | 10 | 0 | 16507 | | jdbc_pxf_fdw | 10 | 16767 | 16768 | | {protocol=jdbc,"mpp_execute=all segments"} hdfs_pxf_fdw | 10 | 16767 | 16768 | | {protocol=hdfs,"mpp_execute=all segments"} hive_pxf_fdw | 10 | 16767 | 16768 | | {protocol=hive,"mpp_execute=all segments"} hbase_pxf_fdw | 10 | 16767 | 16768 | | {protocol=hbase,"mpp_execute=all segments"} s3_pxf_fdw | 10 | 16767 | 16768 | | {protocol=s3,"mpp_execute=all segments"} gs_pxf_fdw | 10 | 16767 | 16768 | | {protocol=gs,"mpp_execute=all segments"} adl_pxf_fdw | 10 | 16767 | 16768 | | {protocol=adl,"mpp_execute=all segments"} wasbs_pxf_fdw | 10 | 16767 | 16768 | | {protocol=wasbs,"mpp_execute=all segments"} file_pxf_fdw | 10 | 16767 | 16768 | | {protocol=file,"mpp_execute=all segments"} tkh_fdw | 10 | 16817 | 16816 | | {protocol=tkh_clickhouse,"mpp_execute=all segments",format=text} adb_fdw | 10 | 97034 | 97035 | | kadb_fdw | 10 | 16826 | 16828 | | {"mpp_execute=all segments",k_initial_offset=0,k_automatic_offsets=true,k_latency_ms=2000} (13 rows)