Skip to content

Commit c2460c5

Browse files
committed
Fixed typos
1 parent e1a3d41 commit c2460c5

File tree

4 files changed

+5
-4
lines changed

4 files changed

+5
-4
lines changed

RELEASE.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
# Release Notes
22
## [4.1.16] - 2024-05-31
33
- Added property to manage null values in Map fields
4+
- Allow separate input and output partition CSV files
45
- Updated README
56

67
## [4.1.15] - 2024-03-05

src/main/java/com/datastax/cdm/properties/KnownProperties.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,7 @@ public enum PropertyType {
178178
public static final String TRANSFORM_CODECS = "spark.cdm.transform.codecs";
179179
public static final String TRANSFORM_CODECS_TIMESTAMP_STRING_FORMAT = "spark.cdm.transform.codecs.timestamp.string.format";
180180
public static final String TRANSFORM_CODECS_TIMESTAMP_STRING_FORMAT_ZONE = "spark.cdm.transform.codecs.timestamp.string.zone";
181-
public static final String TRANSFORM_MAP_REMOVE_KEY_WITH_NO_VALUE = "spark.cdm.transform.map.remove.null.vaue";
181+
public static final String TRANSFORM_MAP_REMOVE_KEY_WITH_NO_VALUE = "spark.cdm.transform.map.remove.null.value";
182182

183183

184184

src/main/java/com/datastax/cdm/schema/CqlTable.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -292,7 +292,7 @@ public Object getAndConvertData(int index, Row row) {
292292
}
293293

294294
if (removeMapWithNoValues && thisObject instanceof Map) {
295-
removeNullValuesFrmMap(thisObject);
295+
return removeNullValuesFromMap(thisObject);
296296
}
297297

298298
CqlConversion cqlConversion = this.cqlConversions.get(index);
@@ -306,7 +306,7 @@ public Object getAndConvertData(int index, Row row) {
306306
}
307307
}
308308

309-
private Object removeNullValuesFrmMap(Object thisObject) {
309+
private Object removeNullValuesFromMap(Object thisObject) {
310310
Set<Map.Entry> ms = (((Map) thisObject).entrySet());
311311
return ms.stream().filter(e -> (e.getValue() != null))
312312
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));

src/resources/cdm-detailed.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -281,7 +281,7 @@ spark.cdm.perfops.ratelimit.target 40000
281281
#spark.cdm.transform.codecs
282282
#spark.cdm.transform.codecs.timestamp.string.format yyyyMMddHHmmss
283283
#spark.cdm.transform.codecs.timestamp.string.zone UTC
284-
#spark.cdm.transform.map.remove.null.vaue false
284+
#spark.cdm.transform.map.remove.null.value false
285285

286286
#===========================================================================================================
287287
# Cassandra Filters are applied on the coordinator node. Note that, depending on the filter, the coordinator

0 commit comments

Comments
 (0)