@Test public void testInfer() throws IOException { final int pre = countStatementsInStore(null); final TripleTransaction transaction = this.store.begin(false); final boolean[] doneReached = new boolean[] { false }; transaction.infer(new Handler<Statement>() { @Override public void handle(@Nullable final Statement element) { if (element == null) { doneReached[0] = true; } } }); final int post = countStatementsInStore(null); assertTrue(doneReached[0]); assertEquals(0, post - pre); }
@Override public TripleTransaction begin(final boolean readOnly) throws DataCorruptedException, IOException { if (existsTransactionMarker()) { throw new DataCorruptedException("The triple store performed a bulk operation " + "that didn't complete successfully."); } return new VirtuosoTripleTransaction(this, readOnly); }
VirtuosoTripleStore implements TripleStore { @Override public TripleTransaction begin(final boolean readOnly) throws DataCorruptedException, IOException { if (existsTransactionMarker()) { throw new DataCorruptedException("The triple store performed a bulk operation " + "that didn't complete successfully."); } return new VirtuosoTripleTransaction(this, readOnly); } }
VirtuosoTripleStore implements TripleStore { @Override public TripleTransaction begin(final boolean readOnly) throws DataCorruptedException, IOException { if (existsTransactionMarker()) { throw new DataCorruptedException("The triple store performed a bulk operation " + "that didn't complete successfully."); } return new VirtuosoTripleTransaction(this, readOnly); } VirtuosoTripleStore(final FileSystem fileSystem, @Nullable final String host,
            @Nullable final Integer port, @Nullable final String username,
            @Nullable final String password);  VirtuosoTripleStore(final FileSystem fileSystem, @Nullable final String host,
            @Nullable final Integer port, @Nullable final String username,
            @Nullable final String password, @Nullable final Boolean pooling,
            @Nullable final Integer batchSize, @Nullable final Integer fetchSize,
            @Nullable final String markerFilename); }
VirtuosoTripleStore implements TripleStore { @Override public TripleTransaction begin(final boolean readOnly) throws DataCorruptedException, IOException { if (existsTransactionMarker()) { throw new DataCorruptedException("The triple store performed a bulk operation " + "that didn't complete successfully."); } return new VirtuosoTripleTransaction(this, readOnly); } VirtuosoTripleStore(final FileSystem fileSystem, @Nullable final String host,
            @Nullable final Integer port, @Nullable final String username,
            @Nullable final String password);  VirtuosoTripleStore(final FileSystem fileSystem, @Nullable final String host,
            @Nullable final Integer port, @Nullable final String username,
            @Nullable final String password, @Nullable final Boolean pooling,
            @Nullable final Integer batchSize, @Nullable final Integer fetchSize,
            @Nullable final String markerFilename); @Override void init(); @Override TripleTransaction begin(final boolean readOnly); @Override void reset(); @Override void close(); @Override String toString(); }
VirtuosoTripleStore implements TripleStore { @Override public TripleTransaction begin(final boolean readOnly) throws DataCorruptedException, IOException { if (existsTransactionMarker()) { throw new DataCorruptedException("The triple store performed a bulk operation " + "that didn't complete successfully."); } return new VirtuosoTripleTransaction(this, readOnly); } VirtuosoTripleStore(final FileSystem fileSystem, @Nullable final String host,
            @Nullable final Integer port, @Nullable final String username,
            @Nullable final String password);  VirtuosoTripleStore(final FileSystem fileSystem, @Nullable final String host,
            @Nullable final Integer port, @Nullable final String username,
            @Nullable final String password, @Nullable final Boolean pooling,
            @Nullable final Integer batchSize, @Nullable final Integer fetchSize,
            @Nullable final String markerFilename); @Override void init(); @Override TripleTransaction begin(final boolean readOnly); @Override void reset(); @Override void close(); @Override String toString();  }