Package org.apache.blur.thrift.generated

Examples of org.apache.blur.thrift.generated.Selector

568
569
570
571
572
573
574
575
576
577
578
579
    }
    if (selector != null) {
      List<Future<FetchResult>> futures = new ArrayList<Future<FetchResult>>();
      for (int i = 0; i < results.results.size(); i++) {
        BlurResult result = results.results.get(i);
        final Selector s = new Selector(selector);
        s.setLocationId(result.locationId);
        futures.add(executor.submit(new Callable<FetchResult>() {
          @Override
          public FetchResult call() throws Exception {
            return iface.fetchRow(table, s);
          }
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
69
  private void doItInternal(Blur.Iface client, String[] args, PagingPrintWriter out) throws BlurException, TException,
      FinishedException {
    String tablename = args[1];
    String rowId = args[2];

    Selector selector = new Selector(Main.selector);
    selector.setRowId(rowId);
    FetchResult fetchRow = client.fetchRow(tablename, selector);
    FetchRowResult rowResult = fetchRow.getRowResult();
    if (rowResult == null) {
      out.println("Row [" + rowId + "] not found.");
      return;
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
    BlurQuery blurQuery = new BlurQuery();
    Query query = new Query();
    query.setQuery(queryStr);
    blurQuery.setQuery(query);
    blurQuery.setSelector(new Selector(Main.selector));
    blurQuery.setCacheResult(false);
    blurQuery.setUseCacheIfPresent(false);

    if (Main.highlight) {
      blurQuery.getSelector().setHighlightOptions(new HighlightOptions());
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
        } else {
          out.println(family + " - " + new TreeSet<String>(columnsToFetch.get(family)));
        }
      }
    } else if (command.equals("reset")) {
      Main.selector = new Selector();
    } else if (command.equals("add")) {
      if (args.length < 3) {
        throw new CommandException("Invalid args: " + help());
      }
      String family = args[2];
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
    return blurQuery;
  }

  private static void maybeAddSelector(BlurQuery blurQuery, SolrParams p) {
    String fieldString = p.get(CommonParams.FL);
    Selector selector = new Selector();
    selector.setRecordOnly(true);

    if (fieldString != null) {
      Map<String, Set<String>> famCols = Maps.newHashMap();
      String[] fields = fieldString.split(",");

      for (String field : fields) {
        String[] famCol = field.split("\\.");

        if (famCol.length != 2) {
          throw new IllegalArgumentException("Fields must be in a family.column format[" + field + "]");
        }
        if (!famCols.containsKey(famCol[0])) {
          famCols.put(famCol[0], new HashSet<String>());
        }
        Set<String> cols = famCols.get(famCol[0]);
        cols.add(famCol[1]);
      }
      selector.setColumnsToFetch(famCols);

    }
    blurQuery.setSelector(selector);
  }
View Full Code Here
233
234
235
236
237
238
239
240
241
242
243
  }

  public List<FetchResult> fetchRowBatch(final String table, List<Selector> selectors) throws BlurException {
    List<Future<FetchResult>> futures = new ArrayList<Future<FetchResult>>();
    for (Selector s : selectors) {
      final Selector selector = s;
      futures.add(_executor.submit(new Callable<FetchResult>() {
        @Override
        public FetchResult call() throws Exception {
          FetchResult fetchResult = new FetchResult();
          fetchRow(table, selector, fetchResult);
View Full Code Here
605
606
607
608
609
610
611
612
613
614
615
616
          @Override
          public BlurResult next() throws BlurException {
            BlurResult result = iterator.next();
            String locationId = result.getLocationId();
            FetchResult fetchResult = new FetchResult();
            Selector s = new Selector(selector);
            s.setLocationId(locationId);
            fetchRow(table, s, fetchResult);
            result.setFetchResult(fetchResult);
            return result;
          }
View Full Code Here
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
      });
    }

    @Override
    void performAction(IndexSearcherClosable searcher, IndexWriter writer) throws IOException {
      Selector selector = new Selector();
      selector.setRowId(_rowId);
      IndexManager.populateSelector(searcher, _shard, _table, selector);
      Row row = null;
      if (!selector.getLocationId().equals(IndexManager.NOT_FOUND)) {
        FetchResult fetchResult = new FetchResult();
        IndexManager.fetchRow(searcher.getIndexReader(), _table, _shard, selector, fetchResult, null, null, _maxHeap,
            _tableContext, null);
        FetchRowResult rowResult = fetchResult.getRowResult();
        if (rowResult != null) {
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
100
101
    // List<Facet> facets;
    // List<SortField> sortFields;

    BlurQuery blurQuery = new BlurQuery();
    blurQuery.setQuery(query);
    Selector selector = new Selector(Main.selector);
    if (!query.isRowQuery()) {
      selector.setRecordOnly(true);
    }
    blurQuery.setSelector(selector);
    blurQuery.setCacheResult(false);
    blurQuery.setUseCacheIfPresent(false);
View Full Code Here
31
32
33
34
35
36
37
38
39
import org.apache.blur.thrift.generated.Query;

public class BlurThriftHelper {

  public static Selector newSelector(String locationId) {
    Selector selector = new Selector();
    selector.locationId = locationId;
    return selector;
  }
View Full Code Here
TOP

Related Classes of org.apache.blur.thrift.generated.Selector

  • org.apache.blur.jdbc.BlurResultSetRecords
  • org.apache.blur.jdbc.BlurResultSetRows
  • org.apache.blur.manager.IndexManager
  • org.apache.blur.manager.IndexManagerTest
  • org.apache.blur.manager.writer.MutatableAction$UpdateRow
  • org.apache.blur.mapreduce.BlurReducer
  • org.apache.blur.shell.GetRowCommand
  • org.apache.blur.shell.QueryCommandHelper
  • org.apache.blur.shell.QueryCommandOld
  • org.apache.blur.shell.SelectorCommand
    • Copyright © 2018 www.massapicom. 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.