+ 
+
* Logging will not be done: *
-
@@ -22,15 +24,37 @@ public interface LambdaLogger {
*
*
+ * See Pre Token Generation Lambda Trigger
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@NoArgsConstructor
+@ToString(callSuper = true)
+public class CognitoUserPoolPreTokenGenerationEventV2 extends CognitoUserPoolEvent {
+ /**
+ * The request from the Amazon Cognito service.
+ */
+ private Request request;
+
+ /**
+ * The response from your Lambda trigger.
+ */
+ private Response response;
+
+ @Builder(setterPrefix = "with")
+ public CognitoUserPoolPreTokenGenerationEventV2(
+ String version,
+ String triggerSource,
+ String region,
+ String userPoolId,
+ String userName,
+ CallerContext callerContext,
+ Request request,
+ Response response) {
+ super(version, triggerSource, region, userPoolId, userName, callerContext);
+ this.request = request;
+ this.response = response;
+ }
+
+ @Data
+ @EqualsAndHashCode(callSuper = true)
+ @NoArgsConstructor
+ @ToString(callSuper = true)
+ public static class Request extends CognitoUserPoolEvent.Request {
+
+ private String[] scopes;
+ private GroupConfiguration groupConfiguration;
+ private Map
+ * Represents the data for an attribute.
+ *
+ * Each attribute value is described as a name-value pair. The name is the data type, and the value is the data itself.
+ *
+ * For more information, see Data Types in the Amazon DynamoDB Developer Guide.
+ *
+ * An attribute of type String. For example:
+ *
+ *
+ * An attribute of type Number. For example:
+ *
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and
+ * libraries. However, DynamoDB treats them as number type attributes for mathematical operations.
+ *
+ * An attribute of type Binary. For example:
+ *
+ *
+ * An attribute of type String Set. For example:
+ *
+ *
+ * An attribute of type Number Set. For example:
+ *
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and
+ * libraries. However, DynamoDB treats them as number type attributes for mathematical operations.
+ *
+ * An attribute of type Binary Set. For example:
+ *
+ *
+ * An attribute of type Map. For example:
+ *
+ *
+ * An attribute of type List. For example:
+ *
+ *
+ * An attribute of type Null. For example:
+ *
+ *
+ * An attribute of type Boolean. For example:
+ *
+ *
+ *
+ */
+
+@Data
+@Builder(setterPrefix = "with")
+@NoArgsConstructor
+@AllArgsConstructor
+public class S3ObjectLambdaEvent {
+
+ private String xAmzRequestId;
+ private GetObjectContext getObjectContext;
+ private Configuration configuration;
+ private UserRequest userRequest;
+ private UserIdentity userIdentity;
+ private String protocolVersion;
+
+ /**
+ * A pre-signed URL that can be used to fetch the original object from Amazon S3.
+ *
+ * The URL is signed using the original caller's identity, and their permissions
+ * will apply when the URL is used. If there are signed headers in the URL, the
+ * Lambda function must include these in the call to Amazon S3, except for the Host.
+ *
+ * @return A pre-signed URL that can be used to fetch the original object from Amazon S3.
+ */
+ public String inputS3Url() {
+ return getGetObjectContext().getInputS3Url();
+ }
+
+ /**
+ * A routing token that is added to the S3 Object Lambda URL when the Lambda function
+ * calls the S3 API WriteGetObjectResponse.
+ *
+ * @return the outputRoute
+ */
+ public String outputRoute() {
+ return getGetObjectContext().getOutputRoute();
+ }
+
+ /**
+ * An opaque token used by S3 Object Lambda to match the WriteGetObjectResponse call
+ * with the original caller.
+ *
+ * @return the outputToken
+ */
+ public String outputToken() {
+ return getGetObjectContext().getOutputToken();
+ }
+
+ @Data
+ @Builder(setterPrefix = "with")
+ @NoArgsConstructor
+ @AllArgsConstructor
+ public static class GetObjectContext {
+ private String inputS3Url;
+ private String outputRoute;
+ private String outputToken;
+ }
+
+ @Data
+ @Builder(setterPrefix = "with")
+ @NoArgsConstructor
+ @AllArgsConstructor
+ public static class Configuration {
+ private String accessPointArn;
+ private String supportingAccessPointArn;
+ private String payload;
+ }
+
+ @Data
+ @Builder(setterPrefix = "with")
+ @NoArgsConstructor
+ @AllArgsConstructor
+ public static class UserRequest {
+ private String url;
+ private Mapimport com.amazonaws.services.lambda.runtime.Context;
+ * import com.amazonaws.services.lambda.runtime.events.S3ObjectLambdaEvent;
+ * import org.apache.http.client.fluent.Request;
+ * import software.amazon.awssdk.services.s3.S3Client;
+ * import software.amazon.awssdk.services.s3.model.WriteGetObjectResponseRequest;
+ *
+ * import java.io.IOException;
+ *
+ * import static software.amazon.awssdk.core.sync.RequestBody.fromString;
+ *
+ * public class S3ObjectRequestHandler {
+ *
+ * private static final S3Client s3Client = S3Client.create();
+ *
+ * public void handleRequest(S3ObjectLambdaEvent event, Context context) throws IOException {
+ * String s3Body = Request.Get(event.inputS3Url()).execute().returnContent().asString();
+ *
+ * String responseBody = s3Body.toUpperCase();
+ *
+ * WriteGetObjectResponseRequest request = WriteGetObjectResponseRequest.builder()
+ * .requestRoute(event.outputRoute())
+ * .requestToken(event.outputToken())
+ * .build();
+ * s3Client.writeGetObjectResponse(request, fromString(responseBody));
+ * }
+ * }
+ *
+ * "S": "Hello"
+ * "N": "123.45"
+ * "B": "dGhpcyB0ZXh0IGlzIGJhc2U2NC1lbmNvZGVk"
+ * "SS": ["Giraffe", "Hippo" ,"Zebra"]
+ * "NS": ["42.2", "-19", "7.5", "3.14"]
+ * "BS": ["U3Vubnk=", "UmFpbnk=", "U25vd3k="]
+ * "M": {"Name": {"S": "Joe"}, "Age": {"N": "35"}}
+ * "L": [ {"S": "Cookies"} , {"S": "Coffee"}, {"N", "3.14159"}]
+ * "NULL": true
+ * "BOOL": true
+ *
+ * "S": "Hello"
+ */
+ public AttributeValue(String s) {
+ setS(s);
+ }
+
+ /**
+ * Constructs a new DynamodbAttributeValue object. Callers should use the setter or fluent setter (with...) methods to
+ * initialize any additional object members.
+ *
+ * @param sS
+ * An attribute of type String Set. For example:
+ *
+ * An attribute of type String. For example:
+ *
+ * "SS": ["Giraffe", "Hippo" ,"Zebra"]
+ */
+ public AttributeValue(java.util.List"S": "Hello"
+ *
+ * "S": "Hello"
+ */
+
+ public void setS(String s) {
+ this.s = s;
+ }
+
+ /**
+ *
+ * An attribute of type String. For example: + *
+ *
+ * "S": "Hello"
+ *
+ * "S": "Hello"
+ */
+
+ public String getS() {
+ return this.s;
+ }
+
+ /**
+ *
+ * An attribute of type String. For example: + *
+ *
+ * "S": "Hello"
+ *
+ * "S": "Hello"
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withS(String s) {
+ setS(s);
+ return this;
+ }
+
+ /**
+ *
+ * An attribute of type Number. For example: + *
+ *
+ * "N": "123.45"
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and + * libraries. However, DynamoDB treats them as number type attributes for mathematical operations. + *
+ * + * @param n + * An attribute of type Number. For example: + *
+ * "N": "123.45"
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and + * libraries. However, DynamoDB treats them as number type attributes for mathematical operations. + */ + + public void setN(String n) { + this.n = n; + } + + /** + *
+ * An attribute of type Number. For example: + *
+ *
+ * "N": "123.45"
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and + * libraries. However, DynamoDB treats them as number type attributes for mathematical operations. + *
+ * + * @return An attribute of type Number. For example: + *
+ * "N": "123.45"
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages + * and libraries. However, DynamoDB treats them as number type attributes for mathematical operations. + */ + + public String getN() { + return this.n; + } + + /** + *
+ * An attribute of type Number. For example: + *
+ *
+ * "N": "123.45"
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and + * libraries. However, DynamoDB treats them as number type attributes for mathematical operations. + *
+ * + * @param n + * An attribute of type Number. For example: + *
+ * "N": "123.45"
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and + * libraries. However, DynamoDB treats them as number type attributes for mathematical operations. + * @return Returns a reference to this object so that method calls can be chained together. + */ + + public AttributeValue withN(String n) { + setN(n); + return this; + } + + /** + *
+ * An attribute of type Binary. For example: + *
+ *
+ * "B": "dGhpcyB0ZXh0IGlzIGJhc2U2NC1lbmNvZGVk"
+ *
+ * The AWS SDK for Java performs a Base64 encoding on this field before sending this request to the AWS service. + * Users of the SDK should not perform Base64 encoding on this field. + *
+ *+ * Warning: ByteBuffers returned by the SDK are mutable. Changes to the content or position of the byte buffer will + * be seen by all objects that have a reference to this object. It is recommended to call ByteBuffer.duplicate() or + * ByteBuffer.asReadOnlyBuffer() before using or reading from the buffer. This behavior will be changed in a future + * major version of the SDK. + *
+ * + * @param b + * An attribute of type Binary. For example: + *
+ * "B": "dGhpcyB0ZXh0IGlzIGJhc2U2NC1lbmNvZGVk"
+ */
+
+ public void setB(java.nio.ByteBuffer b) {
+ this.b = b;
+ }
+
+ /**
+ *
+ * An attribute of type Binary. For example: + *
+ *
+ * "B": "dGhpcyB0ZXh0IGlzIGJhc2U2NC1lbmNvZGVk"
+ *
+ * {@code ByteBuffer}s are stateful. Calling their {@code get} methods changes their {@code position}. We recommend + * using {@link java.nio.ByteBuffer#asReadOnlyBuffer()} to create a read-only view of the buffer with an independent + * {@code position}, and calling {@code get} methods on this rather than directly on the returned {@code ByteBuffer}. + * Doing so will ensure that anyone else using the {@code ByteBuffer} will not be affected by changes to the + * {@code position}. + *
+ * + * @return An attribute of type Binary. For example: + *
+ * "B": "dGhpcyB0ZXh0IGlzIGJhc2U2NC1lbmNvZGVk"
+ */
+
+ public java.nio.ByteBuffer getB() {
+ return this.b;
+ }
+
+ /**
+ *
+ * An attribute of type Binary. For example: + *
+ *
+ * "B": "dGhpcyB0ZXh0IGlzIGJhc2U2NC1lbmNvZGVk"
+ *
+ * The AWS SDK for Java performs a Base64 encoding on this field before sending this request to the AWS service. + * Users of the SDK should not perform Base64 encoding on this field. + *
+ *+ * Warning: ByteBuffers returned by the SDK are mutable. Changes to the content or position of the byte buffer will + * be seen by all objects that have a reference to this object. It is recommended to call ByteBuffer.duplicate() or + * ByteBuffer.asReadOnlyBuffer() before using or reading from the buffer. This behavior will be changed in a future + * major version of the SDK. + *
+ * + * @param b + * An attribute of type Binary. For example: + *
+ * "B": "dGhpcyB0ZXh0IGlzIGJhc2U2NC1lbmNvZGVk"
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withB(java.nio.ByteBuffer b) {
+ setB(b);
+ return this;
+ }
+
+ /**
+ *
+ * An attribute of type String Set. For example: + *
+ *
+ * "SS": ["Giraffe", "Hippo" ,"Zebra"]
+ *
+ *
+ * An attribute of type String Set. For example:
+ *
+ * "SS": ["Giraffe", "Hippo" ,"Zebra"]
+ */
+
+ public java.util.List"SS": ["Giraffe", "Hippo" ,"Zebra"]
+ *
+ *
+ * An attribute of type String Set. For example:
+ *
+ *
+ * NOTE: This method appends the values to the existing list (if any). Use
+ * {@link #setSS(java.util.Collection)} or {@link #withSS(java.util.Collection)} if you want to override the
+ * existing values.
+ * "SS": ["Giraffe", "Hippo" ,"Zebra"]
+ */
+
+ public void setSS(java.util.Collection"SS": ["Giraffe", "Hippo" ,"Zebra"]
+ *
+ *
+ * An attribute of type String Set. For example:
+ *
+ * "SS": ["Giraffe", "Hippo" ,"Zebra"]
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withSS(String... sS) {
+ if (this.sS == null) {
+ setSS(new java.util.ArrayList"SS": ["Giraffe", "Hippo" ,"Zebra"]
+ *
+ *
+ * An attribute of type Number Set. For example:
+ *
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and
+ * libraries. However, DynamoDB treats them as number type attributes for mathematical operations.
+ * "SS": ["Giraffe", "Hippo" ,"Zebra"]
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withSS(java.util.Collection"NS": ["42.2", "-19", "7.5", "3.14"]
+ *
+ * "NS": ["42.2", "-19", "7.5", "3.14"]
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages
+ * and libraries. However, DynamoDB treats them as number type attributes for mathematical operations.
+ */
+
+ public java.util.List
+ * An attribute of type Number Set. For example:
+ *
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and
+ * libraries. However, DynamoDB treats them as number type attributes for mathematical operations.
+ * "NS": ["42.2", "-19", "7.5", "3.14"]
+ *
+ * "NS": ["42.2", "-19", "7.5", "3.14"]
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and
+ * libraries. However, DynamoDB treats them as number type attributes for mathematical operations.
+ */
+
+ public void setNS(java.util.Collection
+ * An attribute of type Number Set. For example:
+ *
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and
+ * libraries. However, DynamoDB treats them as number type attributes for mathematical operations.
+ *
+ * NOTE: This method appends the values to the existing list (if any). Use
+ * {@link #setNS(java.util.Collection)} or {@link #withNS(java.util.Collection)} if you want to override the
+ * existing values.
+ * "NS": ["42.2", "-19", "7.5", "3.14"]
+ *
+ * "NS": ["42.2", "-19", "7.5", "3.14"]
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and
+ * libraries. However, DynamoDB treats them as number type attributes for mathematical operations.
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withNS(String... nS) {
+ if (this.nS == null) {
+ setNS(new java.util.ArrayList
+ * An attribute of type Number Set. For example:
+ *
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and
+ * libraries. However, DynamoDB treats them as number type attributes for mathematical operations.
+ * "NS": ["42.2", "-19", "7.5", "3.14"]
+ *
+ * "NS": ["42.2", "-19", "7.5", "3.14"]
+ *
+ * Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and
+ * libraries. However, DynamoDB treats them as number type attributes for mathematical operations.
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withNS(java.util.Collection
+ * An attribute of type Binary Set. For example:
+ *
+ * "BS": ["U3Vubnk=", "UmFpbnk=", "U25vd3k="]
+ *
+ *
+ * An attribute of type Binary Set. For example:
+ *
+ * "BS": ["U3Vubnk=", "UmFpbnk=", "U25vd3k="]
+ */
+
+ public java.util.List"BS": ["U3Vubnk=", "UmFpbnk=", "U25vd3k="]
+ *
+ *
+ * An attribute of type Binary Set. For example:
+ *
+ *
+ * NOTE: This method appends the values to the existing list (if any). Use
+ * {@link #setBS(java.util.Collection)} or {@link #withBS(java.util.Collection)} if you want to override the
+ * existing values.
+ * "BS": ["U3Vubnk=", "UmFpbnk=", "U25vd3k="]
+ */
+
+ public void setBS(java.util.Collection"BS": ["U3Vubnk=", "UmFpbnk=", "U25vd3k="]
+ *
+ *
+ * An attribute of type Binary Set. For example:
+ *
+ * "BS": ["U3Vubnk=", "UmFpbnk=", "U25vd3k="]
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withBS(java.nio.ByteBuffer... bS) {
+ if (this.bS == null) {
+ setBS(new java.util.ArrayList"BS": ["U3Vubnk=", "UmFpbnk=", "U25vd3k="]
+ *
+ *
+ * An attribute of type Map. For example:
+ *
+ * "BS": ["U3Vubnk=", "UmFpbnk=", "U25vd3k="]
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withBS(java.util.Collection"M": {"Name": {"S": "Joe"}, "Age": {"N": "35"}}
+ *
+ *
+ * An attribute of type Map. For example:
+ *
+ * "M": {"Name": {"S": "Joe"}, "Age": {"N": "35"}}
+ */
+
+ public java.util.Map"M": {"Name": {"S": "Joe"}, "Age": {"N": "35"}}
+ *
+ *
+ * An attribute of type Map. For example:
+ *
+ * "M": {"Name": {"S": "Joe"}, "Age": {"N": "35"}}
+ */
+
+ public void setM(java.util.Map"M": {"Name": {"S": "Joe"}, "Age": {"N": "35"}}
+ *
+ *
+ * An attribute of type List. For example:
+ *
+ * "M": {"Name": {"S": "Joe"}, "Age": {"N": "35"}}
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withM(java.util.Map"L": [ {"S": "Cookies"} , {"S": "Coffee"}, {"N", "3.14159"}]
+ *
+ *
+ * An attribute of type List. For example:
+ *
+ * "L": [ {"S": "Cookies"} , {"S": "Coffee"}, {"N", "3.14159"}]
+ */
+
+ public java.util.List"L": [ {"S": "Cookies"} , {"S": "Coffee"}, {"N", "3.14159"}]
+ *
+ *
+ * An attribute of type List. For example:
+ *
+ *
+ * NOTE: This method appends the values to the existing list (if any). Use
+ * {@link #setL(java.util.Collection)} or {@link #withL(java.util.Collection)} if you want to override the existing
+ * values.
+ * "L": [ {"S": "Cookies"} , {"S": "Coffee"}, {"N", "3.14159"}]
+ */
+
+ public void setL(java.util.Collection"L": [ {"S": "Cookies"} , {"S": "Coffee"}, {"N", "3.14159"}]
+ *
+ *
+ * An attribute of type List. For example:
+ *
+ * "L": [ {"S": "Cookies"} , {"S": "Coffee"}, {"N", "3.14159"}]
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withL(AttributeValue... l) {
+ if (this.l == null) {
+ setL(new java.util.ArrayList"L": [ {"S": "Cookies"} , {"S": "Coffee"}, {"N", "3.14159"}]
+ *
+ *
+ * An attribute of type Null. For example:
+ *
+ * "L": [ {"S": "Cookies"} , {"S": "Coffee"}, {"N", "3.14159"}]
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withL(java.util.Collection"NULL": true
+ *
+ * "NULL": true
+ */
+
+ public void setNULL(Boolean nULLValue) {
+ this.nULLValue = nULLValue;
+ }
+
+ /**
+ *
+ * An attribute of type Null. For example: + *
+ *
+ * "NULL": true
+ *
+ * "NULL": true
+ */
+
+ public Boolean getNULL() {
+ return this.nULLValue;
+ }
+
+ /**
+ *
+ * An attribute of type Null. For example: + *
+ *
+ * "NULL": true
+ *
+ * "NULL": true
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withNULL(Boolean nULLValue) {
+ setNULL(nULLValue);
+ return this;
+ }
+
+ /**
+ *
+ * An attribute of type Null. For example: + *
+ *
+ * "NULL": true
+ *
+ * "NULL": true
+ */
+
+ public Boolean isNULL() {
+ return this.nULLValue;
+ }
+
+ /**
+ *
+ * An attribute of type Boolean. For example: + *
+ *
+ * "BOOL": true
+ *
+ * "BOOL": true
+ */
+
+ public void setBOOL(Boolean bOOL) {
+ this.bOOL = bOOL;
+ }
+
+ /**
+ *
+ * An attribute of type Boolean. For example: + *
+ *
+ * "BOOL": true
+ *
+ * "BOOL": true
+ */
+
+ public Boolean getBOOL() {
+ return this.bOOL;
+ }
+
+ /**
+ *
+ * An attribute of type Boolean. For example: + *
+ *
+ * "BOOL": true
+ *
+ * "BOOL": true
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+
+ public AttributeValue withBOOL(Boolean bOOL) {
+ setBOOL(bOOL);
+ return this;
+ }
+
+ /**
+ *
+ * An attribute of type Boolean. For example: + *
+ *
+ * "BOOL": true
+ *
+ * "BOOL": true
+ */
+
+ public Boolean isBOOL() {
+ return this.bOOL;
+ }
+
+ /**
+ * Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be
+ * redacted from this string using a placeholder value.
+ *
+ * @return A string representation of this object.
+ *
+ * @see Object#toString()
+ */
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("{");
+ if (getS() != null)
+ sb.append("S: ").append(getS()).append(",");
+ if (getN() != null)
+ sb.append("N: ").append(getN()).append(",");
+ if (getB() != null)
+ sb.append("B: ").append(getB()).append(",");
+ if (getSS() != null)
+ sb.append("SS: ").append(getSS()).append(",");
+ if (getNS() != null)
+ sb.append("NS: ").append(getNS()).append(",");
+ if (getBS() != null)
+ sb.append("BS: ").append(getBS()).append(",");
+ if (getM() != null)
+ sb.append("M: ").append(getM()).append(",");
+ if (getL() != null)
+ sb.append("L: ").append(getL()).append(",");
+ if (getNULL() != null)
+ sb.append("NULL: ").append(getNULL()).append(",");
+ if (getBOOL() != null)
+ sb.append("BOOL: ").append(getBOOL());
+ sb.append("}");
+ return sb.toString();
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ if (this == obj)
+ return true;
+ if (obj == null)
+ return false;
+
+ if (obj instanceof AttributeValue == false)
+ return false;
+ AttributeValue other = (AttributeValue) obj;
+ if (other.getS() == null ^ this.getS() == null)
+ return false;
+ if (other.getS() != null && other.getS().equals(this.getS()) == false)
+ return false;
+ if (other.getN() == null ^ this.getN() == null)
+ return false;
+ if (other.getN() != null && other.getN().equals(this.getN()) == false)
+ return false;
+ if (other.getB() == null ^ this.getB() == null)
+ return false;
+ if (other.getB() != null && other.getB().equals(this.getB()) == false)
+ return false;
+ if (other.getSS() == null ^ this.getSS() == null)
+ return false;
+ if (other.getSS() != null && other.getSS().equals(this.getSS()) == false)
+ return false;
+ if (other.getNS() == null ^ this.getNS() == null)
+ return false;
+ if (other.getNS() != null && other.getNS().equals(this.getNS()) == false)
+ return false;
+ if (other.getBS() == null ^ this.getBS() == null)
+ return false;
+ if (other.getBS() != null && other.getBS().equals(this.getBS()) == false)
+ return false;
+ if (other.getM() == null ^ this.getM() == null)
+ return false;
+ if (other.getM() != null && other.getM().equals(this.getM()) == false)
+ return false;
+ if (other.getL() == null ^ this.getL() == null)
+ return false;
+ if (other.getL() != null && other.getL().equals(this.getL()) == false)
+ return false;
+ if (other.getNULL() == null ^ this.getNULL() == null)
+ return false;
+ if (other.getNULL() != null && other.getNULL().equals(this.getNULL()) == false)
+ return false;
+ if (other.getBOOL() == null ^ this.getBOOL() == null)
+ return false;
+ if (other.getBOOL() != null && other.getBOOL().equals(this.getBOOL()) == false)
+ return false;
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ final int prime = 31;
+ int hashCode = 1;
+
+ hashCode = prime * hashCode + ((getS() == null) ? 0 : getS().hashCode());
+ hashCode = prime * hashCode + ((getN() == null) ? 0 : getN().hashCode());
+ hashCode = prime * hashCode + ((getB() == null) ? 0 : getB().hashCode());
+ hashCode = prime * hashCode + ((getSS() == null) ? 0 : getSS().hashCode());
+ hashCode = prime * hashCode + ((getNS() == null) ? 0 : getNS().hashCode());
+ hashCode = prime * hashCode + ((getBS() == null) ? 0 : getBS().hashCode());
+ hashCode = prime * hashCode + ((getM() == null) ? 0 : getM().hashCode());
+ hashCode = prime * hashCode + ((getL() == null) ? 0 : getL().hashCode());
+ hashCode = prime * hashCode + ((getNULL() == null) ? 0 : getNULL().hashCode());
+ hashCode = prime * hashCode + ((getBOOL() == null) ? 0 : getBOOL().hashCode());
+ return hashCode;
+ }
+
+ @Override
+ public AttributeValue clone() {
+ try {
+ return (AttributeValue) super.clone();
+ } catch (CloneNotSupportedException e) {
+ throw new IllegalStateException("Got a CloneNotSupportedException from Object.clone() even though we're Cloneable!", e);
+ }
+ }
+
+}
\ No newline at end of file
diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/Identity.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/Identity.java
new file mode 100644
index 000000000..12b2fbba1
--- /dev/null
+++ b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/Identity.java
@@ -0,0 +1,182 @@
+/*
+ * Copyright 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with
+ * the License. A copy of the License is located at
+ *
+ * http://aws.amazon.com/apache2.0
+ *
+ * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions
+ * and limitations under the License.
+ */
+package com.amazonaws.services.lambda.runtime.events.models.dynamodb;
+
+import java.io.Serializable;
+
+/**
+ *
+ * Contains details about the type of identity that made the request. + *
+ * + * @see AWS API + * Documentation + */ +public class Identity implements Serializable, Cloneable { + + /** + *+ * A unique identifier for the entity that made the call. For Time To Live, the principalId is + * "dynamodb.amazonaws.com". + *
+ */ + private String principalId; + + /** + *+ * The type of the identity. For Time To Live, the type is "Service". + *
+ */ + private String type; + + /** + *+ * A unique identifier for the entity that made the call. For Time To Live, the principalId is + * "dynamodb.amazonaws.com". + *
+ * + * @param principalId + * A unique identifier for the entity that made the call. For Time To Live, the principalId is + * "dynamodb.amazonaws.com". + */ + public void setPrincipalId(String principalId) { + this.principalId = principalId; + } + + /** + *+ * A unique identifier for the entity that made the call. For Time To Live, the principalId is + * "dynamodb.amazonaws.com". + *
+ * + * @return A unique identifier for the entity that made the call. For Time To Live, the principalId is + * "dynamodb.amazonaws.com". + */ + public String getPrincipalId() { + return this.principalId; + } + + /** + *+ * A unique identifier for the entity that made the call. For Time To Live, the principalId is + * "dynamodb.amazonaws.com". + *
+ * + * @param principalId + * A unique identifier for the entity that made the call. For Time To Live, the principalId is + * "dynamodb.amazonaws.com". + * @return Returns a reference to this object so that method calls can be chained together. + */ + public Identity withPrincipalId(String principalId) { + setPrincipalId(principalId); + return this; + } + + /** + *+ * The type of the identity. For Time To Live, the type is "Service". + *
+ * + * @param type + * The type of the identity. For Time To Live, the type is "Service". + */ + public void setType(String type) { + this.type = type; + } + + /** + *+ * The type of the identity. For Time To Live, the type is "Service". + *
+ * + * @return The type of the identity. For Time To Live, the type is "Service". + */ + public String getType() { + return this.type; + } + + /** + *+ * The type of the identity. For Time To Live, the type is "Service". + *
+ * + * @param type + * The type of the identity. For Time To Live, the type is "Service". + * @return Returns a reference to this object so that method calls can be chained together. + */ + public Identity withType(String type) { + setType(type); + return this; + } + + /** + * Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be + * redacted from this string using a placeholder value. + * + * @return A string representation of this object. + * + * @see Object#toString() + */ + @Override + public String toString() { + StringBuilder sb = new StringBuilder(); + sb.append("{"); + if (getPrincipalId() != null) + sb.append("PrincipalId: ").append(getPrincipalId()).append(","); + if (getType() != null) + sb.append("Type: ").append(getType()); + sb.append("}"); + return sb.toString(); + } + + @Override + public boolean equals(Object obj) { + if (this == obj) + return true; + if (obj == null) + return false; + + if (obj instanceof Identity == false) + return false; + Identity other = (Identity) obj; + if (other.getPrincipalId() == null ^ this.getPrincipalId() == null) + return false; + if (other.getPrincipalId() != null && other.getPrincipalId().equals(this.getPrincipalId()) == false) + return false; + if (other.getType() == null ^ this.getType() == null) + return false; + if (other.getType() != null && other.getType().equals(this.getType()) == false) + return false; + return true; + } + + @Override + public int hashCode() { + final int prime = 31; + int hashCode = 1; + + hashCode = prime * hashCode + ((getPrincipalId() == null) ? 0 : getPrincipalId().hashCode()); + hashCode = prime * hashCode + ((getType() == null) ? 0 : getType().hashCode()); + return hashCode; + } + + @Override + public Identity clone() { + try { + return (Identity) super.clone(); + } catch (CloneNotSupportedException e) { + throw new IllegalStateException("Got a CloneNotSupportedException from Object.clone() " + "even though we're Cloneable!", e); + } + } + +} diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/OperationType.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/OperationType.java new file mode 100644 index 000000000..8d5574ee1 --- /dev/null +++ b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/OperationType.java @@ -0,0 +1,54 @@ +/* + * Copyright 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with + * the License. A copy of the License is located at + * + * http://aws.amazon.com/apache2.0 + * + * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR + * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions + * and limitations under the License. + */ +package com.amazonaws.services.lambda.runtime.events.models.dynamodb; + +public enum OperationType { + + INSERT("INSERT"), + MODIFY("MODIFY"), + REMOVE("REMOVE"); + + private String value; + + private OperationType(String value) { + this.value = value; + } + + @Override + public String toString() { + return this.value; + } + + /** + * Use this in place of valueOf. + * + * @param value + * real value + * @return OperationType corresponding to the value + * + * @throws IllegalArgumentException + * If the specified value does not map to one of the known values in this enum. + */ + public static OperationType fromValue(String value) { + if (value == null || "".equals(value)) { + throw new IllegalArgumentException("Value cannot be null or empty!"); + } + + for (OperationType enumEntry : OperationType.values()) { + if (enumEntry.toString().equals(value)) { + return enumEntry; + } + } + throw new IllegalArgumentException("Cannot create enum from " + value + " value!"); + } +} \ No newline at end of file diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/Record.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/Record.java new file mode 100644 index 000000000..81065811f --- /dev/null +++ b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/Record.java @@ -0,0 +1,801 @@ +/* + * Copyright 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with + * the License. A copy of the License is located at + * + * http://aws.amazon.com/apache2.0 + * + * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR + * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions + * and limitations under the License. + */ +package com.amazonaws.services.lambda.runtime.events.models.dynamodb; + +import java.io.Serializable; + +/** + *+ * A description of a unique event within a stream. + *
+ * + * @see AWS API + * Documentation + */ +public class Record implements Serializable, Cloneable { + + /** + *+ * A globally unique identifier for the event that was recorded in this stream record. + *
+ */ + private String eventID; + /** + *+ * The type of data modification that was performed on the DynamoDB table: + *
+ *-
+ *
-
+ *
+ *
+ *INSERT- a new item was added to the table. + *
+ * -
+ *
+ *
+ *MODIFY- one or more of an existing item's attributes were modified. + *
+ * -
+ *
+ *
+ *REMOVE- the item was deleted from the table + *
+ *
+ * The version number of the stream record format. This number is updated whenever the structure of
+ * Record is modified.
+ *
+ * Client applications must not assume that eventVersion will remain at a particular value, as this
+ * number is subject to change at any time. In general, eventVersion will only increase as the
+ * low-level DynamoDB Streams API evolves.
+ *
+ * The AWS service from which the stream record originated. For DynamoDB Streams, this is aws:dynamodb.
+ *
+ * The region in which the GetRecords request was received.
+ *
+ * The main body of the stream record, containing all of the DynamoDB-specific fields. + *
+ */ + private StreamRecord dynamodb; + /** + *+ * Items that are deleted by the Time to Live process after expiration have the following fields: + *
+ *-
+ *
-
+ *
+ * Records[].userIdentity.type + *
+ *+ * "Service" + *
+ *
+ * -
+ *
+ * Records[].userIdentity.principalId + *
+ *+ * "dynamodb.amazonaws.com" + *
+ *
+ *
+ * A globally unique identifier for the event that was recorded in this stream record. + *
+ * + * @param eventID + * A globally unique identifier for the event that was recorded in this stream record. + */ + public void setEventID(String eventID) { + this.eventID = eventID; + } + + /** + *+ * A globally unique identifier for the event that was recorded in this stream record. + *
+ * + * @return A globally unique identifier for the event that was recorded in this stream record. + */ + public String getEventID() { + return this.eventID; + } + + /** + *+ * A globally unique identifier for the event that was recorded in this stream record. + *
+ * + * @param eventID + * A globally unique identifier for the event that was recorded in this stream record. + * @return Returns a reference to this object so that method calls can be chained together. + */ + public Record withEventID(String eventID) { + setEventID(eventID); + return this; + } + + /** + *+ * The type of data modification that was performed on the DynamoDB table: + *
+ *-
+ *
-
+ *
+ *
+ *INSERT- a new item was added to the table. + *
+ * -
+ *
+ *
+ *MODIFY- one or more of an existing item's attributes were modified. + *
+ * -
+ *
+ *
+ *REMOVE- the item was deleted from the table + *
+ *
-
+ *
-
+ *
+ *
+ *INSERT- a new item was added to the table. + *
+ * -
+ *
+ *
+ *MODIFY- one or more of an existing item's attributes were modified. + *
+ * -
+ *
+ *
+ *REMOVE- the item was deleted from the table + *
+ * @see OperationType
+ */
+ public void setEventName(String eventName) {
+ this.eventName = eventName;
+ }
+
+ /**
+ * -
+ *
+ *
+ *INSERT- a new item was added to the table. + *
+ * -
+ *
+ *
+ *MODIFY- one or more of an existing item's attributes were modified. + *
+ * -
+ *
+ *
+ *REMOVE- the item was deleted from the table + *
+ * -
+ *
+ *
+ *INSERT- a new item was added to the table. + *
+ * -
+ *
+ *
+ *MODIFY- one or more of an existing item's attributes were modified. + *
+ * -
+ *
+ *
+ *REMOVE- the item was deleted from the table + *
+ * @see OperationType
+ */
+ public String getEventName() {
+ return this.eventName;
+ }
+
+ /**
+ * -
+ *
+ *
+ *INSERT- a new item was added to the table. + *
+ * -
+ *
+ *
+ *MODIFY- one or more of an existing item's attributes were modified. + *
+ * -
+ *
+ *
+ *REMOVE- the item was deleted from the table + *
+ * -
+ *
+ *
+ *INSERT- a new item was added to the table. + *
+ * -
+ *
+ *
+ *MODIFY- one or more of an existing item's attributes were modified. + *
+ * -
+ *
+ *
+ *REMOVE- the item was deleted from the table + *
+ * @return Returns a reference to this object so that method calls can be chained together.
+ * @see OperationType
+ */
+ public Record withEventName(String eventName) {
+ setEventName(eventName);
+ return this;
+ }
+
+ /**
+ * -
+ *
+ *
+ *INSERT- a new item was added to the table. + *
+ * -
+ *
+ *
+ *MODIFY- one or more of an existing item's attributes were modified. + *
+ * -
+ *
+ *
+ *REMOVE- the item was deleted from the table + *
+ * -
+ *
+ *
+ *INSERT- a new item was added to the table. + *
+ * -
+ *
+ *
+ *MODIFY- one or more of an existing item's attributes were modified. + *
+ * -
+ *
+ *
+ *REMOVE- the item was deleted from the table + *
+ * @see OperationType
+ */
+ public void setEventName(OperationType eventName) {
+ this.eventName = eventName.toString();
+ }
+
+ /**
+ * -
+ *
+ *
+ *INSERT- a new item was added to the table. + *
+ * -
+ *
+ *
+ *MODIFY- one or more of an existing item's attributes were modified. + *
+ * -
+ *
+ *
+ *REMOVE- the item was deleted from the table + *
+ * -
+ *
+ *
+ *INSERT- a new item was added to the table. + *
+ * -
+ *
+ *
+ *MODIFY- one or more of an existing item's attributes were modified. + *
+ * -
+ *
+ *
+ *REMOVE- the item was deleted from the table + *
+ * @return Returns a reference to this object so that method calls can be chained together.
+ * @see OperationType
+ */
+ public Record withEventName(OperationType eventName) {
+ setEventName(eventName);
+ return this;
+ }
+
+ /**
+ * -
+ *
+ * Records[].userIdentity.type + *
+ *+ * "Service" + *
+ *
+ * -
+ *
+ * Records[].userIdentity.principalId + *
+ *+ * "dynamodb.amazonaws.com" + *
+ *
+ * -
+ *
+ * Records[].userIdentity.type + *
+ *+ * "Service" + *
+ *
+ * -
+ *
+ * Records[].userIdentity.principalId + *
+ *+ * "dynamodb.amazonaws.com" + *
+ *
+ */
+ public void setUserIdentity(Identity userIdentity) {
+ this.userIdentity = userIdentity;
+ }
+
+ /**
+ * -
+ *
+ * Records[].userIdentity.type + *
+ *+ * "Service" + *
+ *
+ * -
+ *
+ * Records[].userIdentity.principalId + *
+ *+ * "dynamodb.amazonaws.com" + *
+ *
+ * -
+ *
+ * Records[].userIdentity.type + *
+ *+ * "Service" + *
+ *
+ * -
+ *
+ * Records[].userIdentity.principalId + *
+ *+ * "dynamodb.amazonaws.com" + *
+ *
+ */
+ public Identity getUserIdentity() {
+ return this.userIdentity;
+ }
+
+ /**
+ * -
+ *
+ * Records[].userIdentity.type + *
+ *+ * "Service" + *
+ *
+ * -
+ *
+ * Records[].userIdentity.principalId + *
+ *+ * "dynamodb.amazonaws.com" + *
+ *
+ * -
+ *
+ * Records[].userIdentity.type + *
+ *+ * "Service" + *
+ *
+ * -
+ *
+ * Records[].userIdentity.principalId + *
+ *+ * "dynamodb.amazonaws.com" + *
+ *
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+ public Record withUserIdentity(Identity userIdentity) {
+ setUserIdentity(userIdentity);
+ return this;
+ }
+
+ /**
+ * Returns a string representation of this object; useful for testing and debugging.
+ *
+ * @return A string representation of this object.
+ *
+ * @see Object#toString()
+ */
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("{");
+ if (getEventID() != null)
+ sb.append("EventID: ").append(getEventID()).append(",");
+ if (getEventName() != null)
+ sb.append("EventName: ").append(getEventName()).append(",");
+ if (getEventVersion() != null)
+ sb.append("EventVersion: ").append(getEventVersion()).append(",");
+ if (getEventSource() != null)
+ sb.append("EventSource: ").append(getEventSource()).append(",");
+ if (getAwsRegion() != null)
+ sb.append("AwsRegion: ").append(getAwsRegion()).append(",");
+ if (getDynamodb() != null)
+ sb.append("Dynamodb: ").append(getDynamodb()).append(",");
+ if (getUserIdentity() != null)
+ sb.append("UserIdentity: ").append(getUserIdentity());
+ sb.append("}");
+ return sb.toString();
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ if (this == obj)
+ return true;
+ if (obj == null)
+ return false;
+
+ if (obj instanceof Record == false)
+ return false;
+ Record other = (Record) obj;
+ if (other.getEventID() == null ^ this.getEventID() == null)
+ return false;
+ if (other.getEventID() != null && other.getEventID().equals(this.getEventID()) == false)
+ return false;
+ if (other.getEventName() == null ^ this.getEventName() == null)
+ return false;
+ if (other.getEventName() != null && other.getEventName().equals(this.getEventName()) == false)
+ return false;
+ if (other.getEventVersion() == null ^ this.getEventVersion() == null)
+ return false;
+ if (other.getEventVersion() != null && other.getEventVersion().equals(this.getEventVersion()) == false)
+ return false;
+ if (other.getEventSource() == null ^ this.getEventSource() == null)
+ return false;
+ if (other.getEventSource() != null && other.getEventSource().equals(this.getEventSource()) == false)
+ return false;
+ if (other.getAwsRegion() == null ^ this.getAwsRegion() == null)
+ return false;
+ if (other.getAwsRegion() != null && other.getAwsRegion().equals(this.getAwsRegion()) == false)
+ return false;
+ if (other.getDynamodb() == null ^ this.getDynamodb() == null)
+ return false;
+ if (other.getDynamodb() != null && other.getDynamodb().equals(this.getDynamodb()) == false)
+ return false;
+ if (other.getUserIdentity() == null ^ this.getUserIdentity() == null)
+ return false;
+ if (other.getUserIdentity() != null && other.getUserIdentity().equals(this.getUserIdentity()) == false)
+ return false;
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ final int prime = 31;
+ int hashCode = 1;
+
+ hashCode = prime * hashCode + ((getEventID() == null) ? 0 : getEventID().hashCode());
+ hashCode = prime * hashCode + ((getEventName() == null) ? 0 : getEventName().hashCode());
+ hashCode = prime * hashCode + ((getEventVersion() == null) ? 0 : getEventVersion().hashCode());
+ hashCode = prime * hashCode + ((getEventSource() == null) ? 0 : getEventSource().hashCode());
+ hashCode = prime * hashCode + ((getAwsRegion() == null) ? 0 : getAwsRegion().hashCode());
+ hashCode = prime * hashCode + ((getDynamodb() == null) ? 0 : getDynamodb().hashCode());
+ hashCode = prime * hashCode + ((getUserIdentity() == null) ? 0 : getUserIdentity().hashCode());
+ return hashCode;
+ }
+
+ @Override
+ public Record clone() {
+ try {
+ return (Record) super.clone();
+ } catch (CloneNotSupportedException e) {
+ throw new IllegalStateException("Got a CloneNotSupportedException from Object.clone() " + "even though we're Cloneable!", e);
+ }
+ }
+
+}
\ No newline at end of file
diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/StreamRecord.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/StreamRecord.java
new file mode 100644
index 000000000..0e41c0de3
--- /dev/null
+++ b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/StreamRecord.java
@@ -0,0 +1,645 @@
+/*
+ * Copyright 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with
+ * the License. A copy of the License is located at
+ *
+ * http://aws.amazon.com/apache2.0
+ *
+ * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions
+ * and limitations under the License.
+ */
+package com.amazonaws.services.lambda.runtime.events.models.dynamodb;
+
+import java.io.Serializable;
+
+/**
+ * -
+ *
+ *
+ *KEYS_ONLY- only the key attributes of the modified item. + *
+ * -
+ *
+ *
+ *NEW_IMAGE- the entire item, as it appeared after it was modified. + *
+ * -
+ *
+ *
+ *OLD_IMAGE- the entire item, as it appeared before it was modified. + *
+ * -
+ *
+ *
+ *NEW_AND_OLD_IMAGES- both the new and the old item images of the item. + *
+ * -
+ *
+ *
+ *KEYS_ONLY- only the key attributes of the modified item. + *
+ * -
+ *
+ *
+ *NEW_IMAGE- the entire item, as it appeared after it was modified. + *
+ * -
+ *
+ *
+ *OLD_IMAGE- the entire item, as it appeared before it was modified. + *
+ * -
+ *
+ *
+ *NEW_AND_OLD_IMAGES- both the new and the old item images of the item. + *
+ * -
+ *
+ *
+ *KEYS_ONLY- only the key attributes of the modified item. + *
+ * -
+ *
+ *
+ *NEW_IMAGE- the entire item, as it appeared after it was modified. + *
+ * -
+ *
+ *
+ *OLD_IMAGE- the entire item, as it appeared before it was modified. + *
+ * -
+ *
+ *
+ *NEW_AND_OLD_IMAGES- both the new and the old item images of the item. + *
+ * @see StreamViewType
+ */
+ public String getStreamViewType() {
+ return this.streamViewType;
+ }
+
+ /**
+ * -
+ *
+ *
+ *KEYS_ONLY- only the key attributes of the modified item. + *
+ * -
+ *
+ *
+ *NEW_IMAGE- the entire item, as it appeared after it was modified. + *
+ * -
+ *
+ *
+ *OLD_IMAGE- the entire item, as it appeared before it was modified. + *
+ * -
+ *
+ *
+ *NEW_AND_OLD_IMAGES- both the new and the old item images of the item. + *
+ * -
+ *
+ *
+ *KEYS_ONLY- only the key attributes of the modified item. + *
+ * -
+ *
+ *
+ *NEW_IMAGE- the entire item, as it appeared after it was modified. + *
+ * -
+ *
+ *
+ *OLD_IMAGE- the entire item, as it appeared before it was modified. + *
+ * -
+ *
+ *
+ *NEW_AND_OLD_IMAGES- both the new and the old item images of the item. + *
+ * @see StreamViewType
+ */
+ public void setStreamViewType(StreamViewType streamViewType) {
+ withStreamViewType(streamViewType);
+ }
+
+ /**
+ * -
+ *
+ *
+ *KEYS_ONLY- only the key attributes of the modified item. + *
+ * -
+ *
+ *
+ *NEW_IMAGE- the entire item, as it appeared after it was modified. + *
+ * -
+ *
+ *
+ *OLD_IMAGE- the entire item, as it appeared before it was modified. + *
+ * -
+ *
+ *
+ *NEW_AND_OLD_IMAGES- both the new and the old item images of the item. + *
+ * -
+ *
+ *
+ *KEYS_ONLY- only the key attributes of the modified item. + *
+ * -
+ *
+ *
+ *NEW_IMAGE- the entire item, as it appeared after it was modified. + *
+ * -
+ *
+ *
+ *OLD_IMAGE- the entire item, as it appeared before it was modified. + *
+ * -
+ *
+ *
+ *NEW_AND_OLD_IMAGES- both the new and the old item images of the item. + *
+ * @return Returns a reference to this object so that method calls can be chained together.
+ * @see StreamViewType
+ */
+ public StreamRecord withStreamViewType(StreamViewType streamViewType) {
+ this.streamViewType = streamViewType.toString();
+ return this;
+ }
+
+ /**
+ * Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be
+ * redacted from this string using a placeholder value.
+ *
+ * @return A string representation of this object.
+ *
+ * @see Object#toString()
+ */
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("{");
+ if (getApproximateCreationDateTime() != null)
+ sb.append("ApproximateCreationDateTime: ").append(getApproximateCreationDateTime()).append(",");
+ if (getKeys() != null)
+ sb.append("Keys: ").append(getKeys()).append(",");
+ if (getNewImage() != null)
+ sb.append("NewImage: ").append(getNewImage()).append(",");
+ if (getOldImage() != null)
+ sb.append("OldImage: ").append(getOldImage()).append(",");
+ if (getSequenceNumber() != null)
+ sb.append("SequenceNumber: ").append(getSequenceNumber()).append(",");
+ if (getSizeBytes() != null)
+ sb.append("SizeBytes: ").append(getSizeBytes()).append(",");
+ if (getStreamViewType() != null)
+ sb.append("StreamViewType: ").append(getStreamViewType());
+ sb.append("}");
+ return sb.toString();
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ if (this == obj)
+ return true;
+ if (obj == null)
+ return false;
+
+ if (obj instanceof StreamRecord == false)
+ return false;
+ StreamRecord other = (StreamRecord) obj;
+ if (other.getApproximateCreationDateTime() == null ^ this.getApproximateCreationDateTime() == null)
+ return false;
+ if (other.getApproximateCreationDateTime() != null && other.getApproximateCreationDateTime().equals(this.getApproximateCreationDateTime()) == false)
+ return false;
+ if (other.getKeys() == null ^ this.getKeys() == null)
+ return false;
+ if (other.getKeys() != null && other.getKeys().equals(this.getKeys()) == false)
+ return false;
+ if (other.getNewImage() == null ^ this.getNewImage() == null)
+ return false;
+ if (other.getNewImage() != null && other.getNewImage().equals(this.getNewImage()) == false)
+ return false;
+ if (other.getOldImage() == null ^ this.getOldImage() == null)
+ return false;
+ if (other.getOldImage() != null && other.getOldImage().equals(this.getOldImage()) == false)
+ return false;
+ if (other.getSequenceNumber() == null ^ this.getSequenceNumber() == null)
+ return false;
+ if (other.getSequenceNumber() != null && other.getSequenceNumber().equals(this.getSequenceNumber()) == false)
+ return false;
+ if (other.getSizeBytes() == null ^ this.getSizeBytes() == null)
+ return false;
+ if (other.getSizeBytes() != null && other.getSizeBytes().equals(this.getSizeBytes()) == false)
+ return false;
+ if (other.getStreamViewType() == null ^ this.getStreamViewType() == null)
+ return false;
+ if (other.getStreamViewType() != null && other.getStreamViewType().equals(this.getStreamViewType()) == false)
+ return false;
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ final int prime = 31;
+ int hashCode = 1;
+
+ hashCode = prime * hashCode + ((getApproximateCreationDateTime() == null) ? 0 : getApproximateCreationDateTime().hashCode());
+ hashCode = prime * hashCode + ((getKeys() == null) ? 0 : getKeys().hashCode());
+ hashCode = prime * hashCode + ((getNewImage() == null) ? 0 : getNewImage().hashCode());
+ hashCode = prime * hashCode + ((getOldImage() == null) ? 0 : getOldImage().hashCode());
+ hashCode = prime * hashCode + ((getSequenceNumber() == null) ? 0 : getSequenceNumber().hashCode());
+ hashCode = prime * hashCode + ((getSizeBytes() == null) ? 0 : getSizeBytes().hashCode());
+ hashCode = prime * hashCode + ((getStreamViewType() == null) ? 0 : getStreamViewType().hashCode());
+ return hashCode;
+ }
+
+ @Override
+ public StreamRecord clone() {
+ try {
+ return (StreamRecord) super.clone();
+ } catch (CloneNotSupportedException e) {
+ throw new IllegalStateException("Got a CloneNotSupportedException from Object.clone() " + "even though we're Cloneable!", e);
+ }
+ }
+
+}
\ No newline at end of file
diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/StreamViewType.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/StreamViewType.java
new file mode 100644
index 000000000..93cdbc8fc
--- /dev/null
+++ b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/dynamodb/StreamViewType.java
@@ -0,0 +1,59 @@
+/*
+ * Copyright 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with
+ * the License. A copy of the License is located at
+ *
+ * http://aws.amazon.com/apache2.0
+ *
+ * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions
+ * and limitations under the License.
+ */
+package com.amazonaws.services.lambda.runtime.events.models.dynamodb;
+
+public enum StreamViewType {
+
+ NEW_IMAGE("NEW_IMAGE"),
+ OLD_IMAGE("OLD_IMAGE"),
+ NEW_AND_OLD_IMAGES("NEW_AND_OLD_IMAGES"),
+ KEYS_ONLY("KEYS_ONLY");
+
+ private String value;
+
+ StreamViewType(String value) {
+ this.value = value;
+ }
+
+ public String getValue() {
+ return value;
+ }
+
+ @Override
+ public String toString() {
+ return this.value;
+ }
+
+ /**
+ * Use this in place of valueOf.
+ *
+ * @param value real value
+ * @return StreamViewType corresponding to the value
+ *
+ * @throws IllegalArgumentException
+ * If the specified value does not map to one of the known values in this enum.
+ */
+ public static StreamViewType fromValue(String value) {
+ if (value == null || "".equals(value)) {
+ throw new IllegalArgumentException("Value cannot be null or empty!");
+ }
+
+ for (StreamViewType enumEntry : StreamViewType.values()) {
+ if (enumEntry.toString().equals(value)) {
+ return enumEntry;
+ }
+ }
+
+ throw new IllegalArgumentException("Cannot create enum from " + value + " value!");
+ }
+}
\ No newline at end of file
diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/kinesis/EncryptionType.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/kinesis/EncryptionType.java
new file mode 100644
index 000000000..8ffb3e149
--- /dev/null
+++ b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/kinesis/EncryptionType.java
@@ -0,0 +1,54 @@
+/*
+ * Copyright 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with
+ * the License. A copy of the License is located at
+ *
+ * http://aws.amazon.com/apache2.0
+ *
+ * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions
+ * and limitations under the License.
+ */
+package com.amazonaws.services.lambda.runtime.events.models.kinesis;
+
+public enum EncryptionType {
+
+ NONE("NONE"),
+ KMS("KMS");
+
+ private String value;
+
+ private EncryptionType(String value) {
+ this.value = value;
+ }
+
+ @Override
+ public String toString() {
+ return this.value;
+ }
+
+ /**
+ * Use this in place of valueOf.
+ *
+ * @param value
+ * real value
+ * @return EncryptionType corresponding to the value
+ *
+ * @throws IllegalArgumentException
+ * If the specified value does not map to one of the known values in this enum.
+ */
+ public static EncryptionType fromValue(String value) {
+ if (value == null || "".equals(value)) {
+ throw new IllegalArgumentException("Value cannot be null or empty!");
+ }
+
+ for (EncryptionType enumEntry : EncryptionType.values()) {
+ if (enumEntry.toString().equals(value)) {
+ return enumEntry;
+ }
+ }
+
+ throw new IllegalArgumentException("Cannot create enum from " + value + " value!");
+ }
+}
\ No newline at end of file
diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/kinesis/Record.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/kinesis/Record.java
new file mode 100644
index 000000000..085fe8e5a
--- /dev/null
+++ b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/kinesis/Record.java
@@ -0,0 +1,494 @@
+/*
+ * Copyright 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with
+ * the License. A copy of the License is located at
+ *
+ * http://aws.amazon.com/apache2.0
+ *
+ * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions
+ * and limitations under the License.
+ */
+package com.amazonaws.services.lambda.runtime.events.models.kinesis;
+
+import java.io.Serializable;
+
+/**
+ * -
+ *
+ *
+ *NONE: Do not encrypt the records in the stream. + *
+ * -
+ *
+ *
+ *KMS: Use server-side encryption on the records in the stream using a customer-managed AWS KMS key. + *
+ * -
+ *
+ *
+ *NONE: Do not encrypt the records in the stream. + *
+ * -
+ *
+ *
+ *KMS: Use server-side encryption on the records in the stream using a customer-managed AWS KMS key. + *
+ * -
+ *
+ *
+ *NONE: Do not encrypt the records in the stream. + *
+ * -
+ *
+ *
+ *KMS: Use server-side encryption on the records in the stream using a customer-managed AWS KMS + * key. + *
+ * @see EncryptionType
+ */
+ public void setEncryptionType(String encryptionType) {
+ this.encryptionType = encryptionType;
+ }
+
+ /**
+ * -
+ *
+ *
+ *NONE: Do not encrypt the records in the stream. + *
+ * -
+ *
+ *
+ *KMS: Use server-side encryption on the records in the stream using a customer-managed AWS KMS key. + *
+ * -
+ *
+ *
+ *NONE: Do not encrypt the records in the stream. + *
+ * -
+ *
+ *
+ *KMS: Use server-side encryption on the records in the stream using a customer-managed AWS + * KMS key. + *
+ * @see EncryptionType
+ */
+ public String getEncryptionType() {
+ return this.encryptionType;
+ }
+
+ /**
+ * -
+ *
+ *
+ *NONE: Do not encrypt the records in the stream. + *
+ * -
+ *
+ *
+ *KMS: Use server-side encryption on the records in the stream using a customer-managed AWS KMS key. + *
+ * -
+ *
+ *
+ *NONE: Do not encrypt the records in the stream. + *
+ * -
+ *
+ *
+ *KMS: Use server-side encryption on the records in the stream using a customer-managed AWS KMS + * key. + *
+ * @return Returns a reference to this object so that method calls can be chained together.
+ * @see EncryptionType
+ */
+ public Record withEncryptionType(String encryptionType) {
+ setEncryptionType(encryptionType);
+ return this;
+ }
+
+ /**
+ * -
+ *
+ *
+ *NONE: Do not encrypt the records in the stream. + *
+ * -
+ *
+ *
+ *KMS: Use server-side encryption on the records in the stream using a customer-managed AWS KMS key. + *
+ * -
+ *
+ *
+ *NONE: Do not encrypt the records in the stream. + *
+ * -
+ *
+ *
+ *KMS: Use server-side encryption on the records in the stream using a customer-managed AWS KMS + * key. + *
+ * @return Returns a reference to this object so that method calls can be chained together.
+ * @see EncryptionType
+ */
+ public Record withEncryptionType(EncryptionType encryptionType) {
+ this.encryptionType = encryptionType.toString();
+ return this;
+ }
+
+ /**
+ * Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be
+ * redacted from this string using a placeholder value.
+ *
+ * @return A string representation of this object.
+ *
+ * @see Object#toString()
+ */
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("{");
+ if (getSequenceNumber() != null)
+ sb.append("SequenceNumber: ").append(getSequenceNumber()).append(",");
+ if (getApproximateArrivalTimestamp() != null)
+ sb.append("ApproximateArrivalTimestamp: ").append(getApproximateArrivalTimestamp()).append(",");
+ if (getData() != null)
+ sb.append("Data: ").append(getData()).append(",");
+ if (getPartitionKey() != null)
+ sb.append("PartitionKey: ").append(getPartitionKey()).append(",");
+ if (getEncryptionType() != null)
+ sb.append("EncryptionType: ").append(getEncryptionType());
+ sb.append("}");
+ return sb.toString();
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ if (this == obj)
+ return true;
+ if (obj == null)
+ return false;
+
+ if (obj instanceof Record == false)
+ return false;
+ Record other = (Record) obj;
+ if (other.getSequenceNumber() == null ^ this.getSequenceNumber() == null)
+ return false;
+ if (other.getSequenceNumber() != null && other.getSequenceNumber().equals(this.getSequenceNumber()) == false)
+ return false;
+ if (other.getApproximateArrivalTimestamp() == null ^ this.getApproximateArrivalTimestamp() == null)
+ return false;
+ if (other.getApproximateArrivalTimestamp() != null && other.getApproximateArrivalTimestamp().equals(this.getApproximateArrivalTimestamp()) == false)
+ return false;
+ if (other.getData() == null ^ this.getData() == null)
+ return false;
+ if (other.getData() != null && other.getData().equals(this.getData()) == false)
+ return false;
+ if (other.getPartitionKey() == null ^ this.getPartitionKey() == null)
+ return false;
+ if (other.getPartitionKey() != null && other.getPartitionKey().equals(this.getPartitionKey()) == false)
+ return false;
+ if (other.getEncryptionType() == null ^ this.getEncryptionType() == null)
+ return false;
+ if (other.getEncryptionType() != null && other.getEncryptionType().equals(this.getEncryptionType()) == false)
+ return false;
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ final int prime = 31;
+ int hashCode = 1;
+
+ hashCode = prime * hashCode + ((getSequenceNumber() == null) ? 0 : getSequenceNumber().hashCode());
+ hashCode = prime * hashCode + ((getApproximateArrivalTimestamp() == null) ? 0 : getApproximateArrivalTimestamp().hashCode());
+ hashCode = prime * hashCode + ((getData() == null) ? 0 : getData().hashCode());
+ hashCode = prime * hashCode + ((getPartitionKey() == null) ? 0 : getPartitionKey().hashCode());
+ hashCode = prime * hashCode + ((getEncryptionType() == null) ? 0 : getEncryptionType().hashCode());
+ return hashCode;
+ }
+
+ @Override
+ public Record clone() {
+ try {
+ return (Record) super.clone();
+ } catch (CloneNotSupportedException e) {
+ throw new IllegalStateException("Got a CloneNotSupportedException from Object.clone() " + "even though we're Cloneable!", e);
+ }
+ }
+}
\ No newline at end of file
diff --git a/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/s3/S3EventNotification.java b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/s3/S3EventNotification.java
new file mode 100644
index 000000000..5df14ea2a
--- /dev/null
+++ b/aws-lambda-java-events/src/main/java/com/amazonaws/services/lambda/runtime/events/models/s3/S3EventNotification.java
@@ -0,0 +1,310 @@
+/*
+ * Copyright 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with
+ * the License. A copy of the License is located at
+ *
+ * http://aws.amazon.com/apache2.0
+ *
+ * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions
+ * and limitations under the License.
+ */
+package com.amazonaws.services.lambda.runtime.events.models.s3;
+
+import org.joda.time.DateTime;
+
+import java.io.UnsupportedEncodingException;
+import java.net.URLDecoder;
+import java.util.List;
+
+/**
+* A helper class that represents a strongly typed S3 EventNotification item sent
+* to SQS, SNS, or Lambda.
+*/
+public class S3EventNotification {
+
+ private final List
+ * The type of data modification that was performed on the DynamoDB table: + *
+ *-
+ *
-
+ *
+ * The type of data modification that was performed on the DynamoDB table: + *
+ *-
+ *
-
+ *
+ * The type of data modification that was performed on the DynamoDB table: + *
+ *-
+ *
-
+ *
+ * The type of data modification that was performed on the DynamoDB table: + *
+ *-
+ *
-
+ *
+ * The version number of the stream record format. This number is updated whenever the structure of
+ * Record is modified.
+ *
+ * Client applications must not assume that eventVersion will remain at a particular value, as this
+ * number is subject to change at any time. In general, eventVersion will only increase as the
+ * low-level DynamoDB Streams API evolves.
+ *
Record is modified.
+ *
+ * Client applications must not assume that eventVersion will remain at a particular value, as
+ * this number is subject to change at any time. In general, eventVersion will only increase as
+ * the low-level DynamoDB Streams API evolves.
+ */
+ public void setEventVersion(String eventVersion) {
+ this.eventVersion = eventVersion;
+ }
+
+ /**
+ *
+ * The version number of the stream record format. This number is updated whenever the structure of
+ * Record is modified.
+ *
+ * Client applications must not assume that eventVersion will remain at a particular value, as this
+ * number is subject to change at any time. In general, eventVersion will only increase as the
+ * low-level DynamoDB Streams API evolves.
+ *
Record is modified.
+ *
+ * Client applications must not assume that eventVersion will remain at a particular value, as
+ * this number is subject to change at any time. In general, eventVersion will only increase as
+ * the low-level DynamoDB Streams API evolves.
+ */
+ public String getEventVersion() {
+ return this.eventVersion;
+ }
+
+ /**
+ *
+ * The version number of the stream record format. This number is updated whenever the structure of
+ * Record is modified.
+ *
+ * Client applications must not assume that eventVersion will remain at a particular value, as this
+ * number is subject to change at any time. In general, eventVersion will only increase as the
+ * low-level DynamoDB Streams API evolves.
+ *
Record is modified.
+ *
+ * Client applications must not assume that eventVersion will remain at a particular value, as
+ * this number is subject to change at any time. In general, eventVersion will only increase as
+ * the low-level DynamoDB Streams API evolves.
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+ public Record withEventVersion(String eventVersion) {
+ setEventVersion(eventVersion);
+ return this;
+ }
+
+ /**
+ *
+ * The AWS service from which the stream record originated. For DynamoDB Streams, this is aws:dynamodb.
+ *
aws:dynamodb.
+ */
+ public void setEventSource(String eventSource) {
+ this.eventSource = eventSource;
+ }
+
+ /**
+ *
+ * The AWS service from which the stream record originated. For DynamoDB Streams, this is aws:dynamodb.
+ *
aws:dynamodb.
+ */
+ public String getEventSource() {
+ return this.eventSource;
+ }
+
+ /**
+ *
+ * The AWS service from which the stream record originated. For DynamoDB Streams, this is aws:dynamodb.
+ *
aws:dynamodb.
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+ public Record withEventSource(String eventSource) {
+ setEventSource(eventSource);
+ return this;
+ }
+
+ /**
+ *
+ * The region in which the GetRecords request was received.
+ *
GetRecords request was received.
+ */
+ public void setAwsRegion(String awsRegion) {
+ this.awsRegion = awsRegion;
+ }
+
+ /**
+ *
+ * The region in which the GetRecords request was received.
+ *
GetRecords request was received.
+ */
+ public String getAwsRegion() {
+ return this.awsRegion;
+ }
+
+ /**
+ *
+ * The region in which the GetRecords request was received.
+ *
GetRecords request was received.
+ * @return Returns a reference to this object so that method calls can be chained together.
+ */
+ public Record withAwsRegion(String awsRegion) {
+ setAwsRegion(awsRegion);
+ return this;
+ }
+
+ /**
+ * + * The main body of the stream record, containing all of the DynamoDB-specific fields. + *
+ * + * @param dynamodb + * The main body of the stream record, containing all of the DynamoDB-specific fields. + */ + public void setDynamodb(StreamRecord dynamodb) { + this.dynamodb = dynamodb; + } + + /** + *+ * The main body of the stream record, containing all of the DynamoDB-specific fields. + *
+ * + * @return The main body of the stream record, containing all of the DynamoDB-specific fields. + */ + public StreamRecord getDynamodb() { + return this.dynamodb; + } + + /** + *+ * The main body of the stream record, containing all of the DynamoDB-specific fields. + *
+ * + * @param dynamodb + * The main body of the stream record, containing all of the DynamoDB-specific fields. + * @return Returns a reference to this object so that method calls can be chained together. + */ + public Record withDynamodb(StreamRecord dynamodb) { + setDynamodb(dynamodb); + return this; + } + + /** + *+ * Items that are deleted by the Time to Live process after expiration have the following fields: + *
+ *-
+ *
-
+ *
+ * Items that are deleted by the Time to Live process after expiration have the following fields: + *
+ *-
+ *
-
+ *
+ * Items that are deleted by the Time to Live process after expiration have the following fields: + *
+ *-
+ *
-
+ *
+ * A description of a single data modification that was performed on an item in a DynamoDB table. + *
+ * + * @see AWS API + * Documentation + */ +public class StreamRecord implements Serializable, Cloneable { + + /** + *+ * The approximate date and time when the stream record was created, in UNIX epoch time format. + *
+ */ + private java.util.Date approximateCreationDateTime; + /** + *+ * The primary key attribute(s) for the DynamoDB item that was modified. + *
+ */ + private java.util.Map+ * The item in the DynamoDB table as it appeared after it was modified. + *
+ */ + private java.util.Map+ * The item in the DynamoDB table as it appeared before it was modified. + *
+ */ + private java.util.Map+ * The sequence number of the stream record. + *
+ */ + private String sequenceNumber; + /** + *+ * The size of the stream record, in bytes. + *
+ */ + private Long sizeBytes; + /** + *+ * The type of data from the modified DynamoDB item that was captured in this stream record: + *
+ *-
+ *
+ * The approximate date and time when the stream record was created, in UNIX epoch time format. + *
+ * + * @param approximateCreationDateTime + * The approximate date and time when the stream record was created, in UNIX epoch time format. + */ + public void setApproximateCreationDateTime(java.util.Date approximateCreationDateTime) { + this.approximateCreationDateTime = approximateCreationDateTime; + } + + /** + *+ * The approximate date and time when the stream record was created, in UNIX epoch time format. + *
+ * + * @return The approximate date and time when the stream record was created, in UNIX epoch time format. + */ + public java.util.Date getApproximateCreationDateTime() { + return this.approximateCreationDateTime; + } + + /** + *+ * The approximate date and time when the stream record was created, in UNIX epoch time format. + *
+ * + * @param approximateCreationDateTime + * The approximate date and time when the stream record was created, in UNIX epoch time format. + * @return Returns a reference to this object so that method calls can be chained together. + */ + public StreamRecord withApproximateCreationDateTime(java.util.Date approximateCreationDateTime) { + setApproximateCreationDateTime(approximateCreationDateTime); + return this; + } + + /** + *+ * The primary key attribute(s) for the DynamoDB item that was modified. + *
+ * + * @return The primary key attribute(s) for the DynamoDB item that was modified. + */ + public java.util.Map+ * The primary key attribute(s) for the DynamoDB item that was modified. + *
+ * + * @param keys + * The primary key attribute(s) for the DynamoDB item that was modified. + */ + public void setKeys(java.util.Map+ * The primary key attribute(s) for the DynamoDB item that was modified. + *
+ * + * @param keys + * The primary key attribute(s) for the DynamoDB item that was modified. + * @return Returns a reference to this object so that method calls can be chained together. + */ + public StreamRecord withKeys(java.util.Map+ * The item in the DynamoDB table as it appeared after it was modified. + *
+ * + * @return The item in the DynamoDB table as it appeared after it was modified. + */ + public java.util.Map+ * The item in the DynamoDB table as it appeared after it was modified. + *
+ * + * @param newImage + * The item in the DynamoDB table as it appeared after it was modified. + */ + public void setNewImage(java.util.Map+ * The item in the DynamoDB table as it appeared after it was modified. + *
+ * + * @param newImage + * The item in the DynamoDB table as it appeared after it was modified. + * @return Returns a reference to this object so that method calls can be chained together. + */ + public StreamRecord withNewImage(java.util.Map+ * The item in the DynamoDB table as it appeared before it was modified. + *
+ * + * @return The item in the DynamoDB table as it appeared before it was modified. + */ + public java.util.Map+ * The item in the DynamoDB table as it appeared before it was modified. + *
+ * + * @param oldImage + * The item in the DynamoDB table as it appeared before it was modified. + */ + public void setOldImage(java.util.Map+ * The item in the DynamoDB table as it appeared before it was modified. + *
+ * + * @param oldImage + * The item in the DynamoDB table as it appeared before it was modified. + * @return Returns a reference to this object so that method calls can be chained together. + */ + public StreamRecord withOldImage(java.util.Map+ * The sequence number of the stream record. + *
+ * + * @param sequenceNumber + * The sequence number of the stream record. + */ + public void setSequenceNumber(String sequenceNumber) { + this.sequenceNumber = sequenceNumber; + } + + /** + *+ * The sequence number of the stream record. + *
+ * + * @return The sequence number of the stream record. + */ + public String getSequenceNumber() { + return this.sequenceNumber; + } + + /** + *+ * The sequence number of the stream record. + *
+ * + * @param sequenceNumber + * The sequence number of the stream record. + * @return Returns a reference to this object so that method calls can be chained together. + */ + public StreamRecord withSequenceNumber(String sequenceNumber) { + setSequenceNumber(sequenceNumber); + return this; + } + + /** + *+ * The size of the stream record, in bytes. + *
+ * + * @param sizeBytes + * The size of the stream record, in bytes. + */ + public void setSizeBytes(Long sizeBytes) { + this.sizeBytes = sizeBytes; + } + + /** + *+ * The size of the stream record, in bytes. + *
+ * + * @return The size of the stream record, in bytes. + */ + public Long getSizeBytes() { + return this.sizeBytes; + } + + /** + *+ * The size of the stream record, in bytes. + *
+ * + * @param sizeBytes + * The size of the stream record, in bytes. + * @return Returns a reference to this object so that method calls can be chained together. + */ + public StreamRecord withSizeBytes(Long sizeBytes) { + setSizeBytes(sizeBytes); + return this; + } + + /** + *+ * The type of data from the modified DynamoDB item that was captured in this stream record: + *
+ *-
+ *
-
+ *
+ * The type of data from the modified DynamoDB item that was captured in this stream record: + *
+ *-
+ *
-
+ *
+ * The type of data from the modified DynamoDB item that was captured in this stream record: + *
+ *-
+ *
-
+ *
+ * The unit of data of the Kinesis data stream, which is composed of a sequence number, a partition key, and a data + * blob. + *
+ * + * @see AWS API + * Documentation + */ +public class Record implements Serializable, Cloneable { + + /** + *+ * The unique identifier of the record within its shard. + *
+ */ + private String sequenceNumber; + /** + *+ * The approximate time that the record was inserted into the stream. + *
+ */ + private java.util.Date approximateArrivalTimestamp; + /** + *+ * The data blob. The data in the blob is both opaque and immutable to Kinesis Data Streams, which does not inspect, + * interpret, or change the data in the blob in any way. When the data blob (the payload before base64-encoding) is + * added to the partition key size, the total size must not exceed the maximum record size (1 MB). + *
+ */ + private java.nio.ByteBuffer data; + /** + *+ * Identifies which shard in the stream the data record is assigned to. + *
+ */ + private String partitionKey; + /** + *+ * The encryption type used on the record. This parameter can be one of the following values: + *
+ *-
+ *
+ * The unique identifier of the record within its shard. + *
+ * + * @param sequenceNumber + * The unique identifier of the record within its shard. + */ + public void setSequenceNumber(String sequenceNumber) { + this.sequenceNumber = sequenceNumber; + } + + /** + *+ * The unique identifier of the record within its shard. + *
+ * + * @return The unique identifier of the record within its shard. + */ + public String getSequenceNumber() { + return this.sequenceNumber; + } + + /** + *+ * The unique identifier of the record within its shard. + *
+ * + * @param sequenceNumber + * The unique identifier of the record within its shard. + * @return Returns a reference to this object so that method calls can be chained together. + */ + public Record withSequenceNumber(String sequenceNumber) { + setSequenceNumber(sequenceNumber); + return this; + } + + /** + *+ * The approximate time that the record was inserted into the stream. + *
+ * + * @param approximateArrivalTimestamp + * The approximate time that the record was inserted into the stream. + */ + public void setApproximateArrivalTimestamp(java.util.Date approximateArrivalTimestamp) { + this.approximateArrivalTimestamp = approximateArrivalTimestamp; + } + + /** + *+ * The approximate time that the record was inserted into the stream. + *
+ * + * @return The approximate time that the record was inserted into the stream. + */ + public java.util.Date getApproximateArrivalTimestamp() { + return this.approximateArrivalTimestamp; + } + + /** + *+ * The approximate time that the record was inserted into the stream. + *
+ * + * @param approximateArrivalTimestamp + * The approximate time that the record was inserted into the stream. + * @return Returns a reference to this object so that method calls can be chained together. + */ + public Record withApproximateArrivalTimestamp(java.util.Date approximateArrivalTimestamp) { + setApproximateArrivalTimestamp(approximateArrivalTimestamp); + return this; + } + + /** + *+ * The data blob. The data in the blob is both opaque and immutable to Kinesis Data Streams, which does not inspect, + * interpret, or change the data in the blob in any way. When the data blob (the payload before base64-encoding) is + * added to the partition key size, the total size must not exceed the maximum record size (1 MB). + *
+ *+ * The AWS SDK for Java performs a Base64 encoding on this field before sending this request to the AWS service. + * Users of the SDK should not perform Base64 encoding on this field. + *
+ *+ * Warning: ByteBuffers returned by the SDK are mutable. Changes to the content or position of the byte buffer will + * be seen by all objects that have a reference to this object. It is recommended to call ByteBuffer.duplicate() or + * ByteBuffer.asReadOnlyBuffer() before using or reading from the buffer. This behavior will be changed in a future + * major version of the SDK. + *
+ * + * @param data + * The data blob. The data in the blob is both opaque and immutable to Kinesis Data Streams, which does not + * inspect, interpret, or change the data in the blob in any way. When the data blob (the payload before + * base64-encoding) is added to the partition key size, the total size must not exceed the maximum record + * size (1 MB). + */ + public void setData(java.nio.ByteBuffer data) { + this.data = data; + } + + /** + *+ * The data blob. The data in the blob is both opaque and immutable to Kinesis Data Streams, which does not inspect, + * interpret, or change the data in the blob in any way. When the data blob (the payload before base64-encoding) is + * added to the partition key size, the total size must not exceed the maximum record size (1 MB). + *
+ *+ * {@code ByteBuffer}s are stateful. Calling their {@code get} methods changes their {@code position}. We recommend + * using {@link java.nio.ByteBuffer#asReadOnlyBuffer()} to create a read-only view of the buffer with an independent + * {@code position}, and calling {@code get} methods on this rather than directly on the returned {@code ByteBuffer}. + * Doing so will ensure that anyone else using the {@code ByteBuffer} will not be affected by changes to the + * {@code position}. + *
+ * + * @return The data blob. The data in the blob is both opaque and immutable to Kinesis Data Streams, which does not + * inspect, interpret, or change the data in the blob in any way. When the data blob (the payload before + * base64-encoding) is added to the partition key size, the total size must not exceed the maximum record + * size (1 MB). + */ + public java.nio.ByteBuffer getData() { + return this.data; + } + + /** + *+ * The data blob. The data in the blob is both opaque and immutable to Kinesis Data Streams, which does not inspect, + * interpret, or change the data in the blob in any way. When the data blob (the payload before base64-encoding) is + * added to the partition key size, the total size must not exceed the maximum record size (1 MB). + *
+ *+ * The AWS SDK for Java performs a Base64 encoding on this field before sending this request to the AWS service. + * Users of the SDK should not perform Base64 encoding on this field. + *
+ *+ * Warning: ByteBuffers returned by the SDK are mutable. Changes to the content or position of the byte buffer will + * be seen by all objects that have a reference to this object. It is recommended to call ByteBuffer.duplicate() or + * ByteBuffer.asReadOnlyBuffer() before using or reading from the buffer. This behavior will be changed in a future + * major version of the SDK. + *
+ * + * @param data + * The data blob. The data in the blob is both opaque and immutable to Kinesis Data Streams, which does not + * inspect, interpret, or change the data in the blob in any way. When the data blob (the payload before + * base64-encoding) is added to the partition key size, the total size must not exceed the maximum record + * size (1 MB). + * @return Returns a reference to this object so that method calls can be chained together. + */ + public Record withData(java.nio.ByteBuffer data) { + setData(data); + return this; + } + + /** + *+ * Identifies which shard in the stream the data record is assigned to. + *
+ * + * @param partitionKey + * Identifies which shard in the stream the data record is assigned to. + */ + public void setPartitionKey(String partitionKey) { + this.partitionKey = partitionKey; + } + + /** + *+ * Identifies which shard in the stream the data record is assigned to. + *
+ * + * @return Identifies which shard in the stream the data record is assigned to. + */ + public String getPartitionKey() { + return this.partitionKey; + } + + /** + *+ * Identifies which shard in the stream the data record is assigned to. + *
+ * + * @param partitionKey + * Identifies which shard in the stream the data record is assigned to. + * @return Returns a reference to this object so that method calls can be chained together. + */ + public Record withPartitionKey(String partitionKey) { + setPartitionKey(partitionKey); + return this; + } + + /** + *+ * The encryption type used on the record. This parameter can be one of the following values: + *
+ *-
+ *
-
+ *
+ * The encryption type used on the record. This parameter can be one of the following values: + *
+ *-
+ *
-
+ *
+ * The encryption type used on the record. This parameter can be one of the following values: + *
+ *-
+ *
-
+ *
+ * The encryption type used on the record. This parameter can be one of the following values: + *
+ *-
+ *
-
+ *
+ * 1. loads the user's handler.
+ *
+ * 2. enters the Lambda runtime loop which handles function invocations as defined in the Lambda Custom Runtime API.
+ *
+ *
+ * Once initialized, {@link AWSLambda#startRuntime} will halt only if an irrecoverable error occurs.
+ */
+public class AWSLambda {
+
+ private static URLClassLoader customerClassLoader;
+
+ private static final String TRUST_STORE_PROPERTY = "javax.net.ssl.trustStore";
+
+ private static final String JAVA_SECURITY_PROPERTIES = "java.security.properties";
+
+ private static final String NETWORKADDRESS_CACHE_NEGATIVE_TTL_ENV_VAR = "AWS_LAMBDA_JAVA_NETWORKADDRESS_CACHE_NEGATIVE_TTL";
+
+ private static final String NETWORKADDRESS_CACHE_NEGATIVE_TTL_PROPERTY = "networkaddress.cache.negative.ttl";
+
+ private static final String DEFAULT_NEGATIVE_CACHE_TTL = "1";
+
+ // System property for Lambda tracing, see aws-xray-sdk-java/LambdaSegmentContext
+ // https://github.com/aws/aws-xray-sdk-java/blob/2f467e50db61abb2ed2bd630efc21bddeabd64d9/aws-xray-recorder-sdk-core/src/main/java/com/amazonaws/xray/contexts/LambdaSegmentContext.java#L39-L40
+ private static final String LAMBDA_TRACE_HEADER_PROP = "com.amazonaws.xray.traceHeader";
+
+ private static final String INIT_TYPE_SNAP_START = "snap-start";
+
+ private static final String AWS_LAMBDA_INITIALIZATION_TYPE = System.getenv(ReservedRuntimeEnvironmentVariables.AWS_LAMBDA_INITIALIZATION_TYPE);
+
+ private static final String CONCURRENT_TRACE_ID_KEY = "AWS_LAMBDA_X_TRACE_ID";
+
+ static {
+ // Override the disabledAlgorithms setting to match configuration for openjdk8-u181.
+ // This is to keep DES ciphers around while we deploying security updates.
+ Security.setProperty(
+ "jdk.tls.disabledAlgorithms",
+ "SSLv3, RC4, MD5withRSA, DH keySize < 1024, EC keySize < 224, DES40_CBC, RC4_40, 3DES_EDE_CBC"
+ );
+ // Override the location of the trusted certificate authorities to be provided by the system.
+ // The ca-certificates package provides /etc/pki/java/cacerts which becomes the symlink destination
+ // of $java_home/lib/security/cacerts when java is installed in the chroot. Given that java is provided
+ // in /var/lang as opposed to installed in the chroot, this brings it closer.
+ if (System.getProperty(TRUST_STORE_PROPERTY) == null) {
+ final File systemCacerts = new File("/etc/pki/java/cacerts");
+ if (systemCacerts.exists() && systemCacerts.isFile()) {
+ System.setProperty(TRUST_STORE_PROPERTY, systemCacerts.getPath());
+ }
+ }
+
+ if (isNegativeCacheOverridable()) {
+ String ttlFromEnv = System.getenv(NETWORKADDRESS_CACHE_NEGATIVE_TTL_ENV_VAR);
+ String negativeCacheTtl = ttlFromEnv == null ? DEFAULT_NEGATIVE_CACHE_TTL : ttlFromEnv;
+ Security.setProperty(NETWORKADDRESS_CACHE_NEGATIVE_TTL_PROPERTY, negativeCacheTtl);
+ }
+ }
+
+ private static boolean isNegativeCacheOverridable() {
+ String securityPropertiesPath = System.getProperty(JAVA_SECURITY_PROPERTIES);
+ if (securityPropertiesPath == null) {
+ return true;
+ }
+ try (FileInputStream inputStream = new FileInputStream(securityPropertiesPath)) {
+ Properties secProps = new Properties();
+ secProps.load(inputStream);
+ return !secProps.containsKey(NETWORKADDRESS_CACHE_NEGATIVE_TTL_PROPERTY);
+ } catch (IOException e) {
+ return true;
+ }
+ }
+
+ private static LambdaRequestHandler findRequestHandler(final String handlerString, ClassLoader customerClassLoader) {
+ final HandlerInfo handlerInfo;
+ try {
+ handlerInfo = HandlerInfo.fromString(handlerString, customerClassLoader);
+ } catch (HandlerInfo.InvalidHandlerException e) {
+ UserFault userFault = UserFault.makeUserFault("Invalid handler: `" + handlerString + "'");
+ return new UserFaultHandler(userFault);
+ } catch (ClassNotFoundException e) {
+ return LambdaRequestHandler.classNotFound(e, HandlerInfo.className(handlerString));
+ } catch (NoClassDefFoundError e) {
+ return LambdaRequestHandler.initErrorHandler(e, HandlerInfo.className(handlerString));
+ } catch (Throwable t) {
+ throw UserFault.makeInitErrorUserFault(t, HandlerInfo.className(handlerString));
+ }
+
+ final LambdaRequestHandler requestHandler = EventHandlerLoader.loadEventHandler(handlerInfo);
+ // if loading the handler failed and the failure is fatal (for e.g. the constructor threw an exception)
+ // we want to report this as an init error rather than deferring to the first invoke.
+ if (requestHandler instanceof UserFaultHandler) {
+ UserFault userFault = ((UserFaultHandler) requestHandler).fault;
+ if (userFault.fatal) {
+ throw userFault;
+ }
+ }
+ return requestHandler;
+ }
+
+ private static LambdaRequestHandler getLambdaRequestHandlerObject(String handler, LambdaContextLogger lambdaLogger, LambdaRuntimeApiClient runtimeClient) throws ClassNotFoundException, IOException {
+ UnsafeUtil.disableIllegalAccessWarning();
+
+ System.setOut(new PrintStream(new LambdaOutputStream(System.out), false, "UTF-8"));
+ System.setErr(new PrintStream(new LambdaOutputStream(System.err), false, "UTF-8"));
+ setupRuntimeLogger(lambdaLogger);
+
+ String taskRoot = System.getProperty("user.dir");
+ String libRoot = "/opt/java";
+ // Make system classloader the customer classloader's parent to ensure any aws-lambda-java-core classes
+ // are loaded from the system classloader.
+ customerClassLoader = new CustomerClassLoader(taskRoot, libRoot, ClassLoader.getSystemClassLoader());
+ Thread.currentThread().setContextClassLoader(customerClassLoader);
+
+ // Load the user's handler
+ LambdaRequestHandler requestHandler = null;
+ try {
+ requestHandler = findRequestHandler(handler, customerClassLoader);
+ } catch (UserFault userFault) {
+ lambdaLogger.log(userFault.reportableError(), lambdaLogger.getLogFormat() == LogFormat.JSON ? LogLevel.ERROR : LogLevel.UNDEFINED);
+ LambdaError error = new LambdaError(
+ LambdaErrorConverter.fromUserFault(userFault),
+ RapidErrorType.BadFunctionCode);
+ runtimeClient.reportInitError(error);
+ System.exit(1);
+ }
+
+ if (INIT_TYPE_SNAP_START.equals(AWS_LAMBDA_INITIALIZATION_TYPE)) {
+ onInitComplete(lambdaLogger, runtimeClient);
+ }
+
+ return requestHandler;
+ }
+
+ private static void setupRuntimeLogger(LambdaLogger lambdaLogger)
+ throws ClassNotFoundException {
+ ReflectUtil.setStaticField(
+ Class.forName("com.amazonaws.services.lambda.runtime.LambdaRuntime"),
+ "logger",
+ true,
+ lambdaLogger
+ );
+ }
+
+ /**
+ * convert an integer into a FileDescriptor object using reflection to access private members.
+ */
+ private static FileDescriptor intToFd(int fd) throws RuntimeException {
+ try {
+ Class
+ * It is used to generate a class list and Application CDS archive that includes all the possible classes that could be
+ * loaded by the runtime. This simplifies the process of generating the Application CDS archive.
+ */
+public class ClasspathLoader {
+
+ private static final Set