Speichern null Werte in Cassandra mit DataStax Spark Connector

Question

Ich versuche, Stromdaten in Cassandra mit Spark und Cassandra Spark Connector zu speichern.

Ich habe so etwas wie die folgenden:

eine Model-Klasse erstellen:

public class ContentModel { 
    String id; 

    String available_at; //may be null 

    public ContentModel(String id, String available_at){ 
    this.id=id; 
    this.available_at=available_at, 
    } 
} 

Mapping Streaming Content Modell:

JavaDStream<ContentModel> contentsToModel = myStream.map(new Function<String, ContentModel>() { 
     @Override 
     public ContentModel call(String content) throws Exception { 

      String[] parts = content.split(","); 
      return new ContentModel(parts[0], parts[1]); 
     } 
    }); 

sparen

CassandraStreamingJavaUtil.javaFunctions(contentsToModel).writerBuilder("data", "contents", CassandraJavaUtil.mapToRow(ContentModel.class)).saveToCassandra(); 

Wenn s ome Werte sind null ich die folgende Fehlermeldung erhalten:

com.datastax.spark.connector.types.TypeConversionException: Cannot convert object null to struct.ValueRepr. 

Gibt es eine Möglichkeit Nullwerte zu speichern Funken Cassandra Connector?

Answer 1

Cassandra hat nicht das Konzept von Null. Eine Spalte ist leer oder gefüllt. Ich habe dieses Problem in der folgenden Weise gelöst: Ich habe die map-Methode verwendet und Null-Werte überprüft. Ich habe null mit einer leeren Zeichenfolge überschrieben. Das ist es. Funktioniert wirklich gut.

Answer 2

In scala können Sie auch Optionen dafür verwenden.