Class TransientUserData

  • All Implemented Interfaces:
    java.io.Serializable

    public class TransientUserData
    extends java.lang.Object
    implements java.io.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
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.List<java.lang.Integer> getResourceCounts()
      Get an immutable list of the resource counts for each file processed so far
      java.lang.String getResourceType()  
      boolean isCompleted()  
      void setCompleted​(boolean completed)  
      void setResourceCounts​(java.util.Collection<java.lang.Integer> resourceCounts)
      Set the resourceCounts value to match the given collection
      void setResourceType​(java.lang.String resourceType)  
      • Methods inherited from class java.lang.Object

        clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • 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 java.lang.String getResourceType()
        Returns:
        the resourceType
      • setResourceType

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

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

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