AccumuloTemporalIndexer extends AbstractAccumuloIndexer implements TemporalIndexer { @Override public CloseableIteration<Statement, QueryEvaluationException> queryInstantHasBeginningInterval( final TemporalInterval queryInterval, final StatementConstraints contraints) throws QueryEvaluationException { return queryInstantEqualsInstant(queryInterval.getHasBeginning(), contraints); }  @Override void init(); @Override void setConf(final Configuration conf); @Override Configuration getConf(); @Override void storeStatement(final RyaStatement statement); void removeInterval(final BatchWriter writer, final TemporalInterval interval, final Statement statement); void removeInstant(final BatchWriter writer, final TemporalInstant instant, final Statement statement); void addInterval(final BatchWriter writer, final TemporalInterval interval, final Statement statement); void addInstant(final BatchWriter writer, final TemporalInstant instant, final Statement statement); @Override CloseableIteration<Statement, QueryEvaluationException> queryInstantEqualsInstant(
            final TemporalInstant queryInstant, final StatementConstraints constraints); @Override CloseableIteration<Statement, QueryEvaluationException> queryInstantBeforeInstant(
            final TemporalInstant queryInstant, final StatementConstraints constraints); @Override CloseableIteration<Statement, QueryEvaluationException> queryInstantAfterInstant(
            final TemporalInstant queryInstant, final StatementConstraints constraints); @Override CloseableIteration<Statement, QueryEvaluationException> queryInstantBeforeInterval(
            final TemporalInterval givenInterval, final StatementConstraints contraints); @Override CloseableIteration<Statement, QueryEvaluationException> queryInstantAfterInterval(
            final TemporalInterval givenInterval, final StatementConstraints contraints); @Override CloseableIteration<Statement, QueryEvaluationException> queryInstantInsideInterval(
            final TemporalInterval queryInterval, final StatementConstraints constraints); @Override CloseableIteration<Statement, QueryEvaluationException> queryInstantHasBeginningInterval(
            final TemporalInterval queryInterval, final StatementConstraints contraints); @Override CloseableIteration<Statement, QueryEvaluationException> queryInstantHasEndInterval(
            final TemporalInterval queryInterval, final StatementConstraints contraints); @Override CloseableIteration<Statement, QueryEvaluationException> queryIntervalEquals(
            final TemporalInterval query, final StatementConstraints contraints); @Override CloseableIteration<Statement, QueryEvaluationException> queryIntervalBefore(
            final TemporalInterval queryInterval, final StatementConstraints constraints); @Override CloseableIteration<Statement, QueryEvaluationException> queryIntervalAfter(
            final TemporalInterval queryInterval, final StatementConstraints constraints); @Override Set<IRI> getIndexablePredicates(); @Override void flush(); @Override void close(); @Override String getTableName(); static String makeTableName(final String ryaInstanceName); @Override void deleteStatement(final RyaStatement statement); @Override void setConnector(final Connector connector); @Override void destroy(); @Override void purge(final RdfCloudTripleStoreConfiguration configuration); @Override void dropAndDestroy(); @Override void setMultiTableBatchWriter(MultiTableBatchWriter writer);  }
@Test public void testQueryInstantHasBeginningInterval() throws IOException, QueryEvaluationException { tIndexer.storeStatement(convertStatement(spo_B03_E20)); tIndexer.storeStatement(convertStatement(spo_B02_E30)); tIndexer.storeStatement(convertStatement(spo_B02_E40)); tIndexer.storeStatement(convertStatement(spo_B02_E31)); tIndexer.storeStatement(convertStatement(spo_B30_E32)); TemporalInterval searchInsideInterval = tvB02_E31; int searchSeconds = 2; int expectedResultCount = 1; for (int s = 0; s <= 10; s++) { tIndexer.storeStatement(convertStatement(seriesSpo[s])); } tIndexer.flush(); CloseableIteration<Statement, QueryEvaluationException> iter; iter = tIndexer.queryInstantHasBeginningInterval(searchInsideInterval, EMPTY_CONSTRAINTS); int count = 0; while (iter.hasNext()) { Statement s = iter.next(); Statement nextExpectedStatement = seriesSpo[searchSeconds]; assertTrue("Should match: " + nextExpectedStatement + " == " + s, nextExpectedStatement.equals(s)); count++; } Assert.assertEquals("Should find count of rows.", expectedResultCount, count); }