@@ -31,23 +31,23 @@ public class WritetimeTTL extends AbstractFeature {
31
31
32
32
@ Override
33
33
public boolean loadProperties (IPropertyHelper propertyHelper ) {
34
+ this .autoTTLNames = propertyHelper .getBoolean (KnownProperties .ORIGIN_TTL_AUTO );
34
35
this .ttlNames = getTTLNames (propertyHelper );
35
36
if (null !=this .ttlNames && !this .ttlNames .isEmpty ()) {
36
37
logger .info ("PARAM -- TTLCols: {}" , ttlNames );
38
+ this .autoTTLNames = false ;
37
39
}
38
40
39
- this .autoTTLNames = propertyHelper .getBoolean (KnownProperties .ORIGIN_TTL_AUTO );
41
+ this .autoWritetimeNames = propertyHelper .getBoolean (KnownProperties .ORIGIN_WRITETIME_AUTO );
40
42
this .writetimeNames = getWritetimeNames (propertyHelper );
41
43
if (null !=this .writetimeNames && !this .writetimeNames .isEmpty ()) {
42
44
logger .info ("PARAM -- WriteTimestampCols: {}" , writetimeNames );
43
- this .autoTTLNames = false ;
45
+ this .autoWritetimeNames = false ;
44
46
}
45
47
46
- this .autoWritetimeNames = propertyHelper .getBoolean (KnownProperties .ORIGIN_WRITETIME_AUTO );
47
48
this .customWritetime = getCustomWritetime (propertyHelper );
48
49
if (this .customWritetime > 0 ) {
49
50
logger .info ("PARAM -- {}: {} datetime is {} " , KnownProperties .TRANSFORM_CUSTOM_WRITETIME , customWritetime , Instant .ofEpochMilli (customWritetime / 1000 ));
50
- this .autoWritetimeNames = false ;
51
51
}
52
52
53
53
this .writetimeIncrement = propertyHelper .getLong (KnownProperties .TRANSFORM_CUSTOM_WRITETIME_INCREMENT );
@@ -115,10 +115,12 @@ public boolean initializeAndValidate(CqlTable originTable, CqlTable targetTable)
115
115
116
116
if (autoTTLNames ) {
117
117
this .ttlNames = originTable .getWritetimeTTLColumns ();
118
+ logger .info ("PARAM -- Automatic TTLCols: {}" , ttlNames );
118
119
}
119
120
120
121
if (autoWritetimeNames ) {
121
122
this .writetimeNames = originTable .getWritetimeTTLColumns ();
123
+ logger .info ("PARAM -- Automatic WriteTimestampCols: {}" , writetimeNames );
122
124
}
123
125
124
126
validateTTLColumns (originTable );
0 commit comments