code: public static CassandraCpoAdapter getInstance(CassandraCpoMetaDescriptor metaDescriptor, DataSourceInfo<ClusterDataSource> cdsiTrx) throws CpoException {
      String adapterKey = metaDescriptor + ":" + cdsiTrx.getDataSourceName();
      CassandraCpoAdapter adapter = (CassandraCpoAdapter) findCpoAdapter(adapterKey);
      if (adapter == null) {
        adapter = new CassandraCpoAdapter(metaDescriptor, cdsiTrx);
        addCpoAdapter(adapterKey, adapter);
      }
      return adapter;
    }
docs: Creates a CassandraCpoAdapter.
  
  @param metaDescriptor This datasource that identifies the cpo metadata datasource
  @param cdsiTrx        The datasource that identifies the transaction database for read and write transactions.
  @throws org.synchronoss.cpo.CpoException
  exception