"java.lang.IllegalArgumentException: requirement failed: Columns not found in class row1Struct: [sha256_hash_column]

[Alix Métivier]

hi everyone, 

I'm having issue writing to cassandra, the error is related to a java avro class, when a field contains '_' then it will fail to find that field in the class. I've tried different APIs : 

java.util.Map<String, String> columnMapping_tCassandraOutput_5 = new java.util.HashMap<String, String>();
columnMapping_tCassandraOutput_5.put("key", "key");
columnMapping_tCassandraOutput_5.put("sha256_hash_column", "sha256_hash_column");

com.datastax.spark.connector.japi.CassandraJavaUtil.javaFunctions(rdd_row1out)
.writerBuilder(context.cassandra_keyspace, context.test_table_columns_names_containing_numbers,
com.datastax.spark.connector.japi.CassandraJavaUtil.mapToRow(row1Struct.class))
.withColumnSelector(com.datastax.spark.connector.japi.CassandraJavaUtil.someColumns("key",
"sha256_hash_column"))
.saveToCassandra();

and also 

com.datastax.spark.connector.japi.CassandraJavaUtil.javaFunctions(rdd_row1out)
.writerBuilder(context.cassandra_keyspace, context.test_table_columns_names_containing_numbers,
com.datastax.spark.connector.japi.CassandraJavaUtil.mapToRow(row1Struct.class))
.saveToCassandra();

but both will fail, if I remove the _ to have sha256hashcolumn then job is working as expected. I have not found any mention of this so just a confirmation that it won't be supported would make my day ! 

Thanks,

Alix.