From 1cbf7f8e70c4e6e363d763c3206d9ace6c0f10e6 Mon Sep 17 00:00:00 2001 From: patchwork01 <110390516+patchwork01@users.noreply.github.com> Date: Wed, 26 Feb 2025 12:08:52 +0000 Subject: [PATCH] Reformat AddFilesToStateStore --- .../ingest/runner/impl/commit/AddFilesToStateStore.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/java/ingest/ingest-runner/src/main/java/sleeper/ingest/runner/impl/commit/AddFilesToStateStore.java b/java/ingest/ingest-runner/src/main/java/sleeper/ingest/runner/impl/commit/AddFilesToStateStore.java index 552d2953d8..6fa2c4d7f7 100644 --- a/java/ingest/ingest-runner/src/main/java/sleeper/ingest/runner/impl/commit/AddFilesToStateStore.java +++ b/java/ingest/ingest-runner/src/main/java/sleeper/ingest/runner/impl/commit/AddFilesToStateStore.java @@ -46,7 +46,8 @@ static AddFilesToStateStore synchronous(StateStore stateStore) { } static AddFilesToStateStore synchronous( - StateStore stateStore, IngestJobTracker tracker, Supplier timeSupplier, IngestJobAddedFilesEvent.Builder statusUpdateBuilder) { + StateStore stateStore, IngestJobTracker tracker, + Supplier timeSupplier, IngestJobAddedFilesEvent.Builder statusUpdateBuilder) { return references -> { List files = AllReferencesToAFile.newFilesWithReferences(references); new AddFilesTransaction(files).synchronousCommit(stateStore); @@ -55,8 +56,8 @@ static AddFilesToStateStore synchronous( } static AddFilesToStateStore asynchronous( - TableProperties tableProperties, StateStoreCommitRequestSender commitSender, Supplier timeSupplier, - AddFilesTransaction.Builder transactionBuilder) { + TableProperties tableProperties, StateStoreCommitRequestSender commitSender, + Supplier timeSupplier, AddFilesTransaction.Builder transactionBuilder) { return references -> { List files = AllReferencesToAFile.newFilesWithReferences(references); AddFilesTransaction transaction = transactionBuilder.files(files).writtenTime(timeSupplier.get()).build();