X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=champ-lib%2Fchamp-janus%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Faai%2Fchampjanus%2Fgraph%2Fimpl%2FJanusChampGraphImpl.java;fp=champ-lib%2Fchamp-janus%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Faai%2Fchampjanus%2Fgraph%2Fimpl%2FJanusChampGraphImpl.java;h=ea90ce99f36252390fce953f4ded7f8e066d656f;hb=f2bf2ab992260d1896d0f4b6f947bbf80b82eb07;hp=f150b44b0dcc9c03e558d41ce8eed2ba2d483a51;hpb=0338683186c994d579b1ec297604dba59df73dff;p=aai%2Fchamp.git diff --git a/champ-lib/champ-janus/src/main/java/org/onap/aai/champjanus/graph/impl/JanusChampGraphImpl.java b/champ-lib/champ-janus/src/main/java/org/onap/aai/champjanus/graph/impl/JanusChampGraphImpl.java index f150b44..ea90ce9 100644 --- a/champ-lib/champ-janus/src/main/java/org/onap/aai/champjanus/graph/impl/JanusChampGraphImpl.java +++ b/champ-lib/champ-janus/src/main/java/org/onap/aai/champjanus/graph/impl/JanusChampGraphImpl.java @@ -50,6 +50,7 @@ import java.util.stream.StreamSupport; public final class JanusChampGraphImpl extends AbstractTinkerpopChampGraph { private static final Logger LOGGER = LoggerFactory.getLogger(JanusChampGraphImpl.class); private static final String JANUS_CASSANDRA_KEYSPACE = "storage.cassandra.keyspace"; + private static final String JANUS_CQL_KEYSPACE = "storage.cql.keyspace"; private static final String JANUS_HBASE_TABLE = "storage.hbase.table"; private static final String JANUS_UNIQUE_SUFFIX = "graph.unique-instance-id-suffix"; private static final ChampSchemaEnforcer SCHEMA_ENFORCER = new DefaultChampSchemaEnforcer(); @@ -87,8 +88,10 @@ public final class JanusChampGraphImpl extends AbstractTinkerpopChampGraph { "cassandrathrift".equals(storageBackend) || "astyanax".equals(storageBackend) || "embeddedcassandra".equals(storageBackend)) { - - janusGraphBuilder.set(JANUS_CASSANDRA_KEYSPACE, builder.graphName); + + janusGraphBuilder.set(JANUS_CASSANDRA_KEYSPACE, builder.graphName); + } else if("cql".equals(storageBackend)){ + janusGraphBuilder.set(JANUS_CQL_KEYSPACE, builder.graphName); } else if ("hbase".equals(storageBackend)) { janusGraphBuilder.set(JANUS_HBASE_TABLE, builder.graphName); } else if ("berkleyje".equals(storageBackend)) {