Struct ChunkId

Source

pub struct ChunkId(/* private fields */);

Expand description

A unique ID for a Chunk.

Chunks are the atomic unit of ingestion, transport, storage, events and GC in Rerun.

Internally, a Chunk is made up of rows, which are themselves uniquely identified by their RowId.

There is no relationship whatsoever between a ChunkId and the RowIds within that chunk.

§String format

Example: chunk_182342300C5F8C327a7b4a6e5a379ac4. The “chunk_” prefix is optional when parsing. See re_tuid docs for explanations of TUID namespaces.

§Uniqueness

ChunkId are assumed unique within a single Recording.

The chunk store will treat two chunks with the same ChunkId as the same, and only keep one of them (which one is kept is an arbitrary and unstable implementation detail).

This makes it easy to build and maintain secondary indices around RowIds with few to no extraneous state tracking.

§Garbage collection

Garbage collection is handled at the chunk level by first ordering the chunks based on the minimum RowId present in each of them. Garbage collection therefore happens (roughly) in the logger’s wall-clock order.

This has very important implications when inserting data far into the past or into the future: think carefully about your RowIds in these cases.

Struct ChunkId Copy item path

§String format

§Uniqueness

§Garbage collection

Implementations§

impl ChunkId

pub const ZERO: Self

pub const MAX: Self

pub fn new() -> Self

pub fn from_tuid(tuid: Tuid) -> Self

pub fn as_tuid(&self) -> Tuid

pub fn next(&self) -> Self

pub fn incremented_by(&self, n: u64) -> Self

pub fn from_u128(id: u128) -> Self

impl ChunkId

pub fn partial_descriptor() -> ComponentDescriptor

Methods from Deref<Target = Tuid>§

pub const ARROW_EXTENSION_NAME: &'static str = "rerun.datatypes.TUID"

pub const ZERO: Tuid

pub const MAX: Tuid

pub fn as_u128(&self) -> u128

pub fn as_bytes(&self) -> [u8; 16]

pub fn nanos_since_epoch(&self) -> u64

pub fn inc(&self) -> u64

pub fn next(&self) -> Tuid

pub fn incremented_by(&self, n: u64) -> Tuid

pub fn short_string(&self) -> String

Trait Implementations§

impl Clone for ChunkId

fn clone(&self) -> ChunkId

fn clone_from(&mut self, source: &Self)

impl Component for ChunkId

fn name() -> ComponentType

impl Debug for ChunkId

fn fmt(&self, f: &mut Formatter<'_>) -> Result

impl Deref for ChunkId

type Target = Tuid

fn deref(&self) -> &Self::Target

impl DerefMut for ChunkId

fn deref_mut(&mut self) -> &mut Self::Target

impl<'de> Deserialize<'de> for ChunkId

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

impl Display for ChunkId

fn fmt(&self, f: &mut Formatter<'_>) -> Result

impl<'a> From<&'a ChunkId> for Cow<'a, ChunkId>

fn from(value: &'a ChunkId) -> Self

impl<'a> From<ChunkId> for Cow<'a, ChunkId>

fn from(value: ChunkId) -> Self

impl FromStr for ChunkId

type Err = InvalidChunkIdError

fn from_str(s: &str) -> Result<Self, Self::Err>

impl Hash for ChunkId

fn hash<__H: Hasher>(&self, state: &mut __H)

fn hash_slice<H>(data: &[Self], state: &mut H)where H: Hasher, Self: Sized,

impl Loggable for ChunkId

fn arrow_datatype() -> DataType

fn to_arrow_opt<'a>( _values: impl IntoIterator<Item = Option<impl Into<Cow<'a, Self>>>>, ) -> SerializationResult<ArrayRef>where Self: 'a,

fn to_arrow<'a>( values: impl IntoIterator<Item = impl Into<Cow<'a, Self>>>, ) -> SerializationResult<ArrayRef>

fn from_arrow(array: &dyn Array) -> DeserializationResult<Vec<Self>>

fn arrow_empty() -> ArrayRef

fn from_arrow_opt(data: &dyn Array) -> DeserializationResult<Vec<Option<Self>>>

fn verify_arrow_array(data: &dyn Array) -> DeserializationResult<()>

impl Ord for ChunkId

fn cmp(&self, other: &ChunkId) -> Ordering

fn max(self, other: Self) -> Selfwhere Self: Sized,

fn min(self, other: Self) -> Selfwhere Self: Sized,

fn clamp(self, min: Self, max: Self) -> Selfwhere Self: Sized,

impl PartialEq for ChunkId

fn eq(&self, other: &ChunkId) -> bool

fn ne(&self, other: &Rhs) -> bool

impl PartialOrd for ChunkId

fn partial_cmp(&self, other: &ChunkId) -> Option<Ordering>

fn lt(&self, other: &Rhs) -> bool

fn le(&self, other: &Rhs) -> bool

fn gt(&self, other: &Rhs) -> bool

fn ge(&self, other: &Rhs) -> bool

impl Serialize for ChunkId

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where __S: Serializer,

impl SizeBytes for ChunkId

fn heap_size_bytes(&self) -> u64

Struct ChunkId

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

fn hash<H: Hasher>(&self, state: &mut H)

fn hash_slice<H>(data: &[Self], state: &mut H)
where H: Hasher, Self: Sized,

fn to_arrow_opt<'a>( _values: impl IntoIterator<Item = Option<impl Into<Cow<'a, Self>>>>, ) -> SerializationResult<ArrayRef>
where Self: 'a,

fn max(self, other: Self) -> Self
where Self: Sized,

fn min(self, other: Self) -> Self
where Self: Sized,

fn clamp(self, min: Self, max: Self) -> Self
where Self: Sized,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<L> ComponentBatch for L
where L: Clone + Loggable,

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<P, T> Receiver for P
where P: Deref<Target = T> + ?Sized, T: ?Sized,

impl<T> ToOwned for T
where T: Clone,

impl<T> ToString for T
where T: Display + ?Sized,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,