Class DiscoveryDataBag


  • public class DiscoveryDataBag
    extends Object
    Provides interface for GridComponent to collect and exchange discovery data both on joining node and on cluster nodes. It only organizes interaction with components and doesn't provide any capabilities of converting collected data into formats eligible for transmitting over media (like marshalling, compressing and so on).
    • Constructor Detail

      • DiscoveryDataBag

        public DiscoveryDataBag​(UUID joiningNodeId,
                                boolean isJoiningNodeClient)
        Parameters:
        joiningNodeId - Joining node id.
        isJoiningNodeClient - Flag indicates the joining node is client.
      • DiscoveryDataBag

        public DiscoveryDataBag​(UUID joiningNodeId,
                                Set<Integer> cmnDataInitializedCmps,
                                boolean isJoiningNodeClient)
        Parameters:
        joiningNodeId - Joining node id.
        cmnDataInitializedCmps - Component IDs with already initialized common discovery data.
        isJoiningNodeClient - Flag indicates the joining node is client.
    • Method Detail

      • joiningNodeId

        public UUID joiningNodeId()
        Returns:
        ID of joining node.
      • isJoiningNodeClient

        public boolean isJoiningNodeClient()
        Returns:
        true if the joining node is client node. Return false otherwise.
      • gridDiscoveryData

        public DiscoveryDataBag.GridDiscoveryData gridDiscoveryData​(int cmpId)
        Parameters:
        cmpId - Component ID.
        Returns:
        Discovery data for given component.
      • addJoiningNodeData

        public void addJoiningNodeData​(Integer cmpId,
                                       Serializable data)
        Parameters:
        cmpId - Component ID.
        data - Data.
      • addGridCommonData

        public void addGridCommonData​(Integer cmpId,
                                      Serializable data)
        Parameters:
        cmpId - Component ID.
        data - Data.
      • addNodeSpecificData

        public void addNodeSpecificData​(Integer cmpId,
                                        Serializable data)
        Parameters:
        cmpId - Component ID.
        data - Data.
      • commonDataCollectedFor

        public boolean commonDataCollectedFor​(Integer cmpId)
        Parameters:
        cmpId - Component ID.
        Returns:
        True if common data collected for given component.
      • joiningNodeData

        public void joiningNodeData​(Map<Integer,​Serializable> joinNodeData)
        Parameters:
        joinNodeData - Joining node data.
      • commonData

        public void commonData​(Map<Integer,​Serializable> cmnData)
        Parameters:
        cmnData - Cmn data.
      • nodeSpecificData

        public void nodeSpecificData​(Map<UUID,​Map<Integer,​Serializable>> nodeSpecData)
        Parameters:
        nodeSpecData - Node specific data.
      • joiningNodeData

        public Map<Integer,​Serializable> joiningNodeData()
        Returns:
        Discovery data for each Ignite component that is sent to the cluster nodes by joining node.
      • commonData

        public Map<Integer,​Serializable> commonData()
        Returns:
        Discovery data for each Ignite component that is aggregated from the cluster nodes and sent to the joining node.
      • localNodeSpecificData

        @Nullable
        public @Nullable Map<Integer,​Serializable> localNodeSpecificData()
        Returns:
        Discovery data that belongs to the current cluster node and is sent to the joining node.