Interface Readable<O>

    • Method Detail

      • prepare

        void prepare()
        Prepare reading data.
      • readCurrent

        O readCurrent()
        Method to read current data from the source. The caller should check whether the Readable is finished or not by using isFinished() method before calling this method.
        Returns:
        a data read by the readable.
      • readWatermark

        long readWatermark()
        Read watermark.
        Returns:
        watermark
      • isFinished

        boolean isFinished()
        Returns:
        true if it reads all data.
      • getLocations

        List<String> getLocations()
                           throws Exception
        Returns the list of locations where this readable resides. Each location has a complete copy of the readable.
        Returns:
        List of locations where this readable resides
        Throws:
        UnsupportedOperationException - when this operation is not supported
        Exception - any other exceptions on the way