PipelineActivity class

An activity that performs a transformation on a message.

Constructors

PipelineActivity({AddAttributesActivity? addAttributes, ChannelActivity? channel, DatastoreActivity? datastore, DeviceRegistryEnrichActivity? deviceRegistryEnrich, DeviceShadowEnrichActivity? deviceShadowEnrich, FilterActivity? filter, LambdaActivity? lambda, MathActivity? math, RemoveAttributesActivity? removeAttributes, SelectAttributesActivity? selectAttributes})
PipelineActivity.fromJson(Map<String, dynamic> json)
factory

Properties

addAttributes AddAttributesActivity?
Adds other attributes based on existing attributes in the message.
final
channel ChannelActivity?
Determines the source of the messages to be processed.
final
datastore DatastoreActivity?
Specifies where to store the processed message data.
final
deviceRegistryEnrich DeviceRegistryEnrichActivity?
Adds data from the AWS IoT device registry to your message.
final
deviceShadowEnrich DeviceShadowEnrichActivity?
Adds information from the AWS IoT Device Shadow service to a message.
final
filter FilterActivity?
Filters a message based on its attributes.
final
hashCode int
The hash code for this object.
no setterinherited
lambda LambdaActivity?
Runs a Lambda function to modify the message.
final
math MathActivity?
Computes an arithmetic expression using the message's attributes and adds it to the message.
final
removeAttributes RemoveAttributesActivity?
Removes attributes from a message.
final
runtimeType Type
A representation of the runtime type of the object.
no setterinherited
selectAttributes SelectAttributesActivity?
Creates a new message using only the specified attributes from the original message.
final

Methods

noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
toJson() Map<String, dynamic>
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited