List of storeNew() Examples

Examples of storeNew()

net.opentsdb.meta.TSMeta.storeNew()
Attempts to store a new, blank timeseries meta object via a CompareAndSet Note: This should not be called by user accessible methods as it will overwrite any data already in the column. Note: This call does not guarantee that the UIDs exist before storing as it should only be called *after* a data point has been recorded or during a meta sync. @param tsdb The TSDB to use for storage access @return True if the CAS completed successfully (and no TSMeta existed previously), false if something was already stored in the TSMeta column. @throws HBaseException if there was an issue fetching @throws IllegalArgumentException if parsing failed @throws JSONException if the object could not be serialized
net.opentsdb.meta.UIDMeta.storeNew()
Attempts to store a blank, new UID meta object in the proper location. Warning: This should not be called by user accessible methods as it will overwrite any data already in the column. This method does not use a CAS, instead it uses a PUT to overwrite anything in the column. @param tsdb The TSDB to use for calls @return A deferred without meaning. The response may be null and shouldonly be used to track completion. @throws HBaseException if there was an issue writing to storage @throws IllegalArgumentException if data was missing @throws JSONException if the object could not be serialized

Examples of net.opentsdb.meta.TSMeta.storeNew()

              } else {
                TSMeta new_meta = new TSMeta(tsuid, timestamp);
                tsdb.indexTSMeta(new_meta);
                LOG.info("Counter exists but meta was null, creating meta data for timeseries [" + 
                    tsuid_string + "]");
                return new_meta.storeNew(tsdb);    
              }
            }
          }
          
          // Take care of situations where the counter is created but the

View Full Code Here

Examples of net.opentsdb.meta.TSMeta.storeNew()

            meta.getTSUID().isEmpty()) {
          LOG.warn("Replacing corrupt meta data for timeseries [" + 
              tsuid_string + "]");
          TSMeta new_meta = new TSMeta(tsuid, timestamp);
          tsdb.indexTSMeta(new_meta);
          return new_meta.storeNew(tsdb);
        } else {
          // we only want to update the time if it was outside of an 
          // hour otherwise it's probably an accurate timestamp
          if (meta.getCreated() > (timestamp + 3600) || 
              meta.getCreated() == 0) {

View Full Code Here

Examples of net.opentsdb.meta.TSMeta.storeNew()

              } else {
                TSMeta new_meta = new TSMeta(tsuid, timestamp);
                tsdb.indexTSMeta(new_meta);
                LOG.info("Counter exists but meta was null, creating meta data for timeseries [" + 
                    tsuid_string + "]");
                return new_meta.storeNew(tsdb);    
              }
            }
          }
          
          // Take care of situations where the counter is created but the

View Full Code Here

Examples of net.opentsdb.meta.TSMeta.storeNew()

            meta.getTSUID().isEmpty()) {
          LOG.warn("Replacing corrupt meta data for timeseries [" + 
              tsuid_string + "]");
          TSMeta new_meta = new TSMeta(tsuid, timestamp);
          tsdb.indexTSMeta(new_meta);
          return new_meta.storeNew(tsdb);
        } else {
          // we only want to update the time if it was outside of an 
          // hour otherwise it's probably an accurate timestamp
          if (meta.getCreated() > (timestamp + 3600) || 
              meta.getCreated() == 0) {

View Full Code Here

Examples of net.opentsdb.meta.TSMeta.storeNew()

              } else {
                TSMeta new_meta = new TSMeta(tsuid, timestamp);
                tsdb.indexTSMeta(new_meta);
                LOG.info("Counter exists but meta was null, creating meta data for timeseries [" + 
                    tsuid_string + "]");
                return new_meta.storeNew(tsdb);    
              }
            }
          }
          
          // Take care of situations where the counter is created but the

View Full Code Here

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


      cacheMapping(name, row);
      
      if (tsdb != null && tsdb.getConfig().enable_realtime_uid()) {
        final UIDMeta meta = new UIDMeta(type, row, name);
        meta.storeNew(tsdb);
        LOG.info("Wrote UIDMeta for: " + name);
        tsdb.indexUIDMeta(meta);
      }
      
      synchronized (pending_assignments) {

View Full Code Here

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

              } else {
                TSMeta new_meta = new TSMeta(tsuid, timestamp);
                tsdb.indexTSMeta(new_meta);
                LOG.info("Counter exists but meta was null, creating meta data for timeseries [" + 
                    tsuid_string + "]");
                return new_meta.storeNew(tsdb);    
              }
            }
          }
          
          // Take care of situations where the counter is created but the

View Full Code Here

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

            meta.getTSUID().isEmpty()) {
          LOG.warn("Replacing corrupt meta data for timeseries [" + 
              tsuid_string + "]");
          TSMeta new_meta = new TSMeta(tsuid, timestamp);
          tsdb.indexTSMeta(new_meta);
          return new_meta.storeNew(tsdb);
        } else {
          // we only want to update the time if it was outside of an 
          // hour otherwise it's probably an accurate timestamp
          if (meta.getCreated() > (timestamp + 3600) || 
              meta.getCreated() == 0) {

View Full Code Here

TOP

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.