Skip to content
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

Replicated versioned collapsing merge tree #4

Open
wants to merge 5 commits into
base: Array-inclusion
Choose a base branch
from

Conversation

HelloSunilSaini
Copy link
Owner

No description provided.

@HelloSunilSaini HelloSunilSaini changed the title Replicated collapsing merge tree Replicated versioned collapsing merge tree Mar 3, 2023
if(parameterArray != null && parameterArray.length >= 4) {
versionColumn = parameterArray[3].trim();
}
}

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

error handling here.

ps.setInt(signColumnIndex, -1);
} else if (record.getCdcOperation().getOperation().equalsIgnoreCase(ClickHouseConverter.CDC_OPERATION.UPDATE.getOperation())){
if(beforeSection == true) {
ps.setInt(signColumnIndex, - 1);

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

do we get before in case of incremental snapshot, in case the data is already present as part of CDC ? How is that handled ?

@@ -34,7 +34,7 @@ public String createAlterTableSyntax(String tableName, Map<String, String> colNa
} else {
alterTableSyntax.append(ClickHouseDbConstants.ALTER_TABLE_DELETE_COLUMN).append(" ");
}
alterTableSyntax.append("`").append(entry.getKey()).append("`").append(" ").append(entry.getValue()).append(",");
alterTableSyntax.append("`").append(entry.getKey()).append("`").append(" Nullable(").append(entry.getValue()).append("),");

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

why do we need this ?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants