Package com.facebook.presto.spi

Examples of com.facebook.presto.spi.PageBuilder.build()

218
219
220
221
222
223
224
225
        String fragment = recordSink.commit();

        PageBuilder page = new PageBuilder(TYPES);
        BIGINT.writeLong(page.getBlockBuilder(0), rowCount);
        VARCHAR.writeSlice(page.getBlockBuilder(1), Slices.utf8Slice(fragment));
        return page.build();
    }
}
View Full Code Here
147
148
149
150
151
152
153
154
155
156
157
        tableCommitter.commitTable(fragmentBuilder.build());

        PageBuilder page = new PageBuilder(getTypes());
        BIGINT.writeLong(page.getBlockBuilder(0), rowCount);
        return page.build();
    }

    public interface TableCommitter
    {
        void commitTable(Collection<String> fragments);
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
                    Type type = unloadedKeyRecordCursor.getType(i);
                    type.appendTo(block, position, missingKeysPageBuilder.getBlockBuilder(i));
                }
            }
        }
        Page missingKeysPage = missingKeysPageBuilder.build();

        memoryInBytes += missingKeysPage.getSizeInBytes();
        if (isMemoryExceeded()) {
            return null;
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.