DimitStoreSystem implements Closeable { public DimitPath getPath(String first, String... more) { if (first == null) return getRoot(); StringBuilder buf = new StringBuilder(); buf.append(first); for (String m : more) { buf.append(provider.pathSeperator()); buf.append(m); } DimitPath path = new DimitPath(this, buf.toString()); return path; } DimitStoreSystem(DimitStoreSystemProvider provider, Map<String, Object> env); void open(URI uri); DimitStoreSystemProvider provider(); String getDomain(); DimitPath getRoot(); void setOpen(boolean open); void close(); boolean isOpen(); DimitPath getPath(String first, String... more); WatchService newWatchService(); @SuppressWarnings("unchecked") StoreIO<T> io(); abstract byte[] read(DimitPath path); abstract DimitPath write(DimitPath path, byte[] data, StoreAttribute<?>... attributes); abstract List<StoreWatcher> newStoreWatcher(StoreWatchKey key); @Override boolean equals(Object obj); @Override String toString(); abstract List<String> children(DimitPath path);  }
@Test @Ignore public void testDimitUri() { String fsType = "zk"; String dfsPath = "dzh"; URI dfsUri = URI.create("dimit-" + fsType + ": LOG.info("scheme:{}", dfsUri.getScheme()); LOG.info("path:{}", dfsUri.getPath()); LOG.info("rawPath:{}", dfsUri.getRawPath()); LOG.info("host:{}", dfsUri.getHost()); LOG.info("query:{}", dfsUri.getQuery()); LOG.info("authority:{}", dfsUri.getAuthority()); LOG.info("fragment:{}", dfsUri.getFragment()); }