@@ -42,37 +42,37 @@ protected BoundStatement bind(Row originRow, Row targetRow, Integer ttl, Long wr
42
42
boundStatement = boundStatement .set (currentBindIndex ++, writeTime , Long .class );
43
43
}
44
44
45
- Object bindValueOrg = null ;
46
- Object bindValueDest = null ;
45
+ Object bindValueOrigin = null ;
46
+ Object bindValueTarget = null ;
47
47
for (int targetIndex : columnIndexesToBind ) {
48
48
int originIndex = cqlTable .getCorrespondingIndex (targetIndex );
49
49
50
50
try {
51
51
if (usingCounter && counterIndexes .contains (targetIndex )) {
52
- bindValueOrg = cqlTable .getOtherCqlTable ().getData (originIndex , originRow );
53
- if (null == bindValueOrg ) {
52
+ bindValueOrigin = cqlTable .getOtherCqlTable ().getData (originIndex , originRow );
53
+ if (null == bindValueOrigin ) {
54
54
currentBindIndex ++;
55
55
continue ;
56
56
}
57
- bindValueDest = (null == targetRow ? 0L : cqlTable .getData (targetIndex , targetRow ));
58
- bindValueDest = ((Long ) bindValueOrg - (null == bindValueDest ? 0L : (Long ) bindValueDest ));
57
+ bindValueTarget = (null == targetRow ? 0L : cqlTable .getData (targetIndex , targetRow ));
58
+ bindValueTarget = ((Long ) bindValueOrigin - (null == bindValueTarget ? 0L : (Long ) bindValueTarget ));
59
59
}
60
60
else if (targetIndex == explodeMapKeyIndex ) {
61
- bindValueDest = explodeMapKey ;
61
+ bindValueTarget = explodeMapKey ;
62
62
}
63
63
else if (targetIndex == explodeMapValueIndex ) {
64
- bindValueDest = explodeMapValue ;
64
+ bindValueTarget = explodeMapValue ;
65
65
} else {
66
66
if (originIndex < 0 )
67
67
// we don't have data to bind for this column; continue to the next targetIndex
68
68
continue ;
69
- bindValueDest = cqlTable .getOtherCqlTable ().getAndConvertData (originIndex , originRow );
69
+ bindValueTarget = cqlTable .getOtherCqlTable ().getAndConvertData (originIndex , originRow );
70
70
}
71
71
72
- boundStatement = boundStatement .set (currentBindIndex ++, bindValueDest , cqlTable .getBindClass (targetIndex ));
72
+ boundStatement = boundStatement .set (currentBindIndex ++, bindValueTarget , cqlTable .getBindClass (targetIndex ));
73
73
}
74
74
catch (Exception e ) {
75
- logger .error ("Error trying to bind value:" + bindValueDest + " to column:" +
75
+ logger .error ("Error trying to bind value:" + bindValueTarget + " to column:" +
76
76
targetColumnNames .get (targetIndex ) + " of targetDataType:" + targetColumnTypes .get (targetIndex ) + "/"
77
77
+ cqlTable .getBindClass (targetIndex ).getName () + " at column index:" + targetIndex );
78
78
throw e ;
0 commit comments