2013-08-22 13 views
7

Sto cercando di ottenere i nomi delle colonne ma non è possibile ottenere il modo di ottenere solo i nomi delle colonne.in cassandra-cli come ottenere tutti i nomi di colonna in una tabella e come ottenerlo usando hector in java?

In cli ho eseguito il comando describe table nodes, è restituito il risultato:

CREATE TABLE nodes (
    key text PRIMARY KEY, 
    id text, 
    scores text, 
    topic1 text, 
    topic2 text, 
    topic3 text, 
    topic4 text, 
    topics text 
) WITH COMPACT STORAGE AND 
    bloom_filter_fp_chance=0.010000 AND 
    caching='KEYS_ONLY' AND 
    comment='' AND 
    dclocal_read_repair_chance=0.000000 AND 
    gc_grace_seconds=864000 AND 
    read_repair_chance=0.100000 AND 
    replicate_on_write='true' AND 
    populate_io_cache_on_flush='false' AND 
    compaction={'class': 'SizeTieredCompactionStrategy'} AND 
    compression={'sstable_compression': 'SnappyCompressor'}; 

CREATE INDEX idx_nodes_id ON nodes (id); 

come indicato in questo question, ho prova utilizzando seguente comando nella CLI:

SELECT column_name FROM system.schema_columnfamilies WHERE keyspace_name = 'ianew' AND columnfamily_name = 'nodes'; 

ma ha dato l'errore:

Bad Request: Undefined name column_name in selection clause 
Perhaps you meant to use CQL 2? Try using the -2 option when starting cqlsh. 

Quindi ho provato con:

SELECT * FROM system.schema_columnfamilies WHERE keyspace_name = 'ianew' AND columnfamily_name = 'nodes'; 

tornò tutte le seguenti cose:

keyspace_name | columnfamily_name | bloom_filter_fp_chance | caching | column_aliases | comment | compaction_strategy_class          | compaction_strategy_options | comparator        | compression_parameters              | default_read_consistency | default_validator      | default_write_consistency | gc_grace_seconds | id | key_alias | key_aliases | key_validator       | local_read_repair_chance | max_compaction_threshold | min_compaction_threshold | populate_io_cache_on_flush | read_repair_chance | replicate_on_write | subcomparator | type  | value_alias 
---------------+-------------------+------------------------+-----------+----------------+---------+-----------------------------------------------------------------+-----------------------------+------------------------------------------+-----------------------------------------------------------------------------+--------------------------+------------------------------------------+---------------------------+------------------+------+-----------+-------------+------------------------------------------+--------------------------+--------------------------+--------------------------+----------------------------+--------------------+--------------------+---------------+----------+------------- 
     ianew |    nodes |     null | KEYS_ONLY |    [] |   | org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy |       {} | org.apache.cassandra.db.marshal.UTF8Type | {"sstable_compression":"org.apache.cassandra.io.compress.SnappyCompressor"} |      null | org.apache.cassandra.db.marshal.UTF8Type |      null |   864000 | null |  null |   [] | org.apache.cassandra.db.marshal.UTF8Type |      0 |      32 |      4 |      False |    0.1 |    True |   null | Standard |  null 

come indicato in questo post, ho provato ad utilizzare hector in Java:

SliceQuery<String, String, String> query = HFactory.createSliceQuery(keyspace, StringSerializer.get(), StringSerializer.get(), StringSerializer.get()); 
query.setColumnFamily(columnFamilyName); 
query.setKey("key"); 
query.setRange(null, null, false, Integer.MAX_VALUE); 

ColumnSliceIterator<String, String, String> iterator = new ColumnSliceIterator<String, String, String>(query, null, "\uFFFF", false); 

while (iterator.hasNext()) { 
    HColumnImpl<String, String> column = (HColumnImpl<String, String>) iterator.next(); 
    System.out.println("Column name = " + column.getName() + "; Column value = " + column.getValue()); 
    colNames.add(column.getName()); 
} 

ma tornato senza risultati.

voglio uscita essere qualcosa di simile:

TABLE nodes: 
Columns: key text PRIMARY KEY, id text, scores text, topic1 text, topic2 text, topic3 text, topic4 text, topics text 

e risultato simile attraverso Hector.

versioni che sto usando:

[cqlsh 2.3.0 | Cassandra 1.2.4 | CQL spec 3.0.0 | Thrift protocol 19.35.0] 

risposta

10

In cassandra 1.1 che sarebbe davvero lavorare, ma la famiglia schema_columnfamilies colonna è stata modificata da allora.

Bad Request: Undefined name column_name in selection clause

In Cassandra informazioni 1.2.x sulle colonne vive in uno spazio delle chiavi separata denominata schema_columns con il seguente schema:

CREATE TABLE schema_columns (
    keyspace_name text, 
    columnfamily_name text, 
    column_name text, 
    component_index int, 
    index_name text, 
    index_options text, 
    index_type text, 
    validator text, 
    PRIMARY KEY (keyspace_name, columnfamily_name, column_name) 
); 

provare qualcosa in queste righe:

SELECT * FROM system.schema_columns 
WHERE keyspace_name = 'ianew' AND columnfamily_name = 'nodes'; 

Documentation su quale sia il contenuto dello spazio chiavi del sistema.

+0

ya .. Io provo tutte quelle cose possibili. Ancora risulta in errore .. per query 'SELECT column_aliases FROM system.schema_columnfamilies WHERE keyspace_name = 'ianew' AND columnfamily_name = 'nodes';', Questo ha restituito il risultato: 'column_aliases ----------- ----- [] ' –

+0

@NDThokare Elaborerò la domanda. In realtà stiamo dopo CF schema_columns piuttosto che schema_columnfamilies: http://www.datastax.com/dev/blog/the-data-dictionary-in-cassandra-1-2 –

+0

grazie a @Lyuben, è vero .. ora ho ottenuto il risultato usando 'SELECT nome_colonna FROM system.schema_columnfamilies WHERE keyspace_name = 'ianew' AND columnfamily_name = 'nodes';' –

Problemi correlati