#[non_exhaustive]
pub struct PipeTargetTimestreamParameters { pub time_value: String, pub epoch_time_unit: Option<EpochTimeUnit>, pub time_field_type: Option<TimeFieldType>, pub timestamp_format: Option<String>, pub version_value: String, pub dimension_mappings: Vec<DimensionMapping>, pub single_measure_mappings: Option<Vec<SingleMeasureMapping>>, pub multi_measure_mappings: Option<Vec<MultiMeasureMapping>>, }
Expand description

The parameters for using a Timestream for LiveAnalytics table as a target.

Fields (Non-exhaustive)§

This struct is marked as non-exhaustive
Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.
§time_value: String

Dynamic path to the source data field that represents the time value for your data.

§epoch_time_unit: Option<EpochTimeUnit>

The granularity of the time units used. Default is MILLISECONDS.

Required if TimeFieldType is specified as EPOCH.

§time_field_type: Option<TimeFieldType>

The type of time value used.

The default is EPOCH.

§timestamp_format: Option<String>

How to format the timestamps. For example, YYYY-MM-DDThh:mm:ss.sssTZD.

Required if TimeFieldType is specified as TIMESTAMP_FORMAT.

§version_value: String

64 bit version value or source data field that represents the version value for your data.

Write requests with a higher version number will update the existing measure values of the record and version. In cases where the measure value is the same, the version will still be updated.

Default value is 1.

Timestream for LiveAnalytics does not support updating partial measure values in a record.

Write requests for duplicate data with a higher version number will update the existing measure value and version. In cases where the measure value is the same, Version will still be updated. Default value is 1.

Version must be 1 or greater, or you will receive a ValidationException error.

§dimension_mappings: Vec<DimensionMapping>

Map source data to dimensions in the target Timestream for LiveAnalytics table.

For more information, see Amazon Timestream for LiveAnalytics concepts

§single_measure_mappings: Option<Vec<SingleMeasureMapping>>

Mappings of single source data fields to individual records in the specified Timestream for LiveAnalytics table.

§multi_measure_mappings: Option<Vec<MultiMeasureMapping>>

Maps multiple measures from the source event to the same record in the specified Timestream for LiveAnalytics table.

Implementations§

source§

impl PipeTargetTimestreamParameters

source

pub fn time_value(&self) -> &str

Dynamic path to the source data field that represents the time value for your data.

source

pub fn epoch_time_unit(&self) -> Option<&EpochTimeUnit>

The granularity of the time units used. Default is MILLISECONDS.

Required if TimeFieldType is specified as EPOCH.

source

pub fn time_field_type(&self) -> Option<&TimeFieldType>

The type of time value used.

The default is EPOCH.

source

pub fn timestamp_format(&self) -> Option<&str>

How to format the timestamps. For example, YYYY-MM-DDThh:mm:ss.sssTZD.

Required if TimeFieldType is specified as TIMESTAMP_FORMAT.

source

pub fn version_value(&self) -> &str

64 bit version value or source data field that represents the version value for your data.

Write requests with a higher version number will update the existing measure values of the record and version. In cases where the measure value is the same, the version will still be updated.

Default value is 1.

Timestream for LiveAnalytics does not support updating partial measure values in a record.

Write requests for duplicate data with a higher version number will update the existing measure value and version. In cases where the measure value is the same, Version will still be updated. Default value is 1.

Version must be 1 or greater, or you will receive a ValidationException error.

source

pub fn dimension_mappings(&self) -> &[DimensionMapping]

Map source data to dimensions in the target Timestream for LiveAnalytics table.

For more information, see Amazon Timestream for LiveAnalytics concepts

source

pub fn single_measure_mappings(&self) -> &[SingleMeasureMapping]

Mappings of single source data fields to individual records in the specified Timestream for LiveAnalytics table.

If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use .single_measure_mappings.is_none().

source

pub fn multi_measure_mappings(&self) -> &[MultiMeasureMapping]

Maps multiple measures from the source event to the same record in the specified Timestream for LiveAnalytics table.

If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use .multi_measure_mappings.is_none().

source§

impl PipeTargetTimestreamParameters

source

pub fn builder() -> PipeTargetTimestreamParametersBuilder

Creates a new builder-style object to manufacture PipeTargetTimestreamParameters.

Trait Implementations§

source§

impl Clone for PipeTargetTimestreamParameters

source§

fn clone(&self) -> PipeTargetTimestreamParameters

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 PipeTargetTimestreamParameters

source§

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

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

impl PartialEq for PipeTargetTimestreamParameters

source§

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

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

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

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

impl StructuralPartialEq for PipeTargetTimestreamParameters

Auto Trait Implementations§

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
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

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<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

source§

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

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

§

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, U> TryFrom<U> for T
where U: Into<T>,

§

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>,

§

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.
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