software.amazon.awssdk.services.iotanalytics.model

Class PipelineActivity

java.lang.Object

software.amazon.awssdk.services.iotanalytics.model.PipelineActivity

All Implemented Interfaces:

Serializable, SdkPojo, ToCopyableBuilder<PipelineActivity.Builder,PipelineActivity>

@Generated(value="software.amazon.awssdk:codegen")
public final class PipelineActivity
extends Object
implements SdkPojo, Serializable, ToCopyableBuilder<PipelineActivity.Builder,PipelineActivity>

An activity that performs a transformation on a message.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	PipelineActivity.Builder

Method Summary

Modifier and Type	Method and Description
AddAttributesActivity	addAttributes() Adds other attributes based on existing attributes in the message.
static PipelineActivity.Builder	builder()
ChannelActivity	channel() Determines the source of the messages to be processed.
DatastoreActivity	datastore() Specifies where to store the processed message data.
DeviceRegistryEnrichActivity	deviceRegistryEnrich() Adds data from the AWS IoT device registry to your message.
DeviceShadowEnrichActivity	deviceShadowEnrich() Adds information from the AWS IoT Device Shadows service to a message.
boolean	equals(Object obj)
FilterActivity	filter() Filters a message based on its attributes.
<T> Optional<T>	getValueForField(String fieldName, Class<T> clazz)
int	hashCode()
LambdaActivity	lambda() Runs a Lambda function to modify the message.
MathActivity	math() Computes an arithmetic expression using the message's attributes and adds it to the message.
RemoveAttributesActivity	removeAttributes() Removes attributes from a message.
List<SdkField<?>>	sdkFields()
SelectAttributesActivity	selectAttributes() Creates a new message using only the specified attributes from the original message.
static Class<? extends PipelineActivity.Builder>	serializableBuilderClass()
PipelineActivity.Builder	toBuilder() Take this object and create a builder that contains all of the current property values of this object.
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface software.amazon.awssdk.utils.builder.ToCopyableBuilder

copy

Method Detail

channel

public ChannelActivity channel()

Determines the source of the messages to be processed.

Returns:

Determines the source of the messages to be processed.

lambda

public LambdaActivity lambda()

Runs a Lambda function to modify the message.

Returns:

Runs a Lambda function to modify the message.

datastore

public DatastoreActivity datastore()

Specifies where to store the processed message data.

Returns:

Specifies where to store the processed message data.

addAttributes

public AddAttributesActivity addAttributes()

Adds other attributes based on existing attributes in the message.

Returns:

Adds other attributes based on existing attributes in the message.

removeAttributes

public RemoveAttributesActivity removeAttributes()

Removes attributes from a message.

Returns:

Removes attributes from a message.

selectAttributes

public SelectAttributesActivity selectAttributes()

Creates a new message using only the specified attributes from the original message.

Returns:

Creates a new message using only the specified attributes from the original message.

filter

public FilterActivity filter()

Filters a message based on its attributes.

Returns:

Filters a message based on its attributes.

math

public MathActivity 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

public DeviceRegistryEnrichActivity deviceRegistryEnrich()

Adds data from the AWS IoT device registry to your message.

Returns:

Adds data from the AWS IoT device registry to your message.

deviceShadowEnrich

public DeviceShadowEnrichActivity deviceShadowEnrich()

Adds information from the AWS IoT Device Shadows service to a message.

Returns:

Adds information from the AWS IoT Device Shadows service to a message.

toBuilder

public PipelineActivity.Builder toBuilder()

Description copied from interface: ToCopyableBuilder

Take this object and create a builder that contains all of the current property values of this object.

Specified by:

toBuilder in interface ToCopyableBuilder<PipelineActivity.Builder,PipelineActivity>

Returns:

a builder for type T

builder

public static PipelineActivity.Builder builder()

serializableBuilderClass

public static Class<? extends PipelineActivity.Builder> serializableBuilderClass()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

getValueForField

public <T> Optional<T> getValueForField(String fieldName,
                                        Class<T> clazz)

sdkFields

public List<SdkField<?>> sdkFields()

Specified by:

sdkFields in interface SdkPojo

Returns:

List of SdkField in this POJO. May be empty list but should never be null.