ChangeTrackingStorageConnector extends AbstractStorageConnector { @Override public <T> T unwrap(Class<T> cls) { return centralConnector.unwrap(cls); } ChangeTrackingStorageConnector(AbstractStorageConnector centralConnector); @Override void begin(); @Override void commit(); @Override void rollback(); @Override Collection<Statement> find(Resource subject, Property property, RDFNode value, String context); @Override boolean contains(Resource subject, Property property, RDFNode value, String context); @Override List<String> getContexts(); @Override void add(List<Statement> statements, String context); @Override void remove(List<Statement> statements, String context); @Override void remove(Resource subject, Property property, RDFNode object, String context); @Override AbstractResultSet executeSelectQuery(Query query, StatementOntology target); @Override AbstractResultSet executeAskQuery(Query query, StatementOntology target); @Override void executeUpdate(String query, StatementOntology target); @Override synchronized void close(); @Override T unwrap(Class<T> cls);  }
@Test public void unwrapPassesCallToUnderlyingSharedConnector() { final Dataset dataset = connector.unwrap(Dataset.class); assertSame(centralConnector.storage.dataset, dataset); }