Package org.linuxforhealth.fhir.persistence.cassandra.payload

Class CqlChunkedPayloadStream

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable
    public class CqlChunkedPayloadStream
extends java.io.InputStream
    Reads the payload from CQL. Cassandra imposes both hard and practical upper limits on the length of a column value. Because FHIR payloads can be an arbitrary size, we separate payloads into chunks spread across multiple rows. This class reads those rows in sequence and presents the results as an ordinary stream of bytes

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      int read()  
      int read​(byte[] dst, int off, int len)  

      • Methods inherited from class java.io.InputStream

        available, close, mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, transferTo

      • Methods inherited from class java.lang.Object

        clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • CqlChunkedPayloadStream

        public CqlChunkedPayloadStream​(IBufferProvider bp)
        Public constructor
        Parameters:
        rs -

    • Method Detail

      • read

        public int read()
         throws java.io.IOException
        Specified by:
        read in class java.io.InputStream
        Throws:
        java.io.IOException

      • read

        public int read​(byte[] dst,
                int off,
                int len)
         throws java.io.IOException
        Overrides:
        read in class java.io.InputStream
        Throws:
        java.io.IOException