From ba11587220858d2ea5473bab10a54e9fb4fc8ad0 Mon Sep 17 00:00:00 2001 From: brentnash Date: Wed, 2 Mar 2016 00:03:56 -0800 Subject: [PATCH] More project reorganization and build fixes. --- .../license/asl/header.txt | 0 .../kinesis/agg/KinesisAggRecord.java | 16 +++ .../amazonaws/kinesis/agg/KplAggregator.java | 16 +++ .../kinesis/agg/KplAggregatorListener.java | 16 +++ .../kinesis/agg/KplBatchAggregator.java | 16 +++ .../kinesis/agg/KplProgressiveAggregator.java | 16 +++ java/KinesisDeaggregator/.classpath | 26 ++++ .../.gitignore | 0 .../.project | 46 +++---- .../README.md | 82 ++++++------- .../KinesisLambdaTestConsumer-1.0-dev.jar | Bin .../license/asl/header.txt | 14 +++ .../pom.xml | 114 +++++++++--------- .../deagg/KinesisUserRecordProcessor.java | 30 +++++ .../kinesis/deagg/KplDeaggregator.java | 16 +++ .../deagg/KinesisUserRecordProcessor.java | 14 --- java/KinesisTestConsumers/.classpath | 2 +- .../license/asl/header.txt | 14 +++ .../kinesis/producer/ProducerConfig.java | 16 +++ .../kinesis/producer/ProducerUtils.java | 16 +++ .../SampleKinesisBatchAggregator.java | 16 +++ .../SampleKinesisProgressiveAggregator.java | 16 +++ 22 files changed, 366 insertions(+), 136 deletions(-) rename java/{KinesisLambdaTestConsumer => KinesisAggregator}/license/asl/header.txt (100%) create mode 100644 java/KinesisDeaggregator/.classpath rename java/{KinesisLambdaTestConsumer => KinesisDeaggregator}/.gitignore (100%) rename java/{KinesisLambdaTestConsumer => KinesisDeaggregator}/.project (95%) mode change 100755 => 100644 rename java/{KinesisLambdaTestConsumer => KinesisDeaggregator}/README.md (99%) mode change 100755 => 100644 rename java/{KinesisLambdaTestConsumer => KinesisDeaggregator}/dist/KinesisLambdaTestConsumer-1.0-dev.jar (100%) create mode 100644 java/KinesisDeaggregator/license/asl/header.txt rename java/{KinesisLambdaTestConsumer => KinesisDeaggregator}/pom.xml (96%) mode change 100755 => 100644 create mode 100644 java/KinesisDeaggregator/src/main/java/com/amazonaws/kinesis/deagg/KinesisUserRecordProcessor.java rename java/{KinesisLambdaTestConsumer => KinesisDeaggregator}/src/main/java/com/amazonaws/kinesis/deagg/KplDeaggregator.java (83%) delete mode 100644 java/KinesisLambdaTestConsumer/src/main/java/com/amazonaws/kinesis/deagg/KinesisUserRecordProcessor.java create mode 100644 java/KinesisTestConsumers/license/asl/header.txt diff --git a/java/KinesisLambdaTestConsumer/license/asl/header.txt b/java/KinesisAggregator/license/asl/header.txt similarity index 100% rename from java/KinesisLambdaTestConsumer/license/asl/header.txt rename to java/KinesisAggregator/license/asl/header.txt diff --git a/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KinesisAggRecord.java b/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KinesisAggRecord.java index a0b0bc2..a25d038 100644 --- a/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KinesisAggRecord.java +++ b/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KinesisAggRecord.java @@ -1,3 +1,19 @@ +/** + * Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + * + * Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Amazon Software License (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/asl/ + * + * 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.kinesis.agg; import java.io.ByteArrayOutputStream; diff --git a/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplAggregator.java b/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplAggregator.java index 3ab3c04..178aa6c 100644 --- a/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplAggregator.java +++ b/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplAggregator.java @@ -1,3 +1,19 @@ +/** + * Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + * + * Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Amazon Software License (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/asl/ + * + * 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.kinesis.agg; import java.nio.ByteBuffer; diff --git a/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplAggregatorListener.java b/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplAggregatorListener.java index ca6ebd1..2318258 100644 --- a/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplAggregatorListener.java +++ b/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplAggregatorListener.java @@ -1,3 +1,19 @@ +/** + * Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + * + * Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Amazon Software License (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/asl/ + * + * 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.kinesis.agg; import java.nio.ByteBuffer; diff --git a/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplBatchAggregator.java b/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplBatchAggregator.java index 1696c54..319aecb 100644 --- a/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplBatchAggregator.java +++ b/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplBatchAggregator.java @@ -1,3 +1,19 @@ +/** + * Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + * + * Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Amazon Software License (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/asl/ + * + * 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.kinesis.agg; import java.nio.ByteBuffer; diff --git a/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplProgressiveAggregator.java b/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplProgressiveAggregator.java index 733a92a..d79d399 100644 --- a/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplProgressiveAggregator.java +++ b/java/KinesisAggregator/src/main/java/com/amazonaws/kinesis/agg/KplProgressiveAggregator.java @@ -1,3 +1,19 @@ +/** + * Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + * + * Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Amazon Software License (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/asl/ + * + * 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.kinesis.agg; import java.nio.ByteBuffer; diff --git a/java/KinesisDeaggregator/.classpath b/java/KinesisDeaggregator/.classpath new file mode 100644 index 0000000..af1430b --- /dev/null +++ b/java/KinesisDeaggregator/.classpath @@ -0,0 +1,26 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/java/KinesisLambdaTestConsumer/.gitignore b/java/KinesisDeaggregator/.gitignore similarity index 100% rename from java/KinesisLambdaTestConsumer/.gitignore rename to java/KinesisDeaggregator/.gitignore diff --git a/java/KinesisLambdaTestConsumer/.project b/java/KinesisDeaggregator/.project old mode 100755 new mode 100644 similarity index 95% rename from java/KinesisLambdaTestConsumer/.project rename to java/KinesisDeaggregator/.project index 93cc66b..c955046 --- a/java/KinesisLambdaTestConsumer/.project +++ b/java/KinesisDeaggregator/.project @@ -1,23 +1,23 @@ - - - KinesisDeaggregator - - - - - - org.eclipse.jdt.core.javabuilder - - - - - org.eclipse.m2e.core.maven2Builder - - - - - - org.eclipse.jdt.core.javanature - org.eclipse.m2e.core.maven2Nature - - + + + KinesisDeaggregator + + + + + + org.eclipse.jdt.core.javabuilder + + + + + org.eclipse.m2e.core.maven2Builder + + + + + + org.eclipse.jdt.core.javanature + org.eclipse.m2e.core.maven2Nature + + diff --git a/java/KinesisLambdaTestConsumer/README.md b/java/KinesisDeaggregator/README.md old mode 100755 new mode 100644 similarity index 99% rename from java/KinesisLambdaTestConsumer/README.md rename to java/KinesisDeaggregator/README.md index 4d7625f..7993775 --- a/java/KinesisLambdaTestConsumer/README.md +++ b/java/KinesisDeaggregator/README.md @@ -49,50 +49,50 @@ Using Lists rather than Java Streams, this same funcitonality can be provided by logger.log(e.getMessage()); } ``` - + ## Instructions for Use - -1. Run Maven->Install to build the project -2. Create a new Lambda function in your AWS account -3. Skip blueprint selection -4. Choose Java 8 as the runtime -5. Choose the built file (from step #2) KinesisLambdaTestConsumer-1.0-dev.jar as the code for the function (NOT the KinesisLambdaTestConsumer-0.0.1.jar file). -6. Choose com.amazonaws.KinesisLambdaReceiver as the Handler -7. Set the default batch size as required for your Stream throughput -8. Set the Role, Memory and Timeout appropriately. -9. Connect your new Lambda function to the Kinesis stream you'll be publishing to + +1. Run Maven->Install to build the project +2. Create a new Lambda function in your AWS account +3. Skip blueprint selection +4. Choose Java 8 as the runtime +5. Choose the built file (from step #2) KinesisLambdaTestConsumer-1.0-dev.jar as the code for the function (NOT the KinesisLambdaTestConsumer-0.0.1.jar file). +6. Choose com.amazonaws.KinesisLambdaReceiver as the Handler +7. Set the default batch size as required for your Stream throughput +8. Set the Role, Memory and Timeout appropriately. +9. Connect your new Lambda function to the Kinesis stream you'll be publishing to ## IAM Role - -This is a sample IAM policy for the Lambda execution role: - -``` - { - "Version": "2012-10-17", - "Statement": [ - { - "Effect": "Allow", - "Action": [ - "lambda:InvokeFunction" - ], - "Resource": [ - "*" - ] - }, - { - "Effect": "Allow", - "Action": [ - "kinesis:GetRecords", - "kinesis:GetShardIterator", - "kinesis:DescribeStream", - "kinesis:ListStreams", - "logs:CreateLogGroup", - "logs:CreateLogStream", - "logs:PutLogEvents" - ], - "Resource": "*" - } - ] + +This is a sample IAM policy for the Lambda execution role: + +``` + { + "Version": "2012-10-17", + "Statement": [ + { + "Effect": "Allow", + "Action": [ + "lambda:InvokeFunction" + ], + "Resource": [ + "*" + ] + }, + { + "Effect": "Allow", + "Action": [ + "kinesis:GetRecords", + "kinesis:GetShardIterator", + "kinesis:DescribeStream", + "kinesis:ListStreams", + "logs:CreateLogGroup", + "logs:CreateLogStream", + "logs:PutLogEvents" + ], + "Resource": "*" + } + ] } ``` diff --git a/java/KinesisLambdaTestConsumer/dist/KinesisLambdaTestConsumer-1.0-dev.jar b/java/KinesisDeaggregator/dist/KinesisLambdaTestConsumer-1.0-dev.jar similarity index 100% rename from java/KinesisLambdaTestConsumer/dist/KinesisLambdaTestConsumer-1.0-dev.jar rename to java/KinesisDeaggregator/dist/KinesisLambdaTestConsumer-1.0-dev.jar diff --git a/java/KinesisDeaggregator/license/asl/header.txt b/java/KinesisDeaggregator/license/asl/header.txt new file mode 100644 index 0000000..36ccafe --- /dev/null +++ b/java/KinesisDeaggregator/license/asl/header.txt @@ -0,0 +1,14 @@ +Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + +Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + +Licensed under the Amazon Software License (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/asl/ + +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. \ No newline at end of file diff --git a/java/KinesisLambdaTestConsumer/pom.xml b/java/KinesisDeaggregator/pom.xml old mode 100755 new mode 100644 similarity index 96% rename from java/KinesisLambdaTestConsumer/pom.xml rename to java/KinesisDeaggregator/pom.xml index 021d28e..0c39e79 --- a/java/KinesisLambdaTestConsumer/pom.xml +++ b/java/KinesisDeaggregator/pom.xml @@ -1,58 +1,58 @@ - - - 4.0.0 - KinesisDeaggregator - jar - - com.amazonaws.services.lambda - kpl-lambda-java - 1.0 - - - clean compile - src/main/java - - - org.apache.maven.plugins - maven-shade-plugin - 2.3 - - false - - - - package - - shade - - - true - dev - - - - - - - - - com.amazonaws - amazon-kinesis-client - ${aws-kinesis-client.version} - - - - com.amazonaws - aws-java-sdk - - - - - com.amazonaws - aws-lambda-java-events - ${aws-lambda-sdk.version} - - - 1.1.0 + + + 4.0.0 + KinesisDeaggregator + jar + + com.amazonaws.services.lambda + kpl-lambda-java + 1.0 + + + clean compile + src/main/java + + + org.apache.maven.plugins + maven-shade-plugin + 2.3 + + false + + + + package + + shade + + + true + dev + + + + + + + + + com.amazonaws + amazon-kinesis-client + ${aws-kinesis-client.version} + + + + com.amazonaws + aws-java-sdk + + + + + com.amazonaws + aws-lambda-java-events + ${aws-lambda-sdk.version} + + + 1.1.0 \ No newline at end of file diff --git a/java/KinesisDeaggregator/src/main/java/com/amazonaws/kinesis/deagg/KinesisUserRecordProcessor.java b/java/KinesisDeaggregator/src/main/java/com/amazonaws/kinesis/deagg/KinesisUserRecordProcessor.java new file mode 100644 index 0000000..7e479d0 --- /dev/null +++ b/java/KinesisDeaggregator/src/main/java/com/amazonaws/kinesis/deagg/KinesisUserRecordProcessor.java @@ -0,0 +1,30 @@ +/** + * Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + * + * Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Amazon Software License (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/asl/ + * + * 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.kinesis.deagg; + +import java.util.List; + +import com.amazonaws.services.kinesis.clientlibrary.types.UserRecord; + +/** + * Interface used by a calling method to call the process function + * + */ +public interface KinesisUserRecordProcessor +{ + public Void process(List userRecords); +} diff --git a/java/KinesisLambdaTestConsumer/src/main/java/com/amazonaws/kinesis/deagg/KplDeaggregator.java b/java/KinesisDeaggregator/src/main/java/com/amazonaws/kinesis/deagg/KplDeaggregator.java similarity index 83% rename from java/KinesisLambdaTestConsumer/src/main/java/com/amazonaws/kinesis/deagg/KplDeaggregator.java rename to java/KinesisDeaggregator/src/main/java/com/amazonaws/kinesis/deagg/KplDeaggregator.java index a015512..8f72f95 100644 --- a/java/KinesisLambdaTestConsumer/src/main/java/com/amazonaws/kinesis/deagg/KplDeaggregator.java +++ b/java/KinesisDeaggregator/src/main/java/com/amazonaws/kinesis/deagg/KplDeaggregator.java @@ -1,3 +1,19 @@ +/** + * Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + * + * Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Amazon Software License (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/asl/ + * + * 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.kinesis.deagg; import java.util.Arrays; diff --git a/java/KinesisLambdaTestConsumer/src/main/java/com/amazonaws/kinesis/deagg/KinesisUserRecordProcessor.java b/java/KinesisLambdaTestConsumer/src/main/java/com/amazonaws/kinesis/deagg/KinesisUserRecordProcessor.java deleted file mode 100644 index aa66d32..0000000 --- a/java/KinesisLambdaTestConsumer/src/main/java/com/amazonaws/kinesis/deagg/KinesisUserRecordProcessor.java +++ /dev/null @@ -1,14 +0,0 @@ -package com.amazonaws.kinesis.deagg; - -import java.util.List; - -import com.amazonaws.services.kinesis.clientlibrary.types.UserRecord; - -/** - * Interface used by a calling method to call the process function - * - */ -public interface KinesisUserRecordProcessor -{ - public Void process(List userRecords); -} diff --git a/java/KinesisTestConsumers/.classpath b/java/KinesisTestConsumers/.classpath index fdbb11b..7991356 100644 --- a/java/KinesisTestConsumers/.classpath +++ b/java/KinesisTestConsumers/.classpath @@ -32,6 +32,6 @@ - + diff --git a/java/KinesisTestConsumers/license/asl/header.txt b/java/KinesisTestConsumers/license/asl/header.txt new file mode 100644 index 0000000..36ccafe --- /dev/null +++ b/java/KinesisTestConsumers/license/asl/header.txt @@ -0,0 +1,14 @@ +Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + +Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + +Licensed under the Amazon Software License (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/asl/ + +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. \ No newline at end of file diff --git a/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/ProducerConfig.java b/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/ProducerConfig.java index c995f75..66c0be9 100644 --- a/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/ProducerConfig.java +++ b/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/ProducerConfig.java @@ -1,3 +1,19 @@ +/** + * Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + * + * Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Amazon Software License (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/asl/ + * + * 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.kinesis.producer; public class ProducerConfig diff --git a/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/ProducerUtils.java b/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/ProducerUtils.java index 7e5d9fb..1e50029 100644 --- a/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/ProducerUtils.java +++ b/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/ProducerUtils.java @@ -1,3 +1,19 @@ +/** + * Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + * + * Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Amazon Software License (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/asl/ + * + * 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.kinesis.producer; import java.math.BigInteger; diff --git a/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/SampleKinesisBatchAggregator.java b/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/SampleKinesisBatchAggregator.java index a0bd55a..93ea36e 100644 --- a/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/SampleKinesisBatchAggregator.java +++ b/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/SampleKinesisBatchAggregator.java @@ -1,3 +1,19 @@ +/** + * Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + * + * Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Amazon Software License (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/asl/ + * + * 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.kinesis.producer; import java.util.List; diff --git a/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/SampleKinesisProgressiveAggregator.java b/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/SampleKinesisProgressiveAggregator.java index 78f9d39..2ac951b 100644 --- a/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/SampleKinesisProgressiveAggregator.java +++ b/java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/SampleKinesisProgressiveAggregator.java @@ -1,3 +1,19 @@ +/** + * Kinesis Producer Library Deaggregation Examples for AWS Lambda/Java + * + * Copyright 2014, Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Amazon Software License (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/asl/ + * + * 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.kinesis.producer; import java.util.List;