Skip to content

Commit bf90f64

Browse files
decimal fix
1 parent 36b1f4f commit bf90f64

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

src/main/java/com/datastax/cdm/CassandraDatasetManager.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
//import com.datastax.loader.CqlDelimLoadTask;
2222

2323
import java.io.*;
24+
import java.math.BigDecimal;
2425
import java.net.MalformedURLException;
2526
import java.net.URL;
2627
import java.util.List;
@@ -269,6 +270,12 @@ void install(String name) throws IOException, InterruptedException, GitAPIExcept
269270
else if(t.equals("float")) {
270271
insert.value(cm.getName(), new Float(record.get(i)));
271272
}
273+
else if(t.equals("decimal")) {
274+
insert.value(cm.getName(), new BigDecimal(record.get(i)));
275+
}
276+
else if(t.equals("map")) {
277+
insert.value(cm.getName(), new BigDecimal(record.get(i)));
278+
}
272279
else {
273280
insert.value(cm.getName(), record.get(i));
274281
}

0 commit comments

Comments
 (0)