Examples of scan()

Examples of ch.agent.crnickl.api.Property.scan()

86
87
88
89
90
91
92
93
94
95
96
  public void testGetByAttributeValue() {
    try {
      @SuppressWarnings("rawtypes")
      Property ticker = db.getProperty("Ticker", true);
      @SuppressWarnings("unchecked")
      List<Chronicle> result = ticker.getChronicles(ticker.scan("SUN"), 42);
      assertEquals(2, result.size());
    } catch (Exception e) {
      fail(e.getMessage());
    }
  }
View Full Code Here

Examples of cleo.search.util.ConnectionsScanner.scan()

88
89
90
91
92
93
94
95
96
97
98
                                         connSourceIdCount,
                                         connTargetIdStart,
                                         connTargetIdCount);
   
    ConnectionsScanner scanner = new ConnectionsScanner(connectionsDir);
    scanner.scan(bootstrap);
    connectionsStore.sync();
   
    System.out.printf("Bootstrap done in %d ms%n", c.tick());
  }
}
View Full Code Here

Examples of cleo.search.util.ElementScoreScanner.scan()

79
80
81
82
83
84
85
86
87
88
89
   
    // Load element scores
    if(elementStoreDir != null && elementScoreDir.exists()) {
      ElementScoreSetter<TypeaheadElement> handler = new ElementScoreSetter<TypeaheadElement>(elementStore);
      ElementScoreScanner scan = new ElementScoreScanner(elementScoreDir);
      scan.scan(handler);
    }
   
    // Create connectionsStore
    int indexSegmentFileSizeMB = 8;
    SegmentFactory indexSegmentFactory = new MemorySegmentFactory();
View Full Code Here

Examples of cleo.search.util.TermsScanner.scan()

179
180
181
182
183
184
185
186
187
188
189
    elementStoreBootstrap.loadLine2(line2Dir);
    elementStoreBootstrap.loadLine3(line3Dir);
    elementStoreBootstrap.loadMedia(mediaDir);
   
    TermsScanner scanner = new TermsScanner(termsDir);
    scanner.scan(new CompositeTermsHandler().add(new TermsDedup()).add(elementStoreBootstrap));
    elementStore.sync();
   
    System.out.printf("Bootstrap done in %d ms%n", c.tick());
  }
}
View Full Code Here

Examples of co.cask.cdap.metrics.data.AggregatesTable.scan()

182
183
184
185
186
187
188
189
190
191
192
    // process.events.processed will have a tag like "input.queue://PurchaseFlow/reader/queue" which indicates
    // where the processed event came from.  So first get the aggregate count for events processed and all the
    // queues they came from. Next, for all those queues, get the aggregate count for events they wrote,
    // and subtract the two to get queue length.
    AggregatesScanner scanner = aggregatesTable.scan(metricsRequest.getContextPrefix(),
                                                     "process.events.processed",
                                                     metricsRequest.getRunId(),
                                                     "input");

    long processed = 0;
View Full Code Here

Examples of com.alibaba.antx.config.entry.ConfigEntry.scan()

350
351
352
353
354
355
356
357
358
359
360
            File destFile = destFiles[i];
            File outputFile = outputFiles[i];

            ConfigEntry entry = getConfigEntryFactory().create(new ConfigResource(destFile), outputFile, type);

            entry.scan();

            if (includeEmptyEntries || !entry.isEmpty()) {
                entries.add(entry);
            }
        }
View Full Code Here

Examples of com.alibaba.antx.util.scanner.DirectoryScanner.scan()

52
53
54
55
56
57
58
59
60
61
62
    protected void scan(InputStream istream) {
        Handler handler = new Handler();
        Scanner scanner = new DirectoryScanner(getConfigEntryResource().getFile(), handler);

        try {
            scanner.scan();
        } catch (ScannerException e) {
            throw new ConfigException(e);
        }

        subEntries = handler.getSubEntries();
View Full Code Here

Examples of com.alibaba.antx.util.scanner.Scanner.scan()

52
53
54
55
56
57
58
59
60
61
62
    protected void scan(InputStream istream) {
        Handler handler = new Handler();
        Scanner scanner = new DirectoryScanner(getConfigEntryResource().getFile(), handler);

        try {
            scanner.scan();
        } catch (ScannerException e) {
            throw new ConfigException(e);
        }

        subEntries = handler.getSubEntries();
View Full Code Here

Examples of com.alibaba.antx.util.scanner.ZipScanner.scan()

67
68
69
70
71
72
73
74
75
76
77
        ZipScanner scanner = new ZipScanner(getConfigEntryResource().getURL(), handler);

        scanner.setInputStream(istream);

        try {
            scanner.scan();
        } catch (ScannerException e) {
            throw new ConfigException(e);
        }

        subEntries = handler.getSubEntries();
View Full Code Here

Examples of com.alibaba.wasp.client.ClientProtocol.scan()

920
921
922
923
924
925
926
927
928
929
930
                action, scannerId == -1 ? false : true, scannerId, false);
            scannerId = response.getScannerId();
          } else {// rpc
            ClientProtocol clientProtocol = connection.getClient(
                serverName.getHostname(), serverName.getPort());
            response = clientProtocol.scan(null,
                RequestConverter.buildScanRequest(action, scannerId, false));
            scannerId = response.getScannerId();
          }
          if (nameDataTypePairs.isEmpty()) {
            nameDataTypePairs.addAll(response.getMetaList());
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.