Спарк Connector - не удалось получить данные при использовании списка кортежей

Question

У меня есть следующее определение моего JavaBean

public class LiveResultsFrmCassandra implements Serializable{ 


    UUID id; 

    String userdn; 
    String queryid; 

    private List<Tuple4<String, String, String, String>> docList = new ArrayList(); 


    public LiveResultsFrmCassandra() { 
    } 

    public UUID getId() { 
     return id; 
    } 

    public String getUserdn() { 
     return userdn; 
    } 

    public String getQueryid() { 
     return queryid; 
    } 


    public void setId(UUID id) { 
     this.id = id; 
    } 

    public void setUserdn(String userdn) { 
     this.userdn = userdn; 
    } 

    public void setQueryid(String queryid) { 
     this.queryid = queryid; 
    } 

    public List<Tuple4<String, String, String, String>> getDocList() { 
     return docList; 
    } 

    public void setDocList(List<Tuple4<String, String, String, String>> docList) { 
     this.docList = docList; 
    } 
} 

У меня есть следующий код для чтения данных с помощью искровой Connector,

JavaRDD<LiveResultsFrmCassandra> resultsRDD = javaFunctions(sparkContext).cassandraTable(mf.getConfig().getDatabaseName(), LIVERESULTS, mapRowTo(LiveResultsFrmCassandra.class)); 

Мои таблица Определение a a

CREATE TABLE IF NOT EXISTS LiveResults (
id uuid PRIMARY KEY, 
doclist list<frozen<tuple<text, text, text, text>>>, 
queryid text, 
userdn text); 

Я вижу, что данные поступают в другие поля, но я не получаю данные для docList. Кто-нибудь видел такое же поведение?

Answer 1

Используйте строчные буквы для док-листа и геттера и сеттера, как показано ниже.

List<Tuple4<String, String, String, String>> doclist = new ArrayList(); 

public List<Tuple4<String, String, String, String>> getDoclist() { 
    return doclist; 
} 

public void setDoclist(List<Tuple4<String, String, String, String>> doclist) { 
    this.doclist = doclist; 
}