File tree 1 file changed +5
-5
lines changed
core/trino-main/src/main/java/io/trino/operator/output
1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -164,12 +164,12 @@ public void addInput(Page page)
164
164
165
165
private List <Slice > splitAndSerializePage (Page page )
166
166
{
167
- List <Page > split = splitPage (page , DEFAULT_MAX_PAGE_SIZE_IN_BYTES );
168
- ImmutableList .Builder <Slice > builder = ImmutableList .builderWithExpectedSize (split .size ());
169
- for (Page p : split ) {
170
- builder .add (serializer .serialize (p ));
167
+ List <Page > inputPages = splitPage (page , DEFAULT_MAX_PAGE_SIZE_IN_BYTES );
168
+ ImmutableList .Builder <Slice > serializedPages = ImmutableList .builderWithExpectedSize (inputPages .size ());
169
+ for (Page inputPage : inputPages ) {
170
+ serializedPages .add (serializer .serialize (inputPage ));
171
171
}
172
- return builder .build ();
172
+ return serializedPages .build ();
173
173
}
174
174
175
175
@ Override
You can’t perform that action at this time.
0 commit comments