File tree Expand file tree Collapse file tree
src/main/java/app/universy/lambda/handlers/dynamo Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1- package com .universy .lambda .handlers .dynamo ;
1+ package app .universy .lambda .handlers .dynamo ;
22
3+ import app .universy .lambda .handlers .dynamo .exceptions .DynamoStreamConsumerException ;
34import com .amazonaws .services .dynamodbv2 .model .Record ;
45import com .amazonaws .services .dynamodbv2 .model .StreamRecord ;
56import com .amazonaws .services .lambda .runtime .Context ;
67import com .amazonaws .services .lambda .runtime .RequestHandler ;
78import com .amazonaws .services .lambda .runtime .events .DynamodbEvent ;
8- import com .universy .lambda .handlers .dynamo .consumers .DiscardConsumer ;
9- import com .universy .lambda .handlers .dynamo .typeresolver .DynamoDBRecordTypeResolver ;
9+ import app .universy .lambda .handlers .dynamo .consumers .DiscardConsumer ;
10+ import app .universy .lambda .handlers .dynamo .typeresolver .DynamoDBRecordTypeResolver ;
1011
1112import java .util .function .Consumer ;
1213
Original file line number Diff line number Diff line change 1- package com .universy .lambda .handlers .dynamo .consumers ;
1+ package app .universy .lambda .handlers .dynamo .consumers ;
22
33import java .util .function .Consumer ;
44
Original file line number Diff line number Diff line change 1- package com .universy .lambda .handlers .dynamo .consumers ;
1+ package app .universy .lambda .handlers .dynamo .consumers ;
22
33import com .amazonaws .services .dynamodbv2 .model .StreamRecord ;
4- import com .universy .lambda .handlers .dynamo .mapper .DynamoItemMapper ;
4+ import app .universy .lambda .handlers .dynamo .mapper .DynamoItemMapper ;
55
66public abstract class InsertConsumer <T > extends StreamRecordConsumer <T > {
77
Original file line number Diff line number Diff line change 1- package com .universy .lambda .handlers .dynamo .consumers ;
1+ package app .universy .lambda .handlers .dynamo .consumers ;
22
33import com .amazonaws .services .dynamodbv2 .model .StreamRecord ;
4- import com .universy .lambda .handlers .dynamo .mapper .DynamoItemMapper ;
4+ import app .universy .lambda .handlers .dynamo .mapper .DynamoItemMapper ;
55
66public abstract class ModifyConsumer <T > extends StreamRecordConsumer <T > {
77
Original file line number Diff line number Diff line change 1- package com .universy .lambda .handlers .dynamo .consumers ;
1+ package app .universy .lambda .handlers .dynamo .consumers ;
22
3+ import app .universy .lambda .handlers .dynamo .mapper .DynamoItemMapper ;
34import com .amazonaws .services .dynamodbv2 .model .StreamRecord ;
4- import com .universy .lambda .handlers .dynamo .mapper .DynamoItemMapper ;
55
66public abstract class RemoveConsumer <T > extends StreamRecordConsumer <T > {
77
Original file line number Diff line number Diff line change 1- package com .universy .lambda .handlers .dynamo .consumers ;
1+ package app .universy .lambda .handlers .dynamo .consumers ;
22
33import com .amazonaws .services .dynamodbv2 .model .StreamRecord ;
4- import com .universy .lambda .handlers .dynamo .mapper .DynamoItemMapper ;
54
65import java .util .function .Consumer ;
76
Original file line number Diff line number Diff line change 1- package com .universy .lambda .handlers .dynamo .exceptions ;
1+ package app .universy .lambda .handlers .dynamo .exceptions ;
22
33public class DynamoStreamConsumerException extends RuntimeException {
44}
Original file line number Diff line number Diff line change 1- package com .universy .lambda .handlers .dynamo .mapper ;
1+ package app .universy .lambda .handlers .dynamo .mapper ;
22
3+ import app .universy .lambda .handlers .dynamo .exceptions .DynamoStreamConsumerException ;
34import com .amazonaws .services .dynamodbv2 .document .ItemUtils ;
45import com .amazonaws .services .dynamodbv2 .model .AttributeValue ;
5- import com .universy .lambda .handlers .dynamo .exceptions .DynamoStreamConsumerException ;
66import org .apache .logging .log4j .LogManager ;
77import org .apache .logging .log4j .Logger ;
88
Original file line number Diff line number Diff line change 1- package com .universy .lambda .handlers .dynamo .mapper ;
1+ package app .universy .lambda .handlers .dynamo .mapper ;
22
33import com .fasterxml .jackson .databind .ObjectMapper ;
44
Original file line number Diff line number Diff line change 1- package com .universy .lambda .handlers .dynamo .typeresolver ;
1+ package app .universy .lambda .handlers .dynamo .typeresolver ;
22
33import com .amazonaws .services .dynamodbv2 .model .Record ;
44
You can’t perform that action at this time.
0 commit comments