@Test public void testAddBulkDifferentContexts() throws IOException { for (int i = 1; i <= BULK_MULTICONTEXT_STATEMENT_COUNT / BULK_MULTICONTEXT_CONTEXT_SIZE; i++) { final VirtuosoTripleTransaction transaction = (VirtuosoTripleTransaction) this.store .begin(false); try { final long beginTime = System.currentTimeMillis(); final int contextCount = BULK_MULTICONTEXT_CONTEXT_SIZE * i; transaction.addBulk( createFakeStatements(BULK_MULTICONTEXT_STATEMENT_COUNT, contextCount), false); final long endTime = System.currentTimeMillis(); System.out.printf("Added statements: %d, Contexts: %d, statements/context: " + "%f, elapsed time: %d, statements/ms: %f\n", BULK_MULTICONTEXT_STATEMENT_COUNT, contextCount, BULK_MULTICONTEXT_STATEMENT_COUNT / (float) contextCount, endTime - beginTime, BULK_MULTICONTEXT_STATEMENT_COUNT / (float) (endTime - beginTime)); } finally { transaction.end(true); } } }
@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();  }