Skip to content

Commit 14e19ff

Browse files
Rob9786Rob9786
committed
5425: Re-saved LambdaHandler
1 parent bd31bb2 commit 14e19ff

File tree

1 file changed

+111
-111
lines changed

1 file changed

+111
-111
lines changed

‎java/core/src/main/java/sleeper/core/deploy/LambdaHandler.java‎

Lines changed: 111 additions & 111 deletions
Original file line numberDiff line numberDiff line change
@@ -35,153 +35,153 @@ public class LambdaHandler {
3535
private static final List<LambdaHandler> ALL = new ArrayList<>();
3636
private static final Map<String, LambdaHandler> ATHENA_HANDLER_BY_CLASSNAME = new HashMap<>();
3737
public static final LambdaHandler ATHENA_SIMPLE_COMPOSITE = builder()
38-
.jar(LambdaJar.ATHENA)
39-
.handler("sleeper.athena.composite.SimpleCompositeHandler")
40-
.optionalStack(OptionalStack.AthenaStack).add();
38+
.jar(LambdaJar.ATHENA)
39+
.handler("sleeper.athena.composite.SimpleCompositeHandler")
40+
.optionalStack(OptionalStack.AthenaStack).add();
4141
public static final LambdaHandler ATHENA_ITERATORS_COMPOSITE = builder()
42-
.jar(LambdaJar.ATHENA)
43-
.handler("sleeper.athena.composite.IteratorApplyingCompositeHandler")
44-
.optionalStack(OptionalStack.AthenaStack).add();
42+
.jar(LambdaJar.ATHENA)
43+
.handler("sleeper.athena.composite.IteratorApplyingCompositeHandler")
44+
.optionalStack(OptionalStack.AthenaStack).add();
4545
public static final LambdaHandler BULK_IMPORT_STARTER = builder()
46-
.jar(LambdaJar.BULK_IMPORT_STARTER)
47-
.handler("sleeper.bulkimport.starter.BulkImportStarterLambda")
48-
.optionalStacks(OptionalStack.BULK_IMPORT_STACKS).add();
46+
.jar(LambdaJar.BULK_IMPORT_STARTER)
47+
.handler("sleeper.bulkimport.starter.BulkImportStarterLambda")
48+
.optionalStacks(OptionalStack.BULK_IMPORT_STACKS).add();
4949
public static final LambdaHandler INGEST_TASK_CREATOR = builder()
50-
.jar(LambdaJar.INGEST_TASK_CREATOR)
51-
.handler("sleeper.ingest.taskrunner.RunIngestTasksLambda::eventHandler")
52-
.optionalStack(OptionalStack.IngestStack).add();
50+
.jar(LambdaJar.INGEST_TASK_CREATOR)
51+
.handler("sleeper.ingest.taskrunner.RunIngestTasksLambda::eventHandler")
52+
.optionalStack(OptionalStack.IngestStack).add();
5353
public static final LambdaHandler INGEST_BATCHER_SUBMITTER = builder()
54-
.jar(LambdaJar.INGEST_BATCHER_SUBMITTER)
55-
.handler("sleeper.ingest.batcher.submitter.IngestBatcherSubmitterLambda::handleRequest")
56-
.optionalStack(OptionalStack.IngestBatcherStack).add();
54+
.jar(LambdaJar.INGEST_BATCHER_SUBMITTER)
55+
.handler("sleeper.ingest.batcher.submitter.IngestBatcherSubmitterLambda::handleRequest")
56+
.optionalStack(OptionalStack.IngestBatcherStack).add();
5757
public static final LambdaHandler INGEST_BATCHER_JOB_CREATOR = builder()
58-
.jar(LambdaJar.INGEST_BATCHER_JOB_CREATOR)
59-
.handler("sleeper.ingest.batcher.job.creator.IngestBatcherJobCreatorLambda::eventHandler")
60-
.optionalStack(OptionalStack.IngestBatcherStack).add();
58+
.jar(LambdaJar.INGEST_BATCHER_JOB_CREATOR)
59+
.handler("sleeper.ingest.batcher.job.creator.IngestBatcherJobCreatorLambda::eventHandler")
60+
.optionalStack(OptionalStack.IngestBatcherStack).add();
6161
public static final LambdaHandler GARBAGE_COLLECTOR_TRIGGER = builder()
62-
.jar(LambdaJar.GARBAGE_COLLECTOR)
63-
.handler("sleeper.garbagecollector.GarbageCollectorTriggerLambda::handleRequest")
64-
.optionalStack(OptionalStack.GarbageCollectorStack).add();
62+
.jar(LambdaJar.GARBAGE_COLLECTOR)
63+
.handler("sleeper.garbagecollector.GarbageCollectorTriggerLambda::handleRequest")
64+
.optionalStack(OptionalStack.GarbageCollectorStack).add();
6565
public static final LambdaHandler GARBAGE_COLLECTOR = builder()
66-
.jar(LambdaJar.GARBAGE_COLLECTOR)
67-
.handler("sleeper.garbagecollector.GarbageCollectorLambda::handleRequest")
68-
.optionalStack(OptionalStack.GarbageCollectorStack).add();
66+
.jar(LambdaJar.GARBAGE_COLLECTOR)
67+
.handler("sleeper.garbagecollector.GarbageCollectorLambda::handleRequest")
68+
.optionalStack(OptionalStack.GarbageCollectorStack).add();
6969
public static final LambdaHandler COMPACTION_JOB_CREATOR_TRIGGER = builder()
70-
.jar(LambdaJar.COMPACTION_JOB_CREATOR)
71-
.handler("sleeper.compaction.job.creation.lambda.CreateCompactionJobsTriggerLambda::handleRequest")
72-
.optionalStack(OptionalStack.CompactionStack).add();
70+
.jar(LambdaJar.COMPACTION_JOB_CREATOR)
71+
.handler("sleeper.compaction.job.creation.lambda.CreateCompactionJobsTriggerLambda::handleRequest")
72+
.optionalStack(OptionalStack.CompactionStack).add();
7373
public static final LambdaHandler COMPACTION_JOB_CREATOR = builder()
74-
.jar(LambdaJar.COMPACTION_JOB_CREATOR)
75-
.handler("sleeper.compaction.job.creation.lambda.CreateCompactionJobsLambda::handleRequest")
76-
.optionalStack(OptionalStack.CompactionStack).add();
74+
.jar(LambdaJar.COMPACTION_JOB_CREATOR)
75+
.handler("sleeper.compaction.job.creation.lambda.CreateCompactionJobsLambda::handleRequest")
76+
.optionalStack(OptionalStack.CompactionStack).add();
7777
public static final LambdaHandler COMPACTION_JOB_DISPATCHER = builder()
78-
.jar(LambdaJar.COMPACTION_JOB_CREATOR)
79-
.handler("sleeper.compaction.job.creation.lambda.CompactionJobDispatchLambda::handleRequest")
80-
.optionalStack(OptionalStack.CompactionStack).add();
78+
.jar(LambdaJar.COMPACTION_JOB_CREATOR)
79+
.handler("sleeper.compaction.job.creation.lambda.CompactionJobDispatchLambda::handleRequest")
80+
.optionalStack(OptionalStack.CompactionStack).add();
8181
public static final LambdaHandler COMPACTION_TASK_CREATOR = builder()
82-
.jar(LambdaJar.COMPACTION_TASK_CREATOR)
83-
.handler("sleeper.compaction.task.creation.RunCompactionTasksLambda::eventHandler")
84-
.optionalStack(OptionalStack.CompactionStack).add();
82+
.jar(LambdaJar.COMPACTION_TASK_CREATOR)
83+
.handler("sleeper.compaction.task.creation.RunCompactionTasksLambda::eventHandler")
84+
.optionalStack(OptionalStack.CompactionStack).add();
8585
public static final LambdaHandler COMPACTION_TASK_TERMINATOR = builder()
86-
.jar(LambdaJar.COMPACTION_TASK_CREATOR)
87-
.handler("sleeper.compaction.task.creation.SafeTerminationLambda::handleRequest")
88-
.optionalStack(OptionalStack.CompactionStack).add();
86+
.jar(LambdaJar.COMPACTION_TASK_CREATOR)
87+
.handler("sleeper.compaction.task.creation.SafeTerminationLambda::handleRequest")
88+
.optionalStack(OptionalStack.CompactionStack).add();
8989
public static final LambdaHandler FIND_PARTITIONS_TO_SPLIT_TRIGGER = builder()
90-
.jar(LambdaJar.PARTITION_SPLITTER)
91-
.handler("sleeper.splitter.lambda.FindPartitionsToSplitTriggerLambda::handleRequest")
92-
.optionalStack(OptionalStack.PartitionSplittingStack).add();
90+
.jar(LambdaJar.PARTITION_SPLITTER)
91+
.handler("sleeper.splitter.lambda.FindPartitionsToSplitTriggerLambda::handleRequest")
92+
.optionalStack(OptionalStack.PartitionSplittingStack).add();
9393
public static final LambdaHandler FIND_PARTITIONS_TO_SPLIT = builder()
94-
.jar(LambdaJar.PARTITION_SPLITTER)
95-
.handler("sleeper.splitter.lambda.FindPartitionsToSplitLambda::handleRequest")
96-
.optionalStack(OptionalStack.PartitionSplittingStack).add();
94+
.jar(LambdaJar.PARTITION_SPLITTER)
95+
.handler("sleeper.splitter.lambda.FindPartitionsToSplitLambda::handleRequest")
96+
.optionalStack(OptionalStack.PartitionSplittingStack).add();
9797
public static final LambdaHandler SPLIT_PARTITION = builder()
98-
.jar(LambdaJar.PARTITION_SPLITTER)
99-
.handler("sleeper.splitter.lambda.SplitPartitionLambda::handleRequest")
100-
.optionalStack(OptionalStack.PartitionSplittingStack).add();
98+
.jar(LambdaJar.PARTITION_SPLITTER)
99+
.handler("sleeper.splitter.lambda.SplitPartitionLambda::handleRequest")
100+
.optionalStack(OptionalStack.PartitionSplittingStack).add();
101101
public static final LambdaHandler KEEP_QUERY_WARM = builder()
102-
.jar(LambdaJar.QUERY)
103-
.handler("sleeper.query.lambda.WarmQueryExecutorLambda::handleRequest")
104-
.optionalStack(OptionalStack.KeepLambdaWarmStack).add();
102+
.jar(LambdaJar.QUERY)
103+
.handler("sleeper.query.lambda.WarmQueryExecutorLambda::handleRequest")
104+
.optionalStack(OptionalStack.KeepLambdaWarmStack).add();
105105
public static final LambdaHandler BULK_EXPORT_PLANNER = builder()
106-
.jar(LambdaJar.BULK_EXPORT_PLANNER)
107-
.handler("sleeper.bulkexport.planner.SqsBulkExportProcessorLambda::handleRequest")
108-
.optionalStack(BulkExportStack).add();
106+
.jar(LambdaJar.BULK_EXPORT_PLANNER)
107+
.handler("sleeper.bulkexport.planner.SqsBulkExportProcessorLambda::handleRequest")
108+
.optionalStack(BulkExportStack).add();
109109
public static final LambdaHandler BULK_EXPORT_TASK_CREATOR = builder()
110-
.jar(LambdaJar.BULK_EXPORT_TASK_CREATOR)
111-
.handler("sleeper.bulkexport.taskcreator.SqsTriggeredBulkExportTaskRunnerLambda::handleRequest")
112-
.optionalStack(BulkExportStack).add();
110+
.jar(LambdaJar.BULK_EXPORT_TASK_CREATOR)
111+
.handler("sleeper.bulkexport.taskcreator.SqsTriggeredBulkExportTaskRunnerLambda::handleRequest")
112+
.optionalStack(BulkExportStack).add();
113113
public static final LambdaHandler QUERY_EXECUTOR = builder()
114-
.jar(LambdaJar.QUERY)
115-
.handler("sleeper.query.lambda.SqsQueryProcessorLambda::handleRequest")
116-
.optionalStack(OptionalStack.QueryStack).add();
114+
.jar(LambdaJar.QUERY)
115+
.handler("sleeper.query.lambda.SqsQueryProcessorLambda::handleRequest")
116+
.optionalStack(OptionalStack.QueryStack).add();
117117
public static final LambdaHandler QUERY_LEAF_PARTITION = builder()
118-
.jar(LambdaJar.QUERY)
119-
.handler("sleeper.query.lambda.SqsLeafPartitionQueryLambda::handleRequest")
120-
.optionalStack(OptionalStack.QueryStack).add();
118+
.jar(LambdaJar.QUERY)
119+
.handler("sleeper.query.lambda.SqsLeafPartitionQueryLambda::handleRequest")
120+
.optionalStack(OptionalStack.QueryStack).add();
121121
public static final LambdaHandler WEB_SOCKET_QUERY = builder()
122-
.jar(LambdaJar.QUERY)
123-
.handler("sleeper.query.lambda.WebSocketQueryProcessorLambda::handleRequest")
124-
.optionalStack(OptionalStack.WebSocketQueryStack).add();
122+
.jar(LambdaJar.QUERY)
123+
.handler("sleeper.query.lambda.WebSocketQueryProcessorLambda::handleRequest")
124+
.optionalStack(OptionalStack.WebSocketQueryStack).add();
125125
public static final LambdaHandler AUTO_DELETE_S3_OBJECTS = builder()
126-
.jar(LambdaJar.CUSTOM_RESOURCES)
127-
.handler("sleeper.cdk.custom.AutoDeleteS3ObjectsLambda::handleEvent")
128-
.core().add();
126+
.jar(LambdaJar.CUSTOM_RESOURCES)
127+
.handler("sleeper.cdk.custom.AutoDeleteS3ObjectsLambda::handleEvent")
128+
.core().add();
129129
public static final LambdaHandler AUTO_STOP_ECS_CLUSTER_TASKS = builder()
130-
.jar(LambdaJar.CUSTOM_RESOURCES)
131-
.handler("sleeper.cdk.custom.AutoStopEcsClusterTasksLambda::handleEvent")
132-
.core().add();
130+
.jar(LambdaJar.CUSTOM_RESOURCES)
131+
.handler("sleeper.cdk.custom.AutoStopEcsClusterTasksLambda::handleEvent")
132+
.core().add();
133133
public static final LambdaHandler PROPERTIES_WRITER = builder()
134-
.jar(LambdaJar.CUSTOM_RESOURCES)
135-
.handler("sleeper.cdk.custom.PropertiesWriterLambda::handleEvent")
136-
.core().add();
134+
.jar(LambdaJar.CUSTOM_RESOURCES)
135+
.handler("sleeper.cdk.custom.PropertiesWriterLambda::handleEvent")
136+
.core().add();
137137
public static final LambdaHandler VPC_CHECK = builder()
138-
.jar(LambdaJar.CUSTOM_RESOURCES)
139-
.handler("sleeper.cdk.custom.VpcCheckLambda::handleEvent")
140-
.core().add();
138+
.jar(LambdaJar.CUSTOM_RESOURCES)
139+
.handler("sleeper.cdk.custom.VpcCheckLambda::handleEvent")
140+
.core().add();
141141
public static final LambdaHandler METRICS_TRIGGER = builder()
142-
.jar(LambdaJar.METRICS)
143-
.handler("sleeper.metrics.TableMetricsTriggerLambda::handleRequest")
144-
.optionalStack(OptionalStack.TableMetricsStack).add();
142+
.jar(LambdaJar.METRICS)
143+
.handler("sleeper.metrics.TableMetricsTriggerLambda::handleRequest")
144+
.optionalStack(OptionalStack.TableMetricsStack).add();
145145
public static final LambdaHandler METRICS = builder()
146-
.jar(LambdaJar.METRICS)
147-
.handler("sleeper.metrics.TableMetricsLambda::handleRequest")
148-
.optionalStack(OptionalStack.TableMetricsStack).add();
146+
.jar(LambdaJar.METRICS)
147+
.handler("sleeper.metrics.TableMetricsLambda::handleRequest")
148+
.optionalStack(OptionalStack.TableMetricsStack).add();
149149
public static final LambdaHandler STATESTORE_COMMITTER = builder()
150-
.jar(LambdaJar.STATESTORE)
151-
.handler("sleeper.statestore.lambda.committer.StateStoreCommitterLambda::handleRequest")
152-
.core().add();
150+
.jar(LambdaJar.STATESTORE)
151+
.handler("sleeper.statestore.lambda.committer.StateStoreCommitterLambda::handleRequest")
152+
.core().add();
153153
public static final LambdaHandler COMPACTION_COMMIT_BATCHER = builder()
154-
.jar(LambdaJar.STATESTORE)
155-
.handler("sleeper.statestore.lambda.committer.CompactionCommitBatcherLambda::handleRequest")
156-
.core().add();
154+
.jar(LambdaJar.STATESTORE)
155+
.handler("sleeper.statestore.lambda.committer.CompactionCommitBatcherLambda::handleRequest")
156+
.core().add();
157157
public static final LambdaHandler SNAPSHOT_CREATION_TRIGGER = builder()
158-
.jar(LambdaJar.STATESTORE)
159-
.handler("sleeper.statestore.lambda.snapshot.TransactionLogSnapshotCreationTriggerLambda::handleRequest")
160-
.core().add();
158+
.jar(LambdaJar.STATESTORE)
159+
.handler("sleeper.statestore.lambda.snapshot.TransactionLogSnapshotCreationTriggerLambda::handleRequest")
160+
.core().add();
161161
public static final LambdaHandler SNAPSHOT_CREATION = builder()
162-
.jar(LambdaJar.STATESTORE)
163-
.handler("sleeper.statestore.lambda.snapshot.TransactionLogSnapshotCreationLambda::handleRequest")
164-
.core().add();
162+
.jar(LambdaJar.STATESTORE)
163+
.handler("sleeper.statestore.lambda.snapshot.TransactionLogSnapshotCreationLambda::handleRequest")
164+
.core().add();
165165
public static final LambdaHandler SNAPSHOT_DELETION_TRIGGER = builder()
166-
.jar(LambdaJar.STATESTORE)
167-
.handler("sleeper.statestore.lambda.snapshot.TransactionLogSnapshotDeletionTriggerLambda::handleRequest")
168-
.core().add();
166+
.jar(LambdaJar.STATESTORE)
167+
.handler("sleeper.statestore.lambda.snapshot.TransactionLogSnapshotDeletionTriggerLambda::handleRequest")
168+
.core().add();
169169
public static final LambdaHandler SNAPSHOT_DELETION = builder()
170-
.jar(LambdaJar.STATESTORE)
171-
.handler("sleeper.statestore.lambda.snapshot.TransactionLogSnapshotDeletionLambda::handleRequest")
172-
.core().add();
170+
.jar(LambdaJar.STATESTORE)
171+
.handler("sleeper.statestore.lambda.snapshot.TransactionLogSnapshotDeletionLambda::handleRequest")
172+
.core().add();
173173
public static final LambdaHandler TRANSACTION_DELETION_TRIGGER = builder()
174-
.jar(LambdaJar.STATESTORE)
175-
.handler("sleeper.statestore.lambda.transaction.TransactionLogTransactionDeletionTriggerLambda::handleRequest")
176-
.core().add();
174+
.jar(LambdaJar.STATESTORE)
175+
.handler("sleeper.statestore.lambda.transaction.TransactionLogTransactionDeletionTriggerLambda::handleRequest")
176+
.core().add();
177177
public static final LambdaHandler TRANSACTION_DELETION = builder()
178-
.jar(LambdaJar.STATESTORE)
179-
.handler("sleeper.statestore.lambda.transaction.TransactionLogTransactionDeletionLambda::handleRequest")
180-
.core().add();
178+
.jar(LambdaJar.STATESTORE)
179+
.handler("sleeper.statestore.lambda.transaction.TransactionLogTransactionDeletionLambda::handleRequest")
180+
.core().add();
181181
public static final LambdaHandler TRANSACTION_FOLLOWER = builder()
182-
.jar(LambdaJar.STATESTORE)
183-
.handler("sleeper.statestore.lambda.transaction.TransactionLogFollowerLambda::handleRequest")
184-
.core().add();
182+
.jar(LambdaJar.STATESTORE)
183+
.handler("sleeper.statestore.lambda.transaction.TransactionLogFollowerLambda::handleRequest")
184+
.core().add();
185185

186186
private final LambdaJar jar;
187187
private final String handler;

0 commit comments

Comments
 (0)