2016-06-10 48 views
6

Sto utilizzando cassandraSQL da spark-shell per interrogare i dati da cassandra. Quindi, voglio sapere due cose su come recuperare più di 20 righe usando cassnadraSQL e in secondo luogo come faccio a visualizzare l'intero valore della colonna. Come puoi vedere di seguito, per impostazione predefinita, aggiunge punti nei valori stringa.recupera più di 20 righe e visualizza il valore completo della colonna in spark-shell

Codice:

val csc = new CassandraSQLContext(sc) 
csc.setKeyspace("KeySpace") 
val maxDF = csc.sql("SQL_QUERY") 
maxDF.show 

uscita:

+--------------------+--------------------+-----------------+--------------------+ 
|     id|    Col2|    Col3|    Col4| 
+--------------------+--------------------+-----------------+--------------------+ 
|8wzloRMrGpf8Q3bbk...|    Value1|     X|     K1| 
|AxRfoHDjV1Fk18OqS...|    Value2|     Y|     K2| 
|FpMVRlaHsEOcHyDgy...|    Value3|     Z|     K3| 
|HERt8eFLRtKkiZndy...|    Value4|     U|     K4| 
|nWOcbbbm8ZOjUSNfY...|    Value5|     V|     K5| 
+0

Provare prima o scala invece di mostrare. – phact

+0

Ci proverò. Potresti dirmi come visualizzare il valore completo della colonna? – Naresh

risposta

11

Se si desidera stampare l'intero valore di una colonna, è sufficiente impostare l'argomento troncare dal show metodo per false:

maxDf.show(false) 

e se si desidera mostrare più di 20 righe:

// example showing 30 columns of 
// maxDf untruncated 
maxDf.show(30, false) 
+1

Scusa, non ho visto la tua risposta prima di pubblicare la mia. –

+0

@eliasah Potresti per favore aiutarmi con questo. Sono bloccato qui 'http: // stackoverflow.com/questions/39363586/issue-while-storing-data-da-spark-streaming-to-cassanadra' – Naresh

+0

@Naresh Non sono sicuro di come posso aiutare. Non ho mai lavorato con C *. – eliasah

2

Non si ottiene in bella forma tabellare invece verrà convertito in oggetto scala.

maxDF.take(50)