risingwave_common::types

Struct Time

source
#[repr(transparent)]
pub struct Time(pub NaiveTime);

Tuple Fields§

§0: NaiveTime

Implementations§

source§

impl Time

source

pub const MIN: Self = _

source

pub fn new(data: NaiveTime) -> Self

source§

impl Time

source

pub fn with_secs_nano(secs: u32, nano: u32) -> Result<Self, InvalidParamsError>

source

pub fn from_protobuf(cur: &mut Cursor<&[u8]>) -> ArrayResult<Time>

source

pub fn to_protobuf<T: Write>(self, output: &mut T) -> ArrayResult<usize>

source

pub fn with_nano(nano: u64) -> Result<Self, InvalidParamsError>

source

pub fn with_micro(micro: u64) -> Result<Self, InvalidParamsError>

source

pub fn with_milli(milli: u32) -> Result<Self, InvalidParamsError>

source

pub fn from_hms_uncheck(hour: u32, min: u32, sec: u32) -> Self

source

pub fn from_hms_micro_uncheck(hour: u32, min: u32, sec: u32, micro: u32) -> Self

source

pub fn from_hms_nano_uncheck(hour: u32, min: u32, sec: u32, nano: u32) -> Self

source

pub fn from_num_seconds_from_midnight_uncheck(secs: u32, nano: u32) -> Self

Trait Implementations§

source§

impl Clone for Time

source§

fn clone(&self) -> Time

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl Debug for Time

source§

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

Formats the value using the given formatter. Read more
source§

impl Default for Time

source§

fn default() -> Time

Returns the “default value” for a type. Read more
source§

impl Display for Time

source§

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

Formats the value using the given formatter. Read more
source§

impl From<Interval> for Time

In PostgreSQL, casting from interval to time discards the days part.

§Example

use std::str::FromStr;

use risingwave_common::types::{Interval, Time};

let interval = Interval::from_month_day_usec(1, 2, 61000003);
let time = Time::from(interval);
assert_eq!(time, Time::from_str("00:01:01.000003").unwrap());

let interval = Interval::from_month_day_usec(0, 0, -61000003);
let time = Time::from(interval);
assert_eq!(time, Time::from_str("23:58:58.999997").unwrap());
source§

fn from(interval: Interval) -> Self

Converts to this type from the input type.
source§

impl From<NaiveTime> for Time

source§

fn from(data: NaiveTime) -> Self

Converts to this type from the input type.
source§

impl From<Time> for Interval

source§

fn from(time: Time) -> Self

Converts to this type from the input type.
source§

impl From<Time> for ScalarImpl

source§

fn from(val: Time) -> Self

Converts to this type from the input type.
source§

impl<'scalar> From<Time> for ScalarRefImpl<'scalar>

source§

fn from(val: Time) -> Self

Converts to this type from the input type.
source§

impl From<Timestamp> for Time

In PostgreSQL, casting from timestamp to time discards the date part.

§Example

use std::str::FromStr;

use risingwave_common::types::{Time, Timestamp};

let ts = Timestamp::from_str("1999-01-08 04:02").unwrap();
let time = Time::from(ts);
assert_eq!(time, Time::from_str("04:02").unwrap());
source§

fn from(ts: Timestamp) -> Self

Converts to this type from the input type.
source§

impl FromIntoArrow for Time

source§

type ArrowType = i64

The corresponding element type in the Arrow array.
source§

fn from_arrow(value: Self::ArrowType) -> Self

source§

fn into_arrow(self) -> Self::ArrowType

source§

impl FromIntoArrow for Time

source§

type ArrowType = i64

The corresponding element type in the Arrow array.
source§

fn from_arrow(value: Self::ArrowType) -> Self

source§

fn into_arrow(self) -> Self::ArrowType

source§

impl<'a> FromSql<'a> for Time

source§

fn from_sql( ty: &Type, raw: &'a [u8], ) -> Result<Self, Box<dyn Error + Sync + Send>>

Creates a new value of this type from a buffer of data of the specified Postgres Type in its binary format. Read more
source§

fn accepts(ty: &Type) -> bool

Determines if a value of this type can be created from the specified Postgres Type.
§

fn from_sql_null(ty: &Type) -> Result<Self, Box<dyn Error + Sync + Send>>

Creates a new value of this type from a NULL SQL value. Read more
§

fn from_sql_nullable( ty: &Type, raw: Option<&'a [u8]>, ) -> Result<Self, Box<dyn Error + Sync + Send>>

A convenience function that delegates to from_sql and from_sql_null depending on the value of raw.
source§

impl FromStr for Time

Parse a time from varchar.

§Example

use std::str::FromStr;

use risingwave_common::types::Time;

Time::from_str("04:05").unwrap();
Time::from_str("04:05:06").unwrap();
source§

type Err = InvalidParamsError

The associated error which can be returned from parsing.
source§

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

Parses a string s to return a value of this type. Read more
source§

impl Hash for Time

source§

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

Feeds this value into the given Hasher. Read more
1.3.0 · source§

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

Feeds a slice of this type into the given Hasher. Read more
source§

impl HashKeyDe for Time

source§

fn deserialize(_data_type: &DataType, buf: impl Buf) -> Self

source§

impl HashKeySer<'_> for Time

source§

fn serialize_into(self, buf: impl BufMut)

Serialize the scalar into the given buffer.
source§

fn exact_size() -> Option<usize>

Returns Some if the serialized size is known for this scalar type.
source§

fn estimated_size(self) -> usize

Returns the estimated serialized size for this scalar.
source§

impl Ord for Time

source§

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

This method returns an Ordering between self and other. Read more
1.21.0 · source§

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

Compares and returns the maximum of two values. Read more
1.21.0 · source§

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

Compares and returns the minimum of two values. Read more
1.50.0 · source§

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

Restrict a value to a certain interval. Read more
source§

impl PartialEq for Time

source§

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
source§

impl PartialOrd for Time

source§

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

This method returns an ordering between self and other values if one exists. Read more
1.0.0 · source§

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

Tests less than (for self and other) and is used by the < operator. Read more
1.0.0 · source§

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

Tests less than or equal to (for self and other) and is used by the <= operator. Read more
1.0.0 · source§

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

Tests greater than (for self and other) and is used by the > operator. Read more
1.0.0 · source§

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

Tests greater than or equal to (for self and other) and is used by the >= operator. Read more
source§

impl PrimitiveArrayItemType for Time

source§

const DATA_TYPE: DataType = DataType::Time

The data type.
source§

fn erase_array_type(arr: PrimitiveArray<Self>) -> ArrayImpl

A helper to convert a primitive array to ArrayImpl.
source§

fn try_into_array(arr: ArrayImpl) -> Option<PrimitiveArray<Self>>

A helper to convert ArrayImpl to self.
source§

fn try_into_array_ref(arr: &ArrayImpl) -> Option<&PrimitiveArray<Self>>

A helper to convert ArrayImpl to self.
source§

fn array_type() -> ArrayType

Returns array type of the primitive array
source§

fn to_protobuf<T: Write>(self, output: &mut T) -> ArrayResult<usize>

source§

fn from_protobuf(cur: &mut Cursor<&[u8]>) -> ArrayResult<Self>

source§

impl RandValue for Time

source§

fn rand_value<R: Rng>(rand: &mut R) -> Self

source§

impl Scalar for Time

Implement Scalar for Time.

source§

type ScalarRefType<'a> = Time

Type for reference of Scalar
source§

fn as_scalar_ref(&self) -> Time

Get a reference to current scalar.
source§

fn to_scalar_value(self) -> ScalarImpl

source§

impl ScalarRef<'_> for Time

Implement ScalarRef for Time.

source§

type ScalarType = Time

ScalarType is the owned type of current ScalarRef.
source§

fn to_owned_scalar(&self) -> Time

Convert ScalarRef to an owned scalar.
source§

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

A wrapped hash function to get the hash value for this scaler.
source§

impl ToBinary for Time

source§

impl ToSql for Time

source§

fn accepts(ty: &Type) -> bool

Determines if a value of this type can be converted to the specified Postgres Type.
source§

fn to_sql_checked( &self, ty: &Type, out: &mut BytesMut, ) -> Result<IsNull, Box<dyn Error + Sync + Send>>

An adaptor method used internally by Rust-Postgres. Read more
source§

fn to_sql( &self, ty: &Type, out: &mut BytesMut, ) -> Result<IsNull, Box<dyn Error + Sync + Send>>
where Self: Sized,

Converts the value of self into the binary format of the specified Postgres Type, appending it to out. Read more
§

fn encode_format(&self, _ty: &Type) -> Format

Specify the encode format
source§

impl ToText for Time

source§

fn write<W: Write>(&self, f: &mut W) -> Result

Write the text to the writer regardless of its data type Read more
source§

fn write_with_type<W: Write>(&self, ty: &DataType, f: &mut W) -> Result

Write the text to the writer according to its data type
source§

fn to_text_with_type(&self, ty: &DataType) -> String

Convert to text according to its data type
source§

fn to_text(&self) -> String

to_text is a special version of to_text_with_type, it convert the scalar to default type text. E.g. for Int64, it will convert to text as a Int64 type. We should prefer to use to_text_with_type because it’s more clear and readable. Read more
source§

impl TryFrom<ScalarImpl> for Time

source§

type Error = ArrayError

The type returned in the event of a conversion error.
source§

fn try_from(val: ScalarImpl) -> ArrayResult<Self>

Performs the conversion.
source§

impl<'scalar> TryFrom<ScalarRefImpl<'scalar>> for Time

source§

type Error = ArrayError

The type returned in the event of a conversion error.
source§

fn try_from(val: ScalarRefImpl<'scalar>) -> ArrayResult<Self>

Performs the conversion.
source§

impl<'a> WithDataType for &'a Time

source§

fn default_data_type() -> DataType

Returns the most obvious DataType for the rust type.
source§

impl<'a> WithDataType for &'a mut Time

source§

fn default_data_type() -> DataType

Returns the most obvious DataType for the rust type.
source§

impl WithDataType for Box<Time>

source§

fn default_data_type() -> DataType

Returns the most obvious DataType for the rust type.
source§

impl WithDataType for Time

source§

fn default_data_type() -> DataType

Returns the most obvious DataType for the rust type.
source§

impl Copy for Time

source§

impl Eq for Time

source§

impl StructuralPartialEq for Time

source§

impl ZeroHeapSize for Time

Auto Trait Implementations§

§

impl Freeze for Time

§

impl RefUnwindSafe for Time

§

impl Send for Time

§

impl Sync for Time

§

impl Unpin for Time

§

impl UnwindSafe for Time

Blanket Implementations§

source§

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

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

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

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

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

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
§

impl<T> BorrowToSql for T
where T: ToSql,

§

fn borrow_to_sql(&self) -> &dyn ToSql

Returns a reference to self as a ToSql trait object.
source§

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

source§

unsafe fn clone_to_uninit(&self, dst: *mut T)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dst. Read more
§

impl<Q, K> Comparable<K> for Q
where Q: Ord + ?Sized, K: Borrow<Q> + ?Sized,

§

fn compare(&self, key: &K) -> Ordering

Compare self to key and return their ordering.
§

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

§

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more
§

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

§

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.
source§

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

source§

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.
§

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

§

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more
§

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

§

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more
source§

impl<T> EstimateSize for T
where T: ZeroHeapSize,

source§

fn estimated_heap_size(&self) -> usize

The estimated heap size of the current struct in bytes.
source§

fn estimated_size(&self) -> usize
where Self: Sized,

The estimated total size of the current struct in bytes, including the estimated_heap_size and the size of Self.
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

§

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

§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
§

impl<T> FutureExt for T

§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

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

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoEither for T

source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
source§

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

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
source§

impl<T> IntoRequest<T> for T

source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
§

impl<T> IntoResult<T> for T

§

type Err = Infallible

§

fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>

source§

impl<M> MetricVecRelabelExt for M

source§

fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>

source§

fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>

source§

fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>

Equivalent to RelabeledMetricVec::with_metric_level_relabel_n with metric_level set to MetricLevel::Debug and relabel_num set to 1.
§

impl<T> Pointable for T

§

const ALIGN: usize = _

The alignment of pointer.
§

type Init = T

The type for initializers.
§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<T> Same for T

source§

type Output = T

Should always be Self
source§

impl<T> ScalarPartialOrd for T

source§

fn scalar_cmp(&self, other: T) -> Option<Ordering>

source§

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

source§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T> ToOwnedDatum for T
where T: Into<ScalarImpl>,

source§

fn to_owned_datum(self) -> Option<ScalarImpl>

Convert the datum to an owned Datum.
source§

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

source§

default fn to_string(&self) -> String

Converts the given value to a String. Read more
source§

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

source§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

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

source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

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

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more
source§

impl<T> WithSubscriber for T

source§

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

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
§

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

§

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

§

impl<T> DevConfig for T
where T: Send + Sync + 'static + Debug,

§

impl<T> FromSqlOwned for T
where T: for<'a> FromSql<'a>,

§

impl<T> Key for T
where T: Send + Sync + 'static + Hash + Eq,

source§

impl<T> LruKey for T
where T: Eq + Send + Hash,

source§

impl<T> LruValue for T
where T: Send + Sync,

source§

impl<N> NodeTrait for N
where N: Copy + Ord + Hash,

§

impl<T> Value for T
where T: Send + Sync + 'static,