千万级数据对账

Identifies matches and discrepancies between two massive datasets using scalable techniques like Spark or hashing-based matching.

Updated Jul 9, 2025
One-click install
npx skills add https://github.com/xiayiping/spring-all --skill -xiayiping
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: 千万级数据对账
Source: https://github.com/xiayiping/spring-all/tree/main/document/big-data
Command: npx skills add https://github.com/xiayiping/spring-all --skill -xiayiping

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

Reconciles massive datasets by identifying matches and discrepancies between two data sources, dramatically reducing manual audit effort.

Core Features & Use Cases

  • Scalable preprocessing: normalize and partition data from databases, files, or streams.
  • High-performance matching: supports hashing-based and sort-merge strategies with optional distributed execution (e.g., Spark).
  • Use Case: For example, reconciling 80 million transactions between a CRM and a billing system within minutes.

Quick Start

Run the reconciliation workflow on your two datasets: load data1.csv and data2.csv, then execute the compare task to produce matched, only-in-dataset1, and only-in-dataset2 results.

Frequently Asked Questions about 千万级数据对账

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I reconcile tens of millions of records between two data sources efficiently?

To reconcile massive datasets efficiently, apply preprocessing, partitioning, and scalable matching techniques like hash-based or sort-merge strategies. This identifies matches and discrepancies between two data sources, processing tens of millions of records within minutes.

What is the best way to perform big data reconciliation across databases and files?

The best way to perform big data reconciliation across databases and files is using distributed processing frameworks like Spark. It supports batch and streaming reconciliation by normalizing data from various sources and applying scalable matching techniques to find discrepancies.

Can I use Spark for hash-join reconciliation on 80 million transactions?

Yes, you can use Spark for hash-join reconciliation on 80 million transactions. The process utilizes distributed execution and in-memory maps to handle massive datasets, allowing you to reconcile large volumes of financial or operational records between systems like CRM and billing within minutes.

How do I start a data reconciliation workflow on two CSV files?

To start a data reconciliation workflow on two CSV files, load data1.csv and data2.csv, then execute the compare task. This produces three distinct outputs: matched records, records only in dataset1, and records only in dataset2.

Does big data reconciliation support streaming data and caches?

Yes, big data reconciliation supports streaming data and caches. It applies to financial records, logs, and operational data, supporting both batch and streaming reconciliation across databases, files, and caches to identify matches and discrepancies within tight time windows.