class SnapshotStorageConnector extends SharedStorageConnector {

    @Override
    public void begin() {
        ensureOpen();
        if (transaction.isActive()) {
            throw new IllegalStateException("Transaction is already active.");
        }
        transaction.begin();
        snapshotCentralDataset();
        this.transactionalUpdates = new ArrayList<>();
        this.transactionalChanges = new LocalModel(configuration.is(JenaConfigParam.TREAT_DEFAULT_GRAPH_AS_UNION));
    }

      SnapshotStorageConnector(AbstractStorageConnector centralConnector);

}