code: @Override
      public <E> List<E> getColumnsById(String schemaName, String tableName, String pKeyColumnName, String columnName,
          Object pKeyColumnValue, Class columnJavaType) {
          // select columnName from tableName where pKeyColumnName =
          // pKeyColumnValue
          List results = new ArrayList();
          CQLTranslator translator = new CQLTranslator();
          String selectQuery = translator.SELECT_QUERY;
          selectQuery = StringUtils.replace(selectQuery, CQLTranslator.COLUMN_FAMILY,
              translator.ensureCase(new StringBuilder(), tableName, false).toString());
          selectQuery = StringUtils.replace(selectQuery, CQLTranslator.COLUMNS,
              translator.ensureCase(new StringBuilder(), columnName, false).toString());
  
          StringBuilder selectQueryBuilder = new StringBuilder(selectQuery);
  
          selectQueryBuilder.append(CQLTranslator.ADD_WHERE_CLAUSE);
  
          translator.buildWhereClause(selectQueryBuilder, columnJavaType, pKeyColumnName, pKeyColumnValue,
              CQLTranslator.EQ_CLAUSE, false);
          selectQueryBuilder.delete(selectQueryBuilder.lastIndexOf(CQLTranslator.AND_CLAUSE),
              selectQueryBuilder.length());
  
          ResultSet rSet = execute(selectQueryBuilder.toString(), null);
  
          Iterator<Row> rowIter = rSet.iterator();
          while (rowIter.hasNext()) {
              Row row = rowIter.next();
              DataType dataType = row.getColumnDefinitions().getType(columnName);
              Object columnValue =
                  DSClientUtilities.assign(row, null, null, dataType.getName(), null, columnName, null, null);
              results.add(columnValue);
          }
          return results;
      }
docs: /*
  (non-Javadoc)
  
  @see com.impetus.kundera.client.Client#getColumnsById(java.lang.String, java.lang.String, java.lang.String,
  java.lang.String, java.lang.Object, java.lang.Class)