Document Center

    AnalyticDB for MySQL

    • Notifications
      • [Notice] Free extension of backup set retention period ended
      • [Notice] Announcement of free extension of backup set retention period
      • Announcements
    • Release notes
    • Product Introduction
      • What is AnalyticDB for MySQL?
      • Editions
      • Features
      • Benefits
      • Scenarios
      • Customer Case
        • Transportation and logistics
          • Intelligent urban public transportation system built based on AnalyticDB for MySQL
        • Internet
          • Keruyun precision marketing solution
          • Fine-grained advertisement management solution for Irobotbox
          • Real-time BI analytics for the Internet industry
        • New retail
          • AnalyticDB for MySQL empowers Flowerplus business development
        • Finance
          • Aggregate payment solution
      • Limits
      • Terms
    • Pricing
      • Billing methods and prices
      • Billing details about specifications changes
      • Impact of expiration or overdue payments
      • Renewal
    • Getting Started
      • Use AnalyticDB for MySQL
      • Create an Alibaba Cloud account
      • Create a cluster
      • Create a database account
      • Configure a whitelist
      • Connect to an AnalyticDB for MySQL cluster
      • Create a database
      • Import and query data
    • User's Guide
      • Instructions for new AnalyticDB for MySQL users
      • Database Connection
        • Apply for or release a public endpoint
        • Tool compatibility
          • Compatibility overview
          • Navicat Premium
          • DBeaver
          • DBVisualizer
          • SQL WorkBench/J
          • DataGrip
          • Oracle Golden Gate
          • Tableau
          • QlikView
          • Yonghong BI
          • FineBI 5.0
          • FineReport 10.0
          • Scriptella
          • Smartbi
        • Use the MySQL command-line tool to connect to AnalyticDB for MySQL
        • Use a business system to connect to AnalyticDB for MySQL
          • Java
          • Druid connection pool
          • Python
          • PHP
          • C# for macOS
          • Go
        • Use a client to connect to AnalyticDB for MySQL
          • DBeaver
          • Navicat
          • SQL WorkBench/J
          • DBVisualizer
        • Enable PrepareStatement for a client in different programming languages
      • Separation of hot and cold data storage
      • Data Warehouse Development
        • Use DataWorks to schedule AnalyticDB for MySQL tasks
        • Use Kettle to synchronize local data to AnalyticDB for MySQL
      • End-to-end data management
        • Log on to a database
        • Manage data assets
        • Develop and schedule tasks
      • Data Visualization
        • FineBI
        • Quick BI
        • Yonghong BI
        • DataV
        • Tableau
        • QlikView
        • FineReport
        • Power BI
        • Smartbi
      • Cluster Management
        • Set a maintenance window
        • Resource pool overview
        • Manage resource pools
        • EIUs
        • Scale out resources
        • Query execution modes
        • Modify the configurations of an AnalyticDB for MySQL cluster
        • Delete a cluster
        • Manage O&M events
      • Materialized views
        • Overview
        • Create materialized views
        • Refresh materialized views
        • Manage materialized views
        • Query materialized views
        • Customer stories
          • Success story I
          • Success story II
          • Success story III
      • Data Security
        • Configure a whitelist
        • Configure SQL audit
        • Disk encryption
      • Account And Permission Management
        • Account types
        • Permission model
        • Database accounts and permissions
        • RAM users and permissions
        • Authorize the service account
        • Reset the password of a privileged account
      • Backup And Recovery
        • Manage backups
        • Clone a cluster
      • Monitoring And Alerts
        • View monitoring information
        • Set an alert rule
      • Tag management
        • Unbind a tag
        • Filter clusters by tag
        • Bind a tag
      • Diagnostics and optimization
        • Data modeling optimization
        • Analyze execution plans by using SQL diagnostics
          • Introduction to SQL diagnostics
          • Use query monitoring charts and lists
          • Use execution plans to analyze queries
      • Daily health reports
    • Developer‘s Guide
      • Welcome
        • Instructions for database developers
        • Prerequisites
      • Data import and export
        • Supported data sources
        • Data base
          • Use DTS to Import Data
            • Synchronize data from an ApsaraDB RDS for MySQL instance to an AnalyticDB for MySQL cluster
            • Synchronize data from aDRDS database to an AnalyticDB for MySQL cluster
            • Migrate data from a PolarDB for MySQL cluster to an AnalyticDB for MySQL V3.0 cluster
          • Use external tables to import data
            • Use external tables to import data from ApsaraDB RDS for MySQL to AnalyticDB for MySQL
            • Use external tables to import data from a self-managed MySQL database to AnalyticDB for MySQL
          • Use external tables to export data
            • Use external tables to export data from AnalyticDB for MySQL to ApsaraDB RDS for MySQL
            • Use external tables to export data from AnalyticDB for MySQL to a self-managed MySQL database
          • Use DataWorks to synchronize data from ApsaraDB RDS for MySQL
            • Overview
            • Configure an ApsaraDB RDS for MySQL connection
            • Configure an Oracle connection
            • Configure an SQL Server connection
            • Configure an AnalyticDB for MySQL V3.0 data source
            • Configure the source and destination connections for a synchronization task
        • OSS
          • Use DataWorks to import data from OSS
            • Configure an OSS connection
            • Configure an AnalyticDB for MySQL connection
            • Configure the source connection and destination connection for a synchronization task
          • Import OSS data to AnalyticDB for MySQL by using external tables
          • Export data to OSS by using external tables
        • HDFS
          • Use external tables to import data from Apsara File Storage for HDFS to AnalyticDB for MySQL
          • Use external tables to export data from AnalyticDB for MySQL to Apsara File Storage for HDFS
        • Big data
          • Use DataWorks to import data from EMR
            • Configure an HDFS connection
            • Configure a MaxCompute connection
            • Configure an AnalyticDB for MySQL connection
            • Configure the source and destination connections for a synchronization task
          • Use DLA to import data from Apache Hadoop
            • Feature description
            • Procedure
          • Import MaxCompute data to AnalyticDB for MySQL
          • Use external tables to export data to MaxCompute partitioned tables
          • Use Apache Flink to write data to AnalyticDB for MySQL
        • Apache Kafka
          • Overview
          • Use Logstash to write Apache Kafka data to AnalyticDB for MySQL
        • Log data
          • Use Logstash to collect log data in real time
          • Use Log Service to transfer log data to AnalyticDB for MySQL
        • Local data
          • Use the LOAD DATA statement to import local data
          • Use the AnalyticDB for MySQL import tool to import on-premises data
        • Asynchronously submit an import or export task
      • SQL manual
        • Basic data types
        • Complex Data Types
          • Array
          • Map
          • JSON
        • Reserved words
        • SQL offset table
          • DDL differences
          • DML differences
          • Differences in other SQL features
          • Unsupported data types and operators
        • Data definition statements
          • CREATE DATABASE
          • CREATE TABLE
          • CREATE RESOURCE GROUP
          • CTAS
          • ALTER TABLE
          • CREATE VIEW
          • DROP DATABASE
          • DROP TABLE
          • DROP VIEW
          • TRUNCATE TABLE
          • SHOW
        • Data manipulation statements
          • INSERT INTO
          • REPLACE INTO
          • ALTER RESOURCE GROUP
          • DROP RESOURCE GROUP
          • INSERT SELECT FROM
          • REPLACE SELECT FROM
          • INSERT OVERWRITE INTO SELECT
          • INSERT ON DUPLICATE KEY UPDATE
          • UPDATE
          • DELETE
          • KILL PROCESS
          • SHOW PROCESSLIST
        • Data query language
          • SELECT
            • Syntax
            • LIMIT
            • UNION, INTERSECT, and EXCEPT
            • WITH
            • GROUP BY
            • HAVING
            • JOIN
            • ORDER BY
            • Subqueries
          • Query users
          • CROSS JOIN
        • Data control language
          • CREATE USER
          • DROP USER
          • GRANT
          • RENAME USER
          • REVOKE
        • Data dictionary of the metadatabase
      • System Functions
        • Control flow functions
        • Numeric functions and operators
          • Arithmetic operators
          • Numeric functions
        • Date and time functions
        • String functions
        • Bit functions and operators
        • Geometry functions
          • Operation functions
          • Spatial relation functions
          • Accessor functions
          • Spatial constructor functions
        • JSON functions
        • Window functions
        • Aggregate functions
        • Encryption and compression functions
        • CAST functions
      • Full-text Search
        • Create a full-text index
        • Query data by using full-text indexes
        • Custom analyzers and dictionaries
      • Query throttling configurations
      • API Reference
        • List of operations by function
        • Request structure
        • Request signatures
        • Common parameters
        • RAM authorization
        • Manage the service-linked role
        • Manage the service-linked role for disk encryption
        • Cluster management
          • CreateDBCluster
          • DescribeDBClusters
          • ModifyDBCluster
          • DeleteDBCluster
          • DescribeDBClusterAttribute
          • ModifyDBClusterMaintainTime
          • DescribeAutoRenewAttribute
          • ModifyAutoRenewAttribute
          • ModifyDBClusterDescription
          • DescribeAvailableResource
          • ModifyDBClusterResourceGroup
        • Manage Resource Pools
          • CreateDBResourcePool
          • DeleteDBResourcePool
          • DescribeDBResourcePool
          • ModifyDBResourcePool
          • BindDBResourcePoolWithUser
          • UnbindDBResourcePoolWithUser
        • Elastic Plan Management
          • CreateElasticPlan
          • DeleteElasticPlan
          • DescribeElasticDailyPlan
          • DescribeElasticPlan
          • ModifyElasticPlan
        • Database
          • DescribeTables
          • DescribeAllDataSource
          • DescribeSchemas
          • DescribeTableDetail
          • DescribeProcessList
          • DescribeColumns
          • DescribeTaskInfo
          • DescribeSQLPlan
          • DescribeSQLPlanTask
          • KillProcess
          • DescribeTablePartitionDiagnose
          • DescribeLoadTasksRecords
          • DescribeConnectionCountRecords
        • Log management
          • DescribeSlowLogRecords
          • DescribeSlowLogTrend
          • DescribeAuditLogConfig
          • ModifyAuditLogConfig
          • DescribeAuditLogRecords
        • Region management
          • DescribeRegions
        • Network management
          • AllocateClusterPublicConnection
          • DescribeDBClusterNetInfo
          • ReleaseClusterPublicConnection
          • ModifyClusterConnectionString
        • Account management
          • CreateAccount
          • DeleteAccount
          • DescribeAccounts
          • DescribeOperatorPermission
          • GrantOperatorPermission
          • ResetAccountPassword
          • RevokeOperatorPermission
          • ModifyAccountDescription
          • DescribeAllAccounts
        • Tag management
          • TagResources
          • ListTagResources
          • UntagResources
        • Backup and restoration
          • DescribeBackups
          • DescribeBackupPolicy
          • ModifyBackupPolicy
          • ModifyLogBackupPolicy
        • Security management
          • DescribeDBClusterAccessWhiteList
          • ModifyDBClusterAccessWhiteList
        • Monitoring management
          • DescribeDBClusterPerformance
          • DescribeDBClusterResourcePoolPerformance
          • DescribeInclinedTables
          • DescribeTableStatistics
        • O&M events
          • DescribeMaintenanceAction
          • ModifyMaintenanceAction
        • SQL diagnostics
          • DescribeDiagnosisRecords
          • DescribeDiagnosisDimensions
          • DescribeDownloadRecords
          • DownloadDiagnosisRecords
        • Cluster running reports
          • DescribeTableAccessCount
          • DescribeSqlPattern
          • DescribeDBClusterHealthReport
          • DescribeDBClusterForecast
        • Appendixes
          • Cluster states
      • SDK Reference
        • SDK reference
    • Performance Optimization
      • Analysis query
        • Overview
        • Query process and execution plan
        • Operators
        • Factors that affect query performance
        • Typical slow queries
        • Query performance analysis
          • Analyze execution plans by using SQL diagnostics
            • Introduction to SQL diagnostics
            • Use query monitoring charts and lists
            • Use execution plans to analyze queries
          • Use the EXPLAIN and EXPLAIN ANALYZE commands to analyze execution plans
          • Use a slow query table
      • Tuning queries
        • Overview
        • SQL self-diagnostics
          • View query properties and diagnosis results
          • Query-level diagnosis results
          • Stage-level diagnostic results
          • Operator-level diagnosis results
        • Join tuning
          • Rewrite left join to right join
          • STRAIGHT_JOIN
          • Manually adjust join orders
        • Filter conditions without pushdown
        • Grouping and aggregation query optimization
      • Common issues and improvement measures
    • Best Practices
      • Schema design
      • Rules for SQL development
      • Optimization of data changes
      • Query optimizers
        • Persist plan and Query-Blocker
      • Permission management by using views
    • Performance White Paper
      • Overview
      • Test description based on standard dataset
        • Test environments
        • Test procedure
        • Test method
      • Test description based on application scenarios
        • Query scenarios
        • Data import scenarios
      • Appendix: test procedure
        • TPC-H test
          • Preparations
          • AnalyticDB for MySQL
          • Presto
          • Construct data
          • Import data
          • TPC-H dataset
        • TPC-DS test
          • Preparations
          • Install TPC-DS tools
          • Construct data
          • Create test tables in AnalyticDB for MySQL
          • Import test data
          • TPC-DS dataset
    • Technical Whitepaper
      • Industry trends and background
        • Technology development trends
        • Business challenges
      • Technical architecture
        • Overall architecture
        • Elastic computing layer
        • Serverless storage layer
      • Technical benefits
        • High performance
          • Xuanwu analytical storage engine
          • Xihe analytical computing engine
          • Cost-based SQL optimization
          • Query optimization based on hybrid loads
          • Read/write splitting architecture
        • High availability
          • High availability of the access layer
          • High availability of the computing layer
          • High availability of the storage layer
        • High scalability
          • Elasticity of the computing layer
          • Elasticity of the storage layer
      • Backup and restoration
        • How backup works
        • How restoration works
      • Monitoring and alarm
        • Monitoring mechanism
          • Data collection
          • Data storage
          • Data aggregation analysis
        • Alerting mechanism
        • Obtain monitoring data (API operation)
    • FAQ
 
All Products
Search
  • Document Center
  • AnalyticDB for MySQL
  • Developer‘s Guide
  • Data import and export
  • Big data
  • Use DataWorks to import data from EMR
  • Configure the source and destination connections for a synchronization task

This Product

  • This Product
  • All Products

    Configure the source and destination connections for a synchronization task

    Document Center

    Configure the source and destination connections for a synchronization task

    Last Updated: Jul 30, 2020

    To synchronize data from E-MapReduce (EMR) to AnalyticDB for MySQL, you can follow the steps for configuring synchronization tasks.

    For more information, see Use DataWorks to synchronize data from ApsaraDB RDS for MySQL.

    How helpful was this page?

    What might be the problems?

      More suggestions?

      Thank you! We've received your feedback.