case class GorillaSuperBlock(channel: SliceableByteChannel) extends Product with Serializable
The GorillaSuperBlock class lazily wraps a channel that it reads from. This facilitates the reading of the binary format. The block does not perform any reading on the channel unless a method explicitly requires it.
- channel
to read from upon method invocation
- Alphabetic
- By Inheritance
- GorillaSuperBlock
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new GorillaSuperBlock(channel: SliceableByteChannel)
- channel
to read from upon method invocation
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##(): Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val channel: SliceableByteChannel
- def clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def readAll: Seq[TSEntry[GorillaBlock]]
Read all of the information of this GorillaSuperBlock and lazily return all contained GorillaBlocks.
Read all of the information of this GorillaSuperBlock and lazily return all contained GorillaBlocks. This uses the more granular methods of this object internally.
- returns
a sequence of gorilla blocks
- Exceptions thrown
TExceptionif the metadata cannot be decoded
- def readAllBlocks(metadata: TSuperBlockMetadata, metaLength: Int): Seq[TSEntry[GorillaBlock]]
Lazily read (but don't decompress) all GorillaBlocks from this GorillaSuperBlock to memory.
Lazily read (but don't decompress) all GorillaBlocks from this GorillaSuperBlock to memory.
- metadata
of the SuperBlock that has information needed for deserialization
- metaLength
the length of the thrift metadata block in the footer
- returns
a sequence of gorilla encoded blocks of a timeseries
- Note
This assumes that the binary data has the correct version/format.
- def readBlock(metadata: TSuperBlockMetadata, offset: Long, length: Int): GorillaBlock
Read (but don't decompress) a GorillaBlock from the GorillaSuperBlock.
Read (but don't decompress) a GorillaBlock from the GorillaSuperBlock.
- metadata
of the SuperBlock that has information needed for deserialization
- offset
the start of the block as given by the index in the footer
- length
the length of the block in bytes
- returns
a gorilla encoded block of a timeseries
- Note
This assumes that the binary data has the correct version/format.
- def readIndex(metaLength: Int): SortedMap[Long, Long]
Read and decompress the index of the GorillaSuperBlock (see format above).
Read and decompress the index of the GorillaSuperBlock (see format above).
- metaLength
the length of the thrift metadata block in the footer
- returns
the index as a sorted map of (timestamp -> byte-offset) tuples
- Note
This assumes that the binary data has the correct version/format.
- def readMetadata: (TSuperBlockMetadata, Int)
Read the metadata of the GorillaSuperBlock.
Read the metadata of the GorillaSuperBlock. This also checks whether the underlying binary data has the correct version and format.
- returns
the metadata as specified by the thrift definition and its length
- Exceptions thrown
TExceptionif the metadata cannot be decoded
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()