Examples of net.opentsdb.meta.UIDMeta.syncToStorage()

net.opentsdb.meta.UIDMeta.syncToStorage()

Attempts a CompareAndSet storage call, loading the object from storage, synchronizing changes, and attempting a put. Note: If the local object didn't have any fields set by the caller then the data will not be written. @param tsdb The TSDB to use for storage access @param overwrite When the RPC method is PUT, will overwrite all useraccessible fields @return True if the storage call was successful, false if the object wasmodified in storage during the CAS call. If false, retry the call. Other failures will result in an exception being thrown. @throws HBaseException if there was an issue fetching @throws IllegalArgumentException if parsing failed @throws NoSuchUniqueId If the UID does not exist @throws IllegalStateException if the data hasn't changed. This is OK! @throws JSONException if the object could not be serialized

          new_meta.setCreated(timestamp);
          tsdb.indexUIDMeta(new_meta);
          LOG.info("Replacing corrupt UID [" + UniqueId.uidToString(uid) + 
            "] of type [" + type + "]");
          
          return new_meta.syncToStorage(tsdb, true);
        }
        
      }
      
      @Override

          new_meta.setCreated(timestamp);
          tsdb.indexUIDMeta(new_meta);
          LOG.info("Replacing corrupt UID [" + UniqueId.uidToString(uid) + 
            "] of type [" + type + "]");
          
          return new_meta.syncToStorage(tsdb, true);
        }
        
      }
      
      @Override

        }
        
      }
      
      try {
        final Deferred<UIDMeta> process_meta = meta.syncToStorage(tsdb, 
            method == HttpMethod.PUT).addCallbackDeferring(new SyncCB());
        final UIDMeta updated_meta = process_meta.joinUninterruptibly();
        tsdb.indexUIDMeta(updated_meta);
        query.sendReply(query.serializer().formatUidMetaV1(updated_meta));
      } catch (IllegalStateException e) {

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.