Class PipelineActivity
- All Implemented Interfaces:
Serializable,SdkPojo,ToCopyableBuilder<PipelineActivity.Builder,PipelineActivity>
An activity that performs a transformation on a message.
- See Also:
-
Nested Class Summary
Nested Classes -
Method Summary
Modifier and TypeMethodDescriptionfinal AddAttributesActivityAdds other attributes based on existing attributes in the message.static PipelineActivity.Builderbuilder()final ChannelActivitychannel()Determines the source of the messages to be processed.final DatastoreActivitySpecifies where to store the processed message data.Adds data from the IoT device registry to your message.Adds information from the IoT Device Shadow service to a message.final booleanfinal booleanequalsBySdkFields(Object obj) Indicates whether some other object is "equal to" this one by SDK fields.final FilterActivityfilter()Filters a message based on its attributes.final <T> Optional<T> getValueForField(String fieldName, Class<T> clazz) final inthashCode()final LambdaActivitylambda()Runs a Lambda function to modify the message.final MathActivitymath()Computes an arithmetic expression using the message's attributes and adds it to the message.final RemoveAttributesActivityRemoves attributes from a message.final SelectAttributesActivityUsed to create a new message using only the specified attributes from the original message.static Class<? extends PipelineActivity.Builder> Take this object and create a builder that contains all of the current property values of this object.final StringtoString()Returns a string representation of this object.Methods inherited from interface software.amazon.awssdk.utils.builder.ToCopyableBuilder
copy
-
Method Details
-
channel
Determines the source of the messages to be processed.
- Returns:
- Determines the source of the messages to be processed.
-
lambda
Runs a Lambda function to modify the message.
- Returns:
- Runs a Lambda function to modify the message.
-
datastore
Specifies where to store the processed message data.
- Returns:
- Specifies where to store the processed message data.
-
addAttributes
Adds other attributes based on existing attributes in the message.
- Returns:
- Adds other attributes based on existing attributes in the message.
-
removeAttributes
Removes attributes from a message.
- Returns:
- Removes attributes from a message.
-
selectAttributes
Used to create a new message using only the specified attributes from the original message.
- Returns:
- Used to create a new message using only the specified attributes from the original message.
-
filter
Filters a message based on its attributes.
- Returns:
- Filters a message based on its attributes.
-
math
Computes an arithmetic expression using the message's attributes and adds it to the message.
- Returns:
- Computes an arithmetic expression using the message's attributes and adds it to the message.
-
deviceRegistryEnrich
Adds data from the IoT device registry to your message.
- Returns:
- Adds data from the IoT device registry to your message.
-
deviceShadowEnrich
Adds information from the IoT Device Shadow service to a message.
- Returns:
- Adds information from the IoT Device Shadow service to a message.
-
toBuilder
Description copied from interface:ToCopyableBuilderTake this object and create a builder that contains all of the current property values of this object.- Specified by:
toBuilderin interfaceToCopyableBuilder<PipelineActivity.Builder,PipelineActivity> - Returns:
- a builder for type T
-
builder
-
serializableBuilderClass
-
hashCode
-
equals
-
equalsBySdkFields
Description copied from interface:SdkPojoIndicates whether some other object is "equal to" this one by SDK fields. An SDK field is a modeled, non-inherited field in anSdkPojoclass, and is generated based on a service model.If an
SdkPojoclass does not have any inherited fields,equalsBySdkFieldsandequalsare essentially the same.- Specified by:
equalsBySdkFieldsin interfaceSdkPojo- Parameters:
obj- the object to be compared with- Returns:
- true if the other object equals to this object by sdk fields, false otherwise.
-
toString
-
getValueForField
-
sdkFields
-