Struct TimePartitioning

pub struct TimePartitioning {
    pub expiration_ms: Option<String>,
    pub field: Option<String>,
    pub require_partition_filter: Option<bool>,
    pub type: String,
}

Fields

expiration_ms: Option<String>

[Optional] Number of milliseconds for which to keep the storage for partitions in the table. The storage in a partition will have an expiration time of its partition time plus this value.

field: Option<String>

[Beta] [Optional] If not set, the table is partitioned by pseudo column, referenced via either ‘_PARTITIONTIME’ as TIMESTAMP type, or ‘_PARTITIONDATE’ as DATE type. If field is specified, the table is instead partitioned by this field. The field must be a top-level TIMESTAMP or DATE field. Its mode must be NULLABLE or REQUIRED.

require_partition_filter: Option<bool>

type: String

[Required] The supported types are DAY, HOUR, MONTH, and YEAR, which will generate one partition per day, hour, month, and year, respectively. When the type is not specified, the default behavior is DAY.

Implementations

impl TimePartitioning

pub fn new(type: String) -> Self

Creates a new time partitioning.

Argument

• type - The type of the partitioning (HOUR, DAY, MONTH or YEAR)

pub fn per_hour() -> Self

Creates a time partitioning per hour.

pub fn per_day() -> Self

Creates a time partitioning per day.

pub fn per_month() -> Self

Creates a time partitioning per month.

pub fn per_year() -> Self

Creates a time partitioning per year.

pub fn expiration_ms(self, duration: Duration) -> Self

Sets the expiration time per partition

pub fn field(self, field: &str) -> Self

Sets the field used for the time partitioning

Trait Implementations

impl Clone for TimePartitioning

fn clone(&self) -> TimePartitioning

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TimePartitioning

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

Formats the value using the given formatter.

impl Default for TimePartitioning

fn default() -> TimePartitioning

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for TimePartitioning

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TimePartitioning

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

where __S: Serializer,

Serialize this value into the given Serde serializer.