Create records to copy data, send corrected records for reprocessing, and create test data quickly.
Select records and forward them to another stream in your cluster.
Save code as a partial data view to reuse later.
Overwrite, delete or calculate new values for message value attributes and keys.
Calculate and temporarily store data to aggregate or group data.