File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
src/main/java/datastax/astra/migrate Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -196,7 +196,7 @@ private String cqlTargetSelectOriginByPK() {
196
196
}
197
197
}
198
198
199
- return "SELECT " + propertyHelper .getAsString (KnownProperties .ORIGIN_COLUMN_NAMES ) + " FROM " + getTargetKeyspaceTable () + " WHERE " + keyBinds ;
199
+ return "SELECT " + propertyHelper .getAsString (KnownProperties .TARGET_COLUMN_NAMES ) + " FROM " + getTargetKeyspaceTable () + " WHERE " + keyBinds ;
200
200
}
201
201
202
202
public long getLargestWriteTimeStamp (Row row ) {
Original file line number Diff line number Diff line change @@ -244,7 +244,7 @@ protected void loadSparkConf() {
244
244
setProperty (KnownProperties .TARGET_COLUMN_NAMES , get (KnownProperties .ORIGIN_COLUMN_NAMES ));
245
245
}
246
246
247
- // Target column list defaults to the source column list
247
+ // Target column key list defaults to the first N columns of the source column list, where N is the size of the target primary key list
248
248
if (null == get (KnownProperties .TARGET_PRIMARY_KEY_TYPES ) || getAsString (KnownProperties .TARGET_PRIMARY_KEY_TYPES ).isEmpty ()) {
249
249
if (null != getMigrationTypeList (KnownProperties .ORIGIN_COLUMN_TYPES ) && !getMigrationTypeList (KnownProperties .ORIGIN_COLUMN_TYPES ).isEmpty ()) {
250
250
List <MigrateDataType > targetPKTypes = getMigrationTypeList (KnownProperties .ORIGIN_COLUMN_TYPES ).subList (0 , getStringList (KnownProperties .TARGET_PRIMARY_KEY ).size ());
You can’t perform that action at this time.
0 commit comments