Interface PipelineActivity.Builder

All Superinterfaces:

Buildable, CopyableBuilder<PipelineActivity.Builder,PipelineActivity>, SdkBuilder<PipelineActivity.Builder,PipelineActivity>, SdkPojo

Enclosing class:

PipelineActivity

@Mutable
@NotThreadSafe
public static interface PipelineActivity.Builder
extends SdkPojo, CopyableBuilder<PipelineActivity.Builder,PipelineActivity>

Method Summary

Modifier and Type	Method	Description
default PipelineActivity.Builder	addAttributes(Consumer<AddAttributesActivity.Builder> addAttributes)	Adds other attributes based on existing attributes in the message.
PipelineActivity.Builder	addAttributes(AddAttributesActivity addAttributes)	Adds other attributes based on existing attributes in the message.
default PipelineActivity.Builder	channel(Consumer<ChannelActivity.Builder> channel)	Determines the source of the messages to be processed.
PipelineActivity.Builder	channel(ChannelActivity channel)	Determines the source of the messages to be processed.
default PipelineActivity.Builder	datastore(Consumer<DatastoreActivity.Builder> datastore)	Specifies where to store the processed message data.
PipelineActivity.Builder	datastore(DatastoreActivity datastore)	Specifies where to store the processed message data.
default PipelineActivity.Builder	deviceRegistryEnrich(Consumer<DeviceRegistryEnrichActivity.Builder> deviceRegistryEnrich)	Adds data from the IoT device registry to your message.
PipelineActivity.Builder	deviceRegistryEnrich(DeviceRegistryEnrichActivity deviceRegistryEnrich)	Adds data from the IoT device registry to your message.
default PipelineActivity.Builder	deviceShadowEnrich(Consumer<DeviceShadowEnrichActivity.Builder> deviceShadowEnrich)	Adds information from the IoT Device Shadow service to a message.
PipelineActivity.Builder	deviceShadowEnrich(DeviceShadowEnrichActivity deviceShadowEnrich)	Adds information from the IoT Device Shadow service to a message.
default PipelineActivity.Builder	filter(Consumer<FilterActivity.Builder> filter)	Filters a message based on its attributes.
PipelineActivity.Builder	filter(FilterActivity filter)	Filters a message based on its attributes.
default PipelineActivity.Builder	lambda(Consumer<LambdaActivity.Builder> lambda)	Runs a Lambda function to modify the message.
PipelineActivity.Builder	lambda(LambdaActivity lambda)	Runs a Lambda function to modify the message.
default PipelineActivity.Builder	math(Consumer<MathActivity.Builder> math)	Computes an arithmetic expression using the message's attributes and adds it to the message.
PipelineActivity.Builder	math(MathActivity math)	Computes an arithmetic expression using the message's attributes and adds it to the message.
default PipelineActivity.Builder	removeAttributes(Consumer<RemoveAttributesActivity.Builder> removeAttributes)	Removes attributes from a message.
PipelineActivity.Builder	removeAttributes(RemoveAttributesActivity removeAttributes)	Removes attributes from a message.
default PipelineActivity.Builder	selectAttributes(Consumer<SelectAttributesActivity.Builder> selectAttributes)	Used to create a new message using only the specified attributes from the original message.
PipelineActivity.Builder	selectAttributes(SelectAttributesActivity selectAttributes)	Used to create a new message using only the specified attributes from the original message.

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

copy

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

applyMutation, build

Methods inherited from interface software.amazon.awssdk.core.SdkPojo

equalsBySdkFields, sdkFieldNameToField, sdkFields

Method Details

channel

PipelineActivity.Builder channel(ChannelActivity channel)

Determines the source of the messages to be processed.

Parameters:

channel - Determines the source of the messages to be processed.

Returns:

Returns a reference to this object so that method calls can be chained together.

channel

default PipelineActivity.Builder channel(Consumer<ChannelActivity.Builder> channel)

Determines the source of the messages to be processed.

This is a convenience method that creates an instance of the ChannelActivity.Builder avoiding the need to create one manually via ChannelActivity.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to channel(ChannelActivity).

Parameters:

channel - a consumer that will call methods on ChannelActivity.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• channel(ChannelActivity)

lambda

PipelineActivity.Builder lambda(LambdaActivity lambda)

Runs a Lambda function to modify the message.

Parameters:

lambda - Runs a Lambda function to modify the message.

Returns:

Returns a reference to this object so that method calls can be chained together.

lambda

default PipelineActivity.Builder lambda(Consumer<LambdaActivity.Builder> lambda)

Runs a Lambda function to modify the message.

This is a convenience method that creates an instance of the LambdaActivity.Builder avoiding the need to create one manually via LambdaActivity.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to lambda(LambdaActivity).

Parameters:

lambda - a consumer that will call methods on LambdaActivity.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• lambda(LambdaActivity)

datastore

PipelineActivity.Builder datastore(DatastoreActivity datastore)

Specifies where to store the processed message data.

Parameters:

datastore - Specifies where to store the processed message data.

Returns:

Returns a reference to this object so that method calls can be chained together.

datastore

default PipelineActivity.Builder datastore(Consumer<DatastoreActivity.Builder> datastore)

Specifies where to store the processed message data.

This is a convenience method that creates an instance of the DatastoreActivity.Builder avoiding the need to create one manually via DatastoreActivity.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to datastore(DatastoreActivity).

Parameters:

datastore - a consumer that will call methods on DatastoreActivity.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• datastore(DatastoreActivity)

addAttributes

PipelineActivity.Builder addAttributes(AddAttributesActivity addAttributes)

Adds other attributes based on existing attributes in the message.

Parameters:

addAttributes - Adds other attributes based on existing attributes in the message.

Returns:

Returns a reference to this object so that method calls can be chained together.

addAttributes

default PipelineActivity.Builder addAttributes(Consumer<AddAttributesActivity.Builder> addAttributes)

Adds other attributes based on existing attributes in the message.

This is a convenience method that creates an instance of the AddAttributesActivity.Builder avoiding the need to create one manually via AddAttributesActivity.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to addAttributes(AddAttributesActivity).

Parameters:

addAttributes - a consumer that will call methods on AddAttributesActivity.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• addAttributes(AddAttributesActivity)

removeAttributes

PipelineActivity.Builder removeAttributes(RemoveAttributesActivity removeAttributes)

Removes attributes from a message.

Parameters:

removeAttributes - Removes attributes from a message.

Returns:

Returns a reference to this object so that method calls can be chained together.

removeAttributes

default PipelineActivity.Builder removeAttributes(Consumer<RemoveAttributesActivity.Builder> removeAttributes)

Removes attributes from a message.

This is a convenience method that creates an instance of the RemoveAttributesActivity.Builder avoiding the need to create one manually via RemoveAttributesActivity.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to removeAttributes(RemoveAttributesActivity).

Parameters:

removeAttributes - a consumer that will call methods on RemoveAttributesActivity.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• removeAttributes(RemoveAttributesActivity)

selectAttributes

PipelineActivity.Builder selectAttributes(SelectAttributesActivity selectAttributes)

Used to create a new message using only the specified attributes from the original message.

Parameters:

selectAttributes - Used to create a new message using only the specified attributes from the original message.

Returns:

Returns a reference to this object so that method calls can be chained together.

selectAttributes

default PipelineActivity.Builder selectAttributes(Consumer<SelectAttributesActivity.Builder> selectAttributes)

Used to create a new message using only the specified attributes from the original message.

This is a convenience method that creates an instance of the SelectAttributesActivity.Builder avoiding the need to create one manually via SelectAttributesActivity.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to selectAttributes(SelectAttributesActivity).

Parameters:

selectAttributes - a consumer that will call methods on SelectAttributesActivity.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• selectAttributes(SelectAttributesActivity)

filter

PipelineActivity.Builder filter(FilterActivity filter)

Filters a message based on its attributes.

Parameters:

filter - Filters a message based on its attributes.

Returns:

Returns a reference to this object so that method calls can be chained together.

filter

default PipelineActivity.Builder filter(Consumer<FilterActivity.Builder> filter)

Filters a message based on its attributes.

This is a convenience method that creates an instance of the FilterActivity.Builder avoiding the need to create one manually via FilterActivity.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to filter(FilterActivity).

Parameters:

filter - a consumer that will call methods on FilterActivity.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• filter(FilterActivity)

math

PipelineActivity.Builder math(MathActivity math)

Computes an arithmetic expression using the message's attributes and adds it to the message.

Parameters:

math - Computes an arithmetic expression using the message's attributes and adds it to the message.

Returns:

Returns a reference to this object so that method calls can be chained together.

math

default PipelineActivity.Builder math(Consumer<MathActivity.Builder> math)

Computes an arithmetic expression using the message's attributes and adds it to the message.

This is a convenience method that creates an instance of the MathActivity.Builder avoiding the need to create one manually via MathActivity.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to math(MathActivity).

Parameters:

math - a consumer that will call methods on MathActivity.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• math(MathActivity)

deviceRegistryEnrich

PipelineActivity.Builder deviceRegistryEnrich(DeviceRegistryEnrichActivity deviceRegistryEnrich)

Adds data from the IoT device registry to your message.

Parameters:

deviceRegistryEnrich - Adds data from the IoT device registry to your message.

Returns:

Returns a reference to this object so that method calls can be chained together.

deviceRegistryEnrich

default PipelineActivity.Builder deviceRegistryEnrich(Consumer<DeviceRegistryEnrichActivity.Builder> deviceRegistryEnrich)

Adds data from the IoT device registry to your message.

This is a convenience method that creates an instance of the DeviceRegistryEnrichActivity.Builder avoiding the need to create one manually via DeviceRegistryEnrichActivity.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to deviceRegistryEnrich(DeviceRegistryEnrichActivity).

Parameters:

deviceRegistryEnrich - a consumer that will call methods on DeviceRegistryEnrichActivity.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• deviceRegistryEnrich(DeviceRegistryEnrichActivity)

deviceShadowEnrich

PipelineActivity.Builder deviceShadowEnrich(DeviceShadowEnrichActivity deviceShadowEnrich)

Adds information from the IoT Device Shadow service to a message.

Parameters:

deviceShadowEnrich - Adds information from the IoT Device Shadow service to a message.

Returns:

Returns a reference to this object so that method calls can be chained together.

deviceShadowEnrich

default PipelineActivity.Builder deviceShadowEnrich(Consumer<DeviceShadowEnrichActivity.Builder> deviceShadowEnrich)

Adds information from the IoT Device Shadow service to a message.

This is a convenience method that creates an instance of the DeviceShadowEnrichActivity.Builder avoiding the need to create one manually via DeviceShadowEnrichActivity.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to deviceShadowEnrich(DeviceShadowEnrichActivity).

Parameters:

deviceShadowEnrich - a consumer that will call methods on DeviceShadowEnrichActivity.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• deviceShadowEnrich(DeviceShadowEnrichActivity)