-
Notifications
You must be signed in to change notification settings - Fork 36
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
python demo example for reconciliation added #1427
base: main
Are you sure you want to change the base?
Conversation
from databricks.labs.remorph.reconcile.recon_config import Table, ColumnMapping, Aggregate | ||
|
||
# Create a workspace client | ||
ws = WorkspaceClient(product="remorph", product_version="0.9.0") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
use it from the __version__
variable from __about__.py
# Create a workspace client | ||
ws = WorkspaceClient(product="remorph", product_version="0.9.0") | ||
|
||
source_catalog = "" # Provide the source catalog name ex: hive_metastore |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
source_catalog = "" # Provide the source catalog name ex: hive_metastore | |
source_catalog = "" # Provide the source catalog name ex: Name of the catalog |
|
||
# Check target_catalog.target_schema.details table for the reconciliation report | ||
|
||
# Table configuration for aggregated reconciliation |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Separate Notebook for Aggregates.
Added a new notebook which can be use to perform reconciliation using Remorph.The notebook includes instructions and code for installing the Remorph library, setting up necessary configuration parameters, and executing the reconciliation process.