2016-08-20 12 views
0

のリストを使用した場合、データを取得することができない私は私の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; 
    } 
} 

の次の定義を持っている私はスパークコネクタを使用してデータを読み取るために、次のコードを持って、

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

マイテーブル定義は次のとおりです

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

データが他のフィールドに入力されていますが、データが取得されませんdocListの場合誰も同じ行動を見たことがありますか?

答えて

2

ドックリストとゲッターとセッターには小文字を使用してください。

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; 
} 
関連する問題