前言

上一篇文章中利用GeoWave导入矢量数据到HBase/Accumulo数据库-CSDN博客，我介绍了如何利用GeoWave导入数据到HBase/Accumulo数据库中，本文，我将介绍如何使用GeoWave实现简单的时空范围查询。

代码

java"> HBaseRequiredOptions hBaseRequiredOptions = new HBaseRequiredOptions();hBaseRequiredOptions.setZookeeper("localhost:2181");HBaseDataStore hBaseDataStore = (HBaseDataStore) DataStoreFactory.createDataStore(hBaseRequiredOptions);System.out.println("connect hbase success!");SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss");Date startTime = sdf.parse("2013-01-01T12:10:01");Date endTime = sdf.parse("2013-01-31T12:11:01");// 使用 format()方法格式化时间String startTimeFormatted = sdf.format(startTime);String endTimeFormatted = sdf.format(endTime);Long startTimeStamp = System.currentTimeMillis();VectorQueryBuilder queryBuilder = VectorQueryBuilder.newBuilder();queryBuilder.indexName("track_point_idx");queryBuilder.addTypeName("track_point");VectorQueryConstraintsFactory vectorQueryConstraintsFactory = queryBuilder.constraintsFactory();Query<SimpleFeature> queryOptions = queryBuilder.constraints(vectorQueryConstraintsFactory.cqlConstraints("BBOX(the_geom, 111.6, 21.31, 111.7, 21.41) " +" and " + "( timestamp >= " + startTimeFormatted + " and timestamp <= " + endTimeFormatted + ")")).build();List<SimpleFeature> simpleFeatures = new ArrayList<>();try (final CloseableIterator<SimpleFeature> iterator =hBaseDataStore.query(queryOptions)) {while (iterator.hasNext()) {SimpleFeature feature = iterator.next();simpleFeatures.add(feature);}System.out.println("size:" + simpleFeatures.size());}

参考资料

GeoWave Developer Guide