Added DynamoDB Table Stream

packages/@aws-cdk/aws-dynamodb/lib/table.ts

@@ -25,10 +25,11 @@ export interface TableProps {
     tableName?: string;
 
     /**
-     * The Type of Stream to create.
-     * @default ''
+     * When an item in the table is modified, StreamViewType determines what information
+     * is written to the stream for this table. Valid values for StreamViewType are:
+     * @default undefined
      */
-    streamSpecification?: cloudformation.TableResource.StreamSpecificationProperty;
+    streamSpecification?: StreamViewType;
 }
 
 /**
@@ -49,14 +50,13 @@ export class Table extends Construct {
 
         const readCapacityUnits = props.readCapacity || 5;
         const writeCapacityUnits = props.writeCapacity || 5;
-        const streamViewType = props.streamSpecification;
 
         this.table = new cloudformation.TableResource(this, 'Resource', {
             tableName: props.tableName,
             keySchema: this.keySchema,
             attributeDefinitions: this.attributeDefinitions,
             provisionedThroughput: { readCapacityUnits, writeCapacityUnits },
-            streamSpecification: streamViewType
+            streamSpecification: props.streamSpecification ? {streamViewType: props.streamSpecification} : undefined
         });
 
         if (props.tableName) { this.addMetadata('aws:cdk:hasPhysicalName', props.tableName); }
@@ -119,4 +119,21 @@ export enum KeyAttributeType {
     Binary = 'B',
     Number = 'N',
     String = 'S',
-}
+}
+
+/**
+ * When an item in the table is modified, StreamViewType determines what information
+ * is written to the stream for this table. Valid values for StreamViewType are:
+ * @link https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_StreamSpecification.html
+ * @enum {string}
+ */
+export enum StreamViewType {
+    /** The entire item, as it appears after it was modified, is written to the stream. */
+    NewImage = 'NEW_IMAGE',
+    /** The entire item, as it appeared before it was modified, is written to the stream. */
+    OldImage = 'OLD_IMAGE',
+    /** Both the new and the old item images of the item are written to the stream. */
+    NewAndOldImages = 'NEW_AND_OLD_IMAGES',
+    /** Only the key attributes of the modified item are written to the stream. */
+    KeysOnly = 'KEYS_ONLY'
+  }

packages/@aws-cdk/aws-dynamodb/test/test.dynamodb.ts

@@ -1,6 +1,6 @@
 import { App, Stack } from '@aws-cdk/cdk';
 import { Test } from 'nodeunit';
-import { KeyAttributeType, Table } from '../lib';
+import { KeyAttributeType, StreamViewType, Table } from '../lib';
 
 export = {
     'default properties': {
@@ -94,7 +94,7 @@ export = {
                 tableName: 'MyTable',
                 readCapacity: 42,
                 writeCapacity: 1337,
-                streamSpecification: {streamViewType: 'NEW_AND_OLD_IMAGES'}
+                streamSpecification: StreamViewType.NewAndOldImages
             });
             table.addPartitionKey('partitionKey', KeyAttributeType.String);
             table.addSortKey('sortKey', KeyAttributeType.Binary);
@@ -129,7 +129,7 @@ export = {
                 tableName: 'MyTable',
                 readCapacity: 42,
                 writeCapacity: 1337,
-                streamSpecification: {streamViewType: 'NEW_IMAGE'}
+                streamSpecification: StreamViewType.NewImage
             });
             table.addPartitionKey('partitionKey', KeyAttributeType.String);
             table.addSortKey('sortKey', KeyAttributeType.Binary);
@@ -164,7 +164,7 @@ export = {
                 tableName: 'MyTable',
                 readCapacity: 42,
                 writeCapacity: 1337,
-                streamSpecification: {streamViewType: 'OLD_IMAGE'}
+                streamSpecification: StreamViewType.OldImage
             });
             table.addPartitionKey('partitionKey', KeyAttributeType.String);
             table.addSortKey('sortKey', KeyAttributeType.Binary);