Examples of com.facebook.presto.spi.block.BlockBuilder.appendLong()

Class com.facebook.presto.spi.block.BlockBuilder

Examples of com.facebook.presto.spi.block.BlockBuilder.appendLong()

com.facebook.presto.spi.block.BlockBuilder.appendLong()
Appends a long value to the block.

        page = new Page(builder.appendLong(123).build());
        int firstValueSize = serializedSize(page) - pageSize;
        assertEquals(firstValueSize, 8 + 1); // value size + value overhead


        // page with two values
        page = new Page(builder.appendLong(456).build());
        int secondValueSize = serializedSize(page) - (pageSize + firstValueSize);
        assertEquals(secondValueSize, 8 + 1); // value size + value overhead
    }


    @Test

View Full Code Here

    public static Block createLongsBlock(int... values)
    {
        BlockBuilder builder = BIGINT.createBlockBuilder(new BlockBuilderStatus());


        for (int value : values) {
            builder.appendLong((long) value);
        }


        return builder.build();
    }

View Full Code Here

        for (Long value : values) {
            if (value == null) {
                builder.appendNull();
            }
            else {
                builder.appendLong(value);
            }
        }


        return builder.build();
    }

View Full Code Here

    public static Block createLongSequenceBlock(int start, int end)
    {
        BlockBuilder builder = BIGINT.createBlockBuilder(new BlockBuilderStatus());


        for (int i = start; i < end; i++) {
            builder.appendLong(i);
        }


        return builder.build();
    }

View Full Code Here

        @Override
        public final Block evaluateFinal()
        {
            BlockBuilder out = getFinalType().createBlockBuilder(new BlockBuilderStatus());


            out.appendLong(count);


            return out.build();
        }
    }
}

View Full Code Here


        BlockCursor cursor = block.cursor();
        BlockBuilder idBlockBuilder = BIGINT.createBlockBuilder(new BlockBuilderStatus());
        while (cursor.advanceNextPosition()) {
            int key = dictionaryBuilder.putIfAbsent(cursor);
            idBlockBuilder.appendLong(key);
        }
        idWriter.append(idBlockBuilder.build());


        return this;
    }

View Full Code Here

        while (!pageBuilder.isFull() && advance()) {
            for (int i = 0; i < cursors.length; i++) {
                BlockBuilder builder = pageBuilder.getBlockBuilder(i);
                if (i == sampleWeightChannel) {
                    if (distinct) {
                        builder.appendLong(1);
                    }
                    else {
                        builder.appendLong(sampleWeight);
                    }
                }

View Full Code Here

                if (i == sampleWeightChannel) {
                    if (distinct) {
                        builder.appendLong(1);
                    }
                    else {
                        builder.appendLong(sampleWeight);
                    }
                }
                else {
                    cursors[i].appendTo(builder);
                }

View Full Code Here

                        Class<?> javaType = type.getJavaType();
                        if (javaType == boolean.class) {
                            output.appendBoolean(cursor.getBoolean(column));
                        }
                        else if (javaType == long.class) {
                            output.appendLong(cursor.getLong(column));
                        }
                        else if (javaType == double.class) {
                            output.appendDouble(cursor.getDouble(column));
                        }
                        else if (javaType == Slice.class) {

View Full Code Here

        // Build the sample weight block, and count how many rows of data to copy
        while (remainingLimit > 0 && cursor.advanceNextPosition()) {
            rowsToCopy++;
            long sampleWeight = cursor.getLong();
            if (sampleWeight <= remainingLimit) {
                builder.appendLong(sampleWeight);
            }
            else {
                builder.appendLong(remainingLimit);
            }
            remainingLimit -= sampleWeight;

View Full Code Here

0 1 2 3 4 5

TOP

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.