Package org.apache.blur.thrift.generated.Blur

Examples of org.apache.blur.thrift.generated.Blur.Iface.query()

69
70
71
72
73
74
75
76
77
78
79
      Selector s = new Selector();
      s.setRecordOnly(recordsOnly);
      s.setColumnFamiliesToFetch(new HashSet<String>(Arrays.asList(families)));
      blurQuery.setSelector(s);

      BlurResults blurResults = client.query(table, blurQuery);

      Map<String, Object> results = new HashMap<String, Object>();
      results.put(TOTAL_KEY, blurResults.getTotalResults());

      Map<String, List> rows = new HashMap<String, List>();
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
      BlurQuery blurQuery = new BlurQuery();

      Query q = new Query(query, true, ScoreType.SUPER, null, null);
      blurQuery.setQuery(q);
      blurQuery.setUserContext(remoteHost);
      BlurResults blurResults = client.query(table, blurQuery);

      Map<String, Object> results = new HashMap<String, Object>();
      results.put(TOTAL_KEY, blurResults.getTotalResults());
      return results;
    } finally {
View Full Code Here
166
167
168
169
170
171
172
173
174
175
176
    }

    String tableName = getTableName(store);
    Iface client = getClient();
    try {
      BlurResults results = client.query(tableName, blurQuery);
      List<String> rowIds = new ArrayList<String>();
      for (BlurResult result : results.getResults()) {
        FetchResult fetchResult = result.getFetchResult();
        FetchRowResult rowResult = fetchResult.getRowResult();
        String id = rowResult.getRow().getId();
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
    BlurQuery query = new BlurQuery(
        new Query("fam0.col0:*", true, ScoreType.SUPER, null, null),
        null,
        null, //new Selector(false, null, null, null, null, null, 0, 10, null),
        false, 0, 10, 1, 2000, UUID.randomUUID().toString(), "testUser", false, System.currentTimeMillis(), null, null);
    client.query("queryUnitTable", query);

    assertEquals(1, QueryUtil.getCurrentQueryCount());
  }

  @SuppressWarnings("unchecked")
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
    BlurQuery query = new BlurQuery(
        new Query("fam0.col0:*", true, ScoreType.SUPER, null, null),
        null,
        null, //new Selector(false, null, null, null, null, null, 0, 10, null),
        false, 0, 10, 1, 2000, UUID.randomUUID().toString(), "testUser", false, System.currentTimeMillis(), null, null);
    client.query("queryUnitTable", query);

    Map<String, Object> queries = QueryUtil.getQueries();

    assertEquals(0, queries.get("slowQueries"));
    assertEquals(2, ((List<Map<String, Object>>) queries.get("queries")).size());
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
    query.setQuery(queryStr);

    blurQuery.addToFacets(new Facet("fam1.col1:value1 OR fam1.col1:value2", 10000));
    blurQuery.addToFacets(new Facet("fam1.col1:value100 AND fam1.col1:value200", Long.MAX_VALUE));

    BlurResults results = client.query(tableName, blurQuery);
    System.out.println("Total Results: " + results.totalResults);

    List<Long> facetCounts = results.getFacetCounts();
    List<Facet> facets = blurQuery.getFacets();
    for (int i = 0; i < facets.size(); i++) {
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
    final BlurQuery blurQuery = new BlurQuery();
    Query query = new Query();
    blurQuery.setQuery(query);
    query.setQuery(queryStr);
    blurQuery.setSelector(new Selector());
    BlurResults results = client.query(tableName, blurQuery);
    System.out.println("Total Results: " + results.totalResults);

    for (BlurResult result : results.getResults()) {
      System.out.println(result);
    }
View Full Code Here
297
298
299
300
301
302
303
304
305
306
307
    Query queryRow = new Query();
    queryRow.setQuery("test.test:value");
    blurQueryRow.setQuery(queryRow);
    blurQueryRow.setUseCacheIfPresent(false);
    blurQueryRow.setCacheResult(false);
    BlurResults resultsRow = client.query(tableName, blurQueryRow);
    assertRowResults(resultsRow);
    assertEquals(numberOfDocs * pass, resultsRow.getTotalResults());

    BlurQuery blurQueryRecord = new BlurQuery();
    Query queryRecord = new Query();
View Full Code Here
306
307
308
309
310
311
312
313
314
315
316
    BlurQuery blurQueryRecord = new BlurQuery();
    Query queryRecord = new Query();
    queryRecord.rowQuery = false;
    queryRecord.setQuery("test.test:value");
    blurQueryRecord.setQuery(queryRecord);
    BlurResults resultsRecord = client.query(tableName, blurQueryRecord);
    assertRecordResults(resultsRecord);
    assertEquals(numberOfDocs * pass, resultsRecord.getTotalResults());

    Schema schema = client.schema(tableName);
    assertFalse(schema.getFamilies().isEmpty());
View Full Code Here
328
329
330
331
332
333
334
335
336
337
338
    blurQueryRow.setQuery(queryRow);
    blurQueryRow.setUseCacheIfPresent(false);
    blurQueryRow.setCacheResult(false);
    blurQueryRow.setSelector(new Selector());

    BlurResults resultsRow = client.query(tableName, blurQueryRow);
    // assertRowResults(resultsRow);
    assertEquals(numberOfDocs, resultsRow.getTotalResults());

    for (BlurResult blurResult : resultsRow.getResults()) {
      System.out.println(blurResult);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.