Class OffsetTimestamp
Represents an operator that shifts the timestamps of a sequence of timestamped payload values by the specified time interval.
[Combinator]
[WorkflowElementCategory(ElementCategory.Transform)]
public class OffsetTimestamp
- Inheritance
-
OffsetTimestamp
- Inherited Members
Properties
TimeShift
Gets or sets a time interval by which to offset the sequence timestamps.
public TimeSpan TimeShift { get; set; }
Property Value
Methods
Process<T>(IObservable<Timestamped<T>>)
Shifts the timestamps of an observable sequence of timestamped payload values by the specified offset.
public IObservable<Timestamped<T>> Process<T>(IObservable<Timestamped<T>> source)
Parameters
source
IObservable<Timestamped<T>>An observable sequence of timestamped payload values.
Returns
- IObservable<Timestamped<T>>
A sequence of timestamped payload values where each timestamp is computed by adding the time interval offset to the timestamp of the corresponding payload in the
source
sequence.
Type Parameters
T
The type of the values in each timestamped payload.
Process<T>(IObservable<Tuple<Timestamped<T>, double>>)
Shifts the timestamps of an observable sequence of timestamped payload values by the specified offset, in fractional seconds.
public IObservable<Timestamped<T>> Process<T>(IObservable<Tuple<Timestamped<T>, double>> source)
Parameters
source
IObservable<Tuple<Timestamped<T>, double>>A sequence of pairs containing a timestamped payload and a time interval, in fractional seconds, by which to offset the payload timestamp.
Returns
- IObservable<Timestamped<T>>
A sequence of timestamped payload values where each timestamp is computed by adding both the seconds offset and the base TimeShift offset to the timestamp of the corresponding payload in the
source
sequence.
Type Parameters
T
The type of the values in each timestamped payload.
Process<T>(IObservable<Tuple<Timestamped<T>, TimeSpan>>)
Shifts the timestamps of an observable sequence of timestamped payload values by the specified time interval.
public IObservable<Timestamped<T>> Process<T>(IObservable<Tuple<Timestamped<T>, TimeSpan>> source)
Parameters
source
IObservable<Tuple<Timestamped<T>, TimeSpan>>A sequence of pairs containing a timestamped payload and the time interval by which to offset the payload timestamp.
Returns
- IObservable<Timestamped<T>>
A sequence of timestamped payload values where each timestamp is computed by adding both the time interval and the base TimeShift offset to the timestamp of the corresponding payload in the
source
sequence.
Type Parameters
T
The type of the values in each timestamped payload.