Skip to content

Commit

Permalink
Reformat AddFilesToStateStore
Browse files Browse the repository at this point in the history
  • Loading branch information
patchwork01 committed Feb 26, 2025
1 parent 2acc220 commit 1cbf7f8
Showing 1 changed file with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,8 @@ static AddFilesToStateStore synchronous(StateStore stateStore) {
}

static AddFilesToStateStore synchronous(
StateStore stateStore, IngestJobTracker tracker, Supplier<Instant> timeSupplier, IngestJobAddedFilesEvent.Builder statusUpdateBuilder) {
StateStore stateStore, IngestJobTracker tracker,
Supplier<Instant> timeSupplier, IngestJobAddedFilesEvent.Builder statusUpdateBuilder) {
return references -> {
List<AllReferencesToAFile> files = AllReferencesToAFile.newFilesWithReferences(references);
new AddFilesTransaction(files).synchronousCommit(stateStore);
Expand All @@ -55,8 +56,8 @@ static AddFilesToStateStore synchronous(
}

static AddFilesToStateStore asynchronous(
TableProperties tableProperties, StateStoreCommitRequestSender commitSender, Supplier<Instant> timeSupplier,
AddFilesTransaction.Builder transactionBuilder) {
TableProperties tableProperties, StateStoreCommitRequestSender commitSender,
Supplier<Instant> timeSupplier, AddFilesTransaction.Builder transactionBuilder) {
return references -> {
List<AllReferencesToAFile> files = AllReferencesToAFile.newFilesWithReferences(references);
AddFilesTransaction transaction = transactionBuilder.files(files).writtenTime(timeSupplier.get()).build();
Expand Down

0 comments on commit 1cbf7f8

Please sign in to comment.