code: @Override
      public <E> List<E> getColumnsById(String schemaName, String tableName, String pKeyColumnName, String columnName,
              Object pKeyColumnValue, Class columnJavaType)
      {
          // fetch list ADDRESS_ID for given PERSON_ID
          QueryBuilder filterBuilder = new TermQueryBuilder(pKeyColumnName, pKeyColumnValue);
  
          SearchResponse response = txClient.prepareSearch(schemaName.toLowerCase()).setTypes(tableName)
                  .setPostFilter(filterBuilder).addField(columnName).execute().actionGet();
  
          SearchHits hits = response.getHits();
  
          List columns = new ArrayList();
          for (SearchHit hit : hits.getHits())
          {
              Map<String, SearchHitField> fields = hit.getFields();
              columns.add(fields.get(columnName).getValue());
          }
  
          return columns;
      }
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)