Class TransientUserData

  • All Implemented Interfaces:
    Serializable

    public class TransientUserData
    extends Object
    implements Serializable
    Used to share state information among partition processing objects such as the ResourcePayloadReader and ExportPartitionCollector. Note that this information is not part of the checkpoint data because it only relates to the current runtime state.
    See Also:
    Serialized Form
    • Constructor Detail

      • TransientUserData

        public TransientUserData()
    • Method Detail

      • isCompleted

        public boolean isCompleted()
        Returns:
        the completed
      • setCompleted

        public void setCompleted​(boolean completed)
        Parameters:
        completed - the completed to set
      • getResourceType

        public String getResourceType()
        Returns:
        the resourceType
      • setResourceType

        public void setResourceType​(String resourceType)
        Parameters:
        resourceType - the resourceType to set
      • getResourceCounts

        public List<Integer> getResourceCounts()
        Get an immutable list of the resource counts for each file processed so far
        Returns:
      • setResourceCounts

        public void setResourceCounts​(Collection<Integer> resourceCounts)
        Set the resourceCounts value to match the given collection
        Parameters:
        resourceCounts -