Class ListObject

    • Method Detail

      • deriveAndSetStatusFromData

        public void deriveAndSetStatusFromData()
      • setStatus

        public void setStatus​(boolean[] status)
      • getStatus

        public boolean[] getStatus()
      • getLength

        public int getLength()
      • getNumCacheableData

        public int getNumCacheableData()
      • setNames

        public void setNames​(List<String> names)
      • getName

        public String getName​(int ix)
      • isNamedList

        public boolean isNamedList()
      • getData

        public Data getData​(int ix)
      • contains

        public boolean contains​(Data d)
      • contains

        public boolean contains​(String name)
      • getDataSize

        public long getDataSize()
      • checkAllDataTypes

        public boolean checkAllDataTypes​(Types.DataType dt)
      • slice

        public Data slice​(int ix)
      • getLineageItem

        public LineageItem getLineageItem​(int ix)
      • slice

        public ListObject slice​(int ix1,
                                int ix2)
      • remove

        public ListObject remove​(int pos)
        Removes the element at the specified position from the list and returns that element as the only element in a new ListObject.
        pos - position of element in the list
        new ListObject with the specified element
      • writeExternal

        public void writeExternal​(ObjectOutput out)
                           throws IOException
        Redirects the default java serialization via externalizable to our default hadoop writable serialization for efficient broadcast/rdd serialization.
        Specified by:
        writeExternal in interface Externalizable
        out - object output
        IOException - if IOException occurs
      • getCleanupStates

        public List<Boolean> getCleanupStates()
        Gets list of current cleanupFlag values recursively for every element in the list and in its sublists of type CacheableData. The order is as CacheableData elements are discovered during DFS. Elements that are not of type CacheableData are skipped.
        list of booleans containing the _cleanupFlag values.
      • enableCleanup

        public void enableCleanup​(boolean flag)
        Sets the cleanupFlag values recursively for every element of type CacheableData in the list and in its sublists to the provided flag value.
        flag - New value for every CacheableData element.
      • enableCleanup

        public void enableCleanup​(Queue<Boolean> flags)
        Sets the cleanupFlag values recursively for every element of type CacheableData in the list and in its sublists to the provided values in flags. The cleanupFlag value of the i-th CacheableData element in the list (counted in the order of DFS) is set to the i-th value in flags.
        flags - Queue of values in the same order as its corresponding elements occur in DFS.