本文整理了Java中org.locationtech.geowave.core.store.api.QueryBuilder.newBuilder方法的一些代码示例，展示了QueryBuilder.newBuilder的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QueryBuilder.newBuilder方法的具体详情如下：
包路径：org.locationtech.geowave.core.store.api.QueryBuilder
类名称：QueryBuilder
方法名：newBuilder

QueryBuilder.newBuilder介绍

[英]get a default query builder
[中]获取默认的查询生成器

代码示例

代码示例来源：origin: locationtech/geowave

public static void deleteAll(final DataStorePluginOptions dataStore) {
 dataStore.createDataStore().delete(QueryBuilder.newBuilder().build());
}

代码示例来源：origin: locationtech/geowave

protected <T> CloseableIterator<T> internalQuery(
  Query<T> query,
  final DeletionMode delete,
  final ScanCallback<T, ?> scanCallback) {
 if (query == null) {
  query = (Query) QueryBuilder.newBuilder().build();
 }
 // all queries will use the same instance of the dedupe filter for
 // client side filtering because the filter needs to be applied across
 // indices
 final BaseQueryOptions queryOptions =
   new BaseQueryOptions(query, adapterStore, internalAdapterStore, scanCallback);
 return internalQuery(query.getQueryConstraints(), queryOptions, delete);
}

代码示例来源：origin: locationtech/geowave

@Override
public synchronized void close() throws IOException {
 if (closed) {
  return;
 } else {
  closed = true;
 }
 for (final Map.Entry<ByteArray, Set<InsertionIdData>> entry : insertionIdsNotYetDeletedByDataId.entrySet()) {
  for (final InsertionIdData insertionId : entry.getValue()) {
   final InsertionIdQuery constraint =
     new InsertionIdQuery(
       insertionId.partitionKey,
       insertionId.sortKey,
       entry.getKey().getBytes());
   final Query<T> query =
     (Query) QueryBuilder.newBuilder().indexName(index.getName()).addTypeName(
       adapter.getTypeName()).constraints(constraint).build();
   // we don't want the duplicates to try to delete one another
   // recursively over and over so we pass false for this deletion
   dataStore.delete(query, false);
  }
 }
}

代码示例来源：origin: locationtech/geowave

@Override
 public Void computeResults(final OperationParams params) {
  // Ensure we have all the required arguments
  if (parameters.size() != 2) {
   throw new ParameterException("Requires arguments: <store name> <type name>");
  }

  final String inputStoreName = parameters.get(0);
  final String typeName = parameters.get(1);

  // Attempt to load store.
  final File configFile = getGeoWaveConfigFile(params);

  final StoreLoader inputStoreLoader = new StoreLoader(inputStoreName);
  if (!inputStoreLoader.loadFromConfig(configFile)) {
   throw new ParameterException("Cannot find store name: " + inputStoreLoader.getStoreName());
  }
  inputStoreOptions = inputStoreLoader.getDataStorePlugin();

  LOGGER.info("Deleting everything in store: " + inputStoreName + " with type name: " + typeName);
  inputStoreOptions.createDataStore().delete(
    QueryBuilder.newBuilder().addTypeName(typeName).build());
  return null;
 }
}

代码示例来源：origin: locationtech/geowave

@Override
 public Void computeResults(final OperationParams params) {
  if (parameters.size() < 1) {
   throw new ParameterException("Must specify store name");
  }

  final String inputStoreName = parameters.get(0);

  // Attempt to load store.
  final File configFile = getGeoWaveConfigFile(params);

  // Attempt to load input store.
  final StoreLoader inputStoreLoader = new StoreLoader(inputStoreName);
  if (!inputStoreLoader.loadFromConfig(configFile)) {
   throw new ParameterException("Cannot find store name: " + inputStoreLoader.getStoreName());
  }
  inputStoreOptions = inputStoreLoader.getDataStorePlugin();

  LOGGER.info("Deleting everything in store: " + inputStoreName);

  inputStoreOptions.createDataStore().delete(QueryBuilder.newBuilder().build());
  return null;
 }
}

代码示例来源：origin: locationtech/geowave

try (
  final CloseableIterator it = query(QueryBuilder.newBuilder().build())) {
 while (it.hasNext()) {
  writer.write(it.next());

代码示例来源：origin: locationtech/geowave

final JavaSparkContext context = new JavaSparkContext(sparkConf);
final RDDOptions rddOpts = new RDDOptions();
rddOpts.setQuery(QueryBuilder.newBuilder().constraints(query).build());
rddOpts.setMinSplits(minSplits);
rddOpts.setMaxSplits(maxSplits);

代码示例来源：origin: locationtech/geowave

private void loadStoresAndViews() throws IOException {
 final Collection<InputStoreInfo> addStores = inputStores.values();
 for (final InputStoreInfo storeInfo : addStores) {
  final RDDOptions rddOpts = new RDDOptions();
  rddOpts.setQuery(QueryBuilder.newBuilder().addTypeName(storeInfo.typeName).build());
  storeInfo.rdd =
    GeoWaveRDDLoader.loadRDD(session.sparkContext(), storeInfo.storeOptions, rddOpts);
  // Create a DataFrame from the Left RDD
  final SimpleFeatureDataFrame dataFrame = new SimpleFeatureDataFrame(session);
  if (!dataFrame.init(storeInfo.storeOptions, storeInfo.typeName)) {
   LOGGER.error("Failed to initialize dataframe");
   return;
  }
  LOGGER.debug(dataFrame.getSchema().json());
  final Dataset<Row> dfTemp = dataFrame.getDataFrame(storeInfo.rdd);
  dfTemp.createOrReplaceTempView(storeInfo.viewName);
 }
}

代码示例来源：origin: locationtech/geowave

@Override
 protected long runQuery(
   final GeotoolsFeatureDataAdapter adapter,
   final String typeName,
   final String indexName,
   final DataStore dataStore,
   final boolean debug,
   DataStorePluginOptions pluginOptions) {
  long count = 0;
  try (final CloseableIterator<Object> it =
    dataStore.query(
      QueryBuilder.newBuilder().addTypeName(typeName).indexName(indexName).build())) {
   while (it.hasNext()) {
    if (debug) {
     System.out.println(it.next());
    } else {
     it.next();
    }
    count++;
   }
  }
  return count;
 }
}

代码示例来源：origin: locationtech/geowave

rddOpts.setQuery(QueryBuilder.newBuilder().addTypeName(adapterTypeName).build());
rddOpts.setMinSplits(partCount);
rddOpts.setMaxSplits(partCount);

代码示例来源：origin: locationtech/geowave

@Override
 protected long runQuery(
   final GeotoolsFeatureDataAdapter adapter,
   final String typeName,
   final String indexName,
   final DataStore dataStore,
   final boolean debug,
   DataStorePluginOptions pluginOptions) {
  getFilter();

  long count = 0;
  try (final CloseableIterator<Object> it =
    dataStore.query(
      QueryBuilder.newBuilder().addTypeName(typeName).indexName(indexName).build())) {
   while (it.hasNext()) {
    final Object o = it.next();
    if (o instanceof SimpleFeature) {
     if (filter.evaluate(o)) {
      if (debug) {
       System.out.println(o);
      }
      count++;
     }
    }
   }
  }
  return count;
 }
}

代码示例来源：origin: locationtech/geowave

QueryBuilder.newBuilder().addTypeName(
      rasterResizeOptions.getOutputCoverageName()).indexName(index.getName()).build());
while (obj.hasNext()) {

代码示例来源：origin: locationtech/geowave

String typeName = dataAdapter.getTypeName();
try (CloseableIterator<?> it =
  store.query(QueryBuilder.newBuilder().addTypeName(typeName).limit(1).build())) {
 if (!it.hasNext()) {
  if (adapterStore == null) {

代码示例来源：origin: locationtech/geowave

try (CloseableIterator<?> entryIt =
  ((BaseDataStore) dataStore).query(
    QueryBuilder.newBuilder().addTypeName(adapter.getTypeName()).indexName(
      index.getName()).setAuthorizations(authorizations).build(),
    (ScanCallback) statsTool)) {

代码示例来源：origin: locationtech/geowave

private CloseableIterator<GridCoverage> queryForTiles(
  final RasterDataAdapter adapter,
  final QueryConstraints query,
  final double[] targetResolutionPerDimension) {
 final AdapterToIndexMapping adapterIndexMapping =
   geowaveAdapterIndexMappingStore.getIndicesForAdapter(getAdapterId(adapter.getTypeName()));
 final Index[] indices = adapterIndexMapping.getIndices(geowaveIndexStore);
 // just work on the first spatial only index that contains this adapter
 // ID
 // TODO consider the best strategy for handling temporal queries here
 for (final Index rasterIndex : indices) {
  if (SpatialDimensionalityTypeProvider.isSpatial(rasterIndex)) {
   return (CloseableIterator) geowaveDataStore.query(
     QueryBuilder.newBuilder().setAuthorizations(
       authorizationSPI.getAuthorizations()).addTypeName(
         adapter.getTypeName()).constraints(query).addHint(
           DataStoreUtils.TARGET_RESOLUTION_PER_DIMENSION_FOR_HIERARCHICAL_INDEX,
           targetResolutionPerDimension).build());
  }
 }
 return new Wrapper(Collections.emptyIterator());
}

代码示例来源：origin: locationtech/geowave

QueryBuilder.newBuilder().addTypeName(adapter.getTypeName()).indexName(
  index.getName()).setAuthorizations(authorizations).build(),
(ScanCallback) statsTool)) {

代码示例来源：origin: locationtech/geowave

/**
 * Build the query options from the command line arguments.
 *
 * @return
 */
public Query<?> buildQuery() {
 final QueryBuilder<?, ?> bldr = QueryBuilder.newBuilder();
 if ((queryOptions.getTypeNames() != null) && (queryOptions.getTypeNames().length > 0)) {
  bldr.setTypeNames(queryOptions.getTypeNames());
 }
 if (queryOptions.getAuthorizations() != null) {
  bldr.setAuthorizations(queryOptions.getAuthorizations());
 }
 if (queryOptions.getIndexName() != null) {
  bldr.indexName(queryOptions.getIndexName());
 }
 return bldr.build();
}

代码示例来源：origin: locationtech/geowave

final boolean deleteDuplicates) {
if (query == null) {
 query = (Query) QueryBuilder.newBuilder().build();

代码示例来源：origin: locationtech/geowave

queryOpts.setQuery(QueryBuilder.newBuilder().constraints(query).build());
queryOpts.setMinSplits(DEFAULT_SPLITS_FOR_COUNT);
queryOpts.setMaxSplits(DEFAULT_SPLITS_FOR_COUNT);

代码示例来源：origin: locationtech/geowave

other.addIndex(typeName, indices);
final QueryBuilder<?, ?> qb = QueryBuilder.newBuilder().addTypeName(typeName);
try (CloseableIterator<?> it = query(qb.build())) {
 try (final Writer writer = other.createWriter(typeName)) {