Skip to content

Commit 5f85b57

Browse files
committed
add javadoc comments
1 parent 1c1db04 commit 5f85b57

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

src/main/java/com/uid2/optout/delta/DeltaProductionOrchestrator.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -211,6 +211,10 @@ private boolean processWindow(SqsWindowReader.WindowReadResult windowResult,
211211
return false;
212212
}
213213

214+
/**
215+
* Adds end-of-delta entry to delta stream and converts to byte array,
216+
* then uploads delta file to S3 and deletes associated messages from SQS.
217+
*/
214218
private void uploadDelta(ByteArrayOutputStream deltaStream, String deltaName,
215219
long windowStart, List<SqsParsedMessage> messages,
216220
Consumer<String> onDeltaProduced) throws IOException {
@@ -232,6 +236,9 @@ private void uploadDelta(ByteArrayOutputStream deltaStream, String deltaName,
232236
});
233237
}
234238

239+
/**
240+
* Uploads dropped requests to S3 and deletes associated messages from SQS.
241+
*/
235242
private void uploadDroppedRequests(JsonArray droppedRequestStream, String droppedRequestName,
236243
long windowStart, List<SqsParsedMessage> messages) throws IOException {
237244

0 commit comments

Comments
 (0)