Advertisement
Guest User

Untitled

a guest
Jul 24th, 2020
109
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 3.74 KB | None | 0 0
  1. public class StorageBackendKey {
  2.  
  3.     private static final String STORAGE_BACKEND_KEY = "storage.backend";
  4.  
  5.     private static final String STORAGE_HOSTNAME_KEY = "storage.hostname";
  6.     private static final String STORAGE_DIRECTORY_KEY = "storage.directory";
  7.  
  8.     private static final String STORAGE_HBASE_TABLE_KEY = "storage.hbase.table";
  9.  
  10.     private static final String STORAGE_CASSANDRA_KEYSPACE_KEY = "storage.cassandra.keyspace";
  11.     private static final String STORAGE_CQL_KEYSPACE_KEY = "storage.cql.keyspace";
  12.  
  13.     private String backend_type;
  14.  
  15.     private String storage_path;
  16.  
  17.     private String storage_instance;
  18.  
  19.     public StorageBackendKey(Configuration configuration) {
  20.         backend_type = configuration.getString(STORAGE_BACKEND_KEY);
  21.  
  22.         if(backend_type.equals("hbase")
  23.                 || backend_type.equals("cql")
  24.                 || backend_type.equals("cassandrathrift")
  25.                 || backend_type.equals("cassandra")
  26.                 || backend_type.equals("embeddedcassandra")) {
  27.             storage_path = configuration.getString(STORAGE_HOSTNAME_KEY);
  28.         } else if (backend_type.equals("berkeleyje")) {
  29.             storage_path = configuration.getString(STORAGE_DIRECTORY_KEY);
  30.         }
  31.  
  32.         if (backend_type.equals("hbase")) {
  33.             storage_instance = configuration.getString(STORAGE_HBASE_TABLE_KEY);
  34.         } else if (backend_type.equals("cql")) {
  35.             storage_instance = configuration.getString(STORAGE_CQL_KEYSPACE_KEY);
  36.         } else if (backend_type.equals("cassandra")
  37.                 || backend_type.equals("cassandrathrift")) {
  38.             storage_instance = configuration.getString(STORAGE_CASSANDRA_KEYSPACE_KEY);
  39.         }
  40.     }
  41.  
  42.     @Override
  43.     public boolean equals(Object o) {
  44.         if (this == o) return true;
  45.         if (o == null || getClass() != o.getClass()) return false;
  46.         StorageBackendKey that = (StorageBackendKey) o;
  47.         return Objects.equals(backend_type, that.backend_type) &&
  48.                 Objects.equals(storage_path, that.storage_path) &&
  49.                 Objects.equals(storage_instance, that.storage_instance);
  50.     }
  51.  
  52.     @Override
  53.     public int hashCode() {
  54.         return Objects.hash(backend_type, storage_path, storage_instance);
  55.     }
  56.  
  57.     @Override
  58.     public String toString() {
  59.         return "StorageBackendKey{" +
  60.                 "backend_type='" + backend_type + '\'' +
  61.                 ", storage_path='" + storage_path + '\'' +
  62.                 ", storage_instance='" + storage_instance + '\'' +
  63.                 '}';
  64.     }
  65. }
  66.  
  67.  
  68.  
  69. public class GraphTraversalMappingUtil {
  70.   public static void populateGraphTraversalToNameMapping(GraphManager graphManager){
  71.  
  72.     if(graphTraversalToNameMap.size() != 0){
  73.       return;
  74.     }
  75.  
  76.     Iterator<String> traversalSourceIterator = graphManager.getTraversalSourceNames().iterator();
  77.  
  78.     Map<StorageBackendKey, String> storageKeyToTraversalMap = new HashMap<StorageBackendKey, String>();
  79.     while(traversalSourceIterator.hasNext()){
  80.       String traversalSource = traversalSourceIterator.next();
  81.       StorageBackendKey key = new StorageBackendKey(
  82.               graphManager.getTraversalSource(traversalSource).getGraph().configuration());
  83.       storageKeyToTraversalMap.put(key, traversalSource);
  84.     }
  85.  
  86.     Iterator<String> graphNamesIterator =  graphManager.getGraphNames().iterator();
  87.     while(graphNamesIterator.hasNext()) {
  88.       String graphName = graphNamesIterator.next();
  89.       StorageBackendKey key = new StorageBackendKey(
  90.               graphManager.getGraph(graphName).configuration());
  91.       graphTraversalToNameMap.put(storageKeyToTraversalMap.get(key), graphName);
  92.     }
  93.  
  94.     logger.info("graphTraversalToNameMap:: {}" + graphTraversalToNameMap);
  95.   }
  96. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement