Examples of org.apache.helix.HelixDataAccessor.updateProperty()

Class org.apache.helix.HelixDataAccessor

Examples of org.apache.helix.HelixDataAccessor.updateProperty()

org.apache.helix.HelixDataAccessor.updateProperty()
Updates a property using newvalue.merge(oldvalue) @param key @param value @return true if the update was successful

      deltaList.add(delta);
      CurrentState currStateUpdate = new CurrentState(resource);
      currStateUpdate.setDeltaList(deltaList);


      // Update the ZK current state of the node
      accessor.updateProperty(key, currStateUpdate);
    }
    catch (Exception e)
    {
      logger.error("Error when removing " +
                       CurrentState.CurrentStateProperty.REQUESTED_STATE.name() +  " from current state.", e);

View Full Code Here

      PropertyKey key =
          keyBuilder.currentState(instanceName, sessionId, resource,
              bucketizer.getBucketName(partitionKey));
      if (_message.getAttribute(Attributes.PARENT_MSG_ID) == null) {
        // normal message
        accessor.updateProperty(key, _currentStateDelta);
      } else {
        // sub-message of a batch message
        ConcurrentHashMap<String, CurrentStateUpdate> csUpdateMap =
            (ConcurrentHashMap<String, CurrentStateUpdate>) _notificationContext
                .get(MapKey.CURRENT_STATE_UPDATE.toString());

View Full Code Here


        // if transit from ERROR state, disable the partition
        if (_message.getFromState().equalsIgnoreCase(HelixDefinedState.ERROR.toString())) {
          disablePartition();
        }
        accessor.updateProperty(
            keyBuilder.currentState(instanceName, _message.getTgtSessionId(), resourceName),
            currentStateDelta);
      }
    } finally {
      StateTransitionError error = new StateTransitionError(type, code, e);

View Full Code Here

          summary.put("CompletedMessages", "" + completedTasksNum);


          controllerStatusUpdate.getRecord().setMapField("Summary", summary);
        }
        // Update the statusUpdate of controllerMsgId
        accessor.updateProperty(controllerStatusUpdateKey, controllerStatusUpdate);
      }
    }


    if (finishedTasks.getListFields().size() > 0) {
      ZNRecordDelta znDelta = new ZNRecordDelta(finishedTasks, MergeOperation.SUBTRACT);

View Full Code Here

      IdealState delta = new IdealState(taskQueueIdealState.getResourceName());
      delta.setDeltaList(deltaList);


      // Remove the finished (COMPLETED or ERROR) tasks from the SCHEDULER_TASK_RESOURCE idealstate
      keyBuilder = accessor.keyBuilder();
      accessor.updateProperty(keyBuilder.idealStates(taskQueueIdealState.getResourceName()), delta);
    }
  }


}

View Full Code Here

          summary.put("CompletedMessages", "" + completedTasksNum);
          
          controllerStatusUpdate.getRecord().setMapField("Summary", summary);
        }
        // Update the statusUpdate of controllerMsgId
        accessor.updateProperty(controllerStatusUpdateKey, controllerStatusUpdate);
      }
    }
    
    if(finishedTasks.getListFields().size() > 0)
    {

View Full Code Here

      IdealState delta = new IdealState(taskQueueIdealState.getResourceName());
      delta.setDeltaList(deltaList);


      // Remove the finished (COMPLETED or ERROR) tasks from the SCHEDULER_TASK_RESOURCE idealstate
      keyBuilder = accessor.keyBuilder();
      accessor.updateProperty(keyBuilder.idealStates(taskQueueIdealState.getResourceName()), delta);
    }
  }


}

View Full Code Here

        // TODO: change to use asyncSet
        for (PropertyKey key : csUpdate.keySet()) {
          // logger.info("updateCS: " + key);
          // System.out.println("\tupdateCS: " + key.getPath() + ", " +
          // curStateMap.get(key));
          accessor.updateProperty(key, csUpdate.get(key));
        }
    }
  }


  // will not return until all sub-message executions are done

View Full Code Here

                              resource,
                              bucketizer.getBucketName(partitionKey));
      if (_message.getAttribute(Attributes.PARENT_MSG_ID) == null)
      {
        // normal message
        accessor.updateProperty(key, _currentStateDelta);
      }
      else
      {
        // sub-message of a batch message
        ConcurrentHashMap<String, CurrentStateUpdate> csUpdateMap

View Full Code Here

  
        // if transit from ERROR state, disable the partition
        if (_message.getFromState().equalsIgnoreCase(HelixDefinedState.ERROR.toString())) {
          disablePartition();
        }
        accessor.updateProperty(keyBuilder.currentState(instanceName,
                                                        _message.getTgtSessionId(),
                                                        resourceName),
                                currentStateDelta);
    }
    } finally {

View Full Code Here

0 1 2 3 4

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.