@@ -162,14 +162,12 @@ private void readStoreFile(Path storeFilePath) throws Exception {
162
162
}
163
163
return block ;
164
164
}, (key , block ) -> {
165
- boolean isCached = blockCache .getBlock (key , true , false , true ) != null ;
166
- if (
167
- block .getBlockType () == BlockType .DATA || block .getBlockType () == BlockType .ROOT_INDEX
168
- || block .getBlockType () == BlockType .INTERMEDIATE_INDEX
169
- ) {
170
- assertTrue (isCached );
171
- }
172
- });
165
+ boolean isCached = blockCache .getBlock (key , true , false , true ) != null ;
166
+ if (block .getBlockType () == BlockType .DATA || block .getBlockType () == BlockType .ROOT_INDEX
167
+ || block .getBlockType () == BlockType .INTERMEDIATE_INDEX ) {
168
+ assertTrue (isCached );
169
+ }
170
+ });
173
171
}
174
172
175
173
private void readStoreFileCacheOnly (Path storeFilePath ) throws Exception {
@@ -182,17 +180,17 @@ private void readStoreFileCacheOnly(Path storeFilePath) throws Exception {
182
180
}
183
181
return block ;
184
182
}, (key , block ) -> {
185
- boolean isCached = blockCache .getBlock (key , true , false , true ) != null ;
186
- if (block .getBlockType () == BlockType .DATA ) {
187
- assertFalse (block .isUnpacked ());
188
- } else if (
189
- block .getBlockType () == BlockType .ROOT_INDEX
190
- || block .getBlockType () == BlockType .INTERMEDIATE_INDEX
191
- ) {
192
- assertTrue (block .isUnpacked ());
193
- }
194
- assertTrue (isCached );
195
- });
183
+ boolean isCached = blockCache .getBlock (key , true , false , true ) != null ;
184
+ if (block .getBlockType () == BlockType .DATA ) {
185
+ assertFalse (block .isUnpacked ());
186
+ } else if (
187
+ block .getBlockType () == BlockType .ROOT_INDEX
188
+ || block .getBlockType () == BlockType .INTERMEDIATE_INDEX
189
+ ) {
190
+ assertTrue (block .isUnpacked ());
191
+ }
192
+ assertTrue (isCached );
193
+ });
196
194
}
197
195
198
196
private void readStoreFile (Path storeFilePath ,
0 commit comments