@@ -223,9 +223,10 @@ public MutationBatch getNextMutationBatchAfterBatchId(int batchId) {
223
223
int nextBatchId = batchId + 1 ;
224
224
225
225
SQLiteStatement query =
226
- db .prepare ("SELECT mutations FROM mutations "
227
- + "WHERE uid = ? AND batch_id >= ? "
228
- + "ORDER BY batch_id ASC LIMIT 1" );
226
+ db .prepare (
227
+ "SELECT mutations FROM mutations "
228
+ + "WHERE uid = ? AND batch_id >= ? "
229
+ + "ORDER BY batch_id ASC LIMIT 1" );
229
230
query .bindString (1 , uid );
230
231
query .bindLong (2 , nextBatchId );
231
232
@@ -242,7 +243,7 @@ private MutationBatch executeSimpleMutationBatchLookup(SQLiteStatement query) {
242
243
}
243
244
244
245
try (ParcelFileDescriptor .AutoCloseInputStream stream =
245
- new ParcelFileDescriptor .AutoCloseInputStream (blobFile )) {
246
+ new ParcelFileDescriptor .AutoCloseInputStream (blobFile )) {
246
247
return serializer .decodeMutationBatch (
247
248
com .google .firebase .firestore .proto .WriteBatch .parseFrom (stream ));
248
249
} catch (InvalidProtocolBufferException e ) {
@@ -440,7 +441,7 @@ public void performConsistencyCheck() {
440
441
* too large, executes another query to load the blob directly.
441
442
*
442
443
* @param batchId The batch ID of the row containing the bytes, for fallback lookup if the value
443
- * is too large.
444
+ * is too large.
444
445
* @param bytes The bytes represented
445
446
*/
446
447
private MutationBatch decodeInlineMutationBatch (int batchId , byte [] bytes ) {
0 commit comments