List of readBlock() Examples

Examples of readBlock()

com.facebook.presto.block.rle.RunLengthBlockEncoding.readBlock()
com.facebook.presto.spi.block.BlockEncoding.readBlock()
Read a block from the specified input. The returned block should begin at the specified position.
com.facebook.presto.spi.block.VariableWidthBlockEncoding.readBlock()
eu.stratosphere.nephele.services.iomanager.BlockChannelReader.readBlock()
Issues a read request, which will asynchronously fill the given segment with the next block in the underlying file channel. Once the read request is fulfilled, the segment will be added to this reader's return queue. @param segment The segment to read the block into. @throws IOException Thrown, when the reader encounters an I/O error. Due to the asynchronous nature of thereader, the exception thrown here may have been caused by an earlier read request.
org.apache.flink.runtime.io.disk.iomanager.BlockChannelReader.readBlock()
Issues a read request, which will asynchronously fill the given segment with the next block in the underlying file channel. Once the read request is fulfilled, the segment will be added to this reader's return queue. @param segment The segment to read the block into. @throws IOException Thrown, when the reader encounters an I/O error. Due to the asynchronous nature of thereader, the exception thrown here may have been caused by an earlier read request.
org.apache.hadoop.hbase.io.hfile.HFileReaderV2.readBlock()
Read in a file block. @param dataBlockOffset offset to read. @param onDiskBlockSize size of the block @param cacheBlock @param pread Use positional read instead of seek+read (positional isbetter doing random reads whereas seek+read is better scanning). @param isCompaction is this block being read as part of a compaction @param expectedBlockType the block type we are expecting to read with thisread operation, or null to read whatever block type is available and avoid checking (that might reduce caching efficiency of encoded data blocks) @return Block wrapped in a ByteBuffer. @throws IOException
org.nfctools.spi.acs.AcrMfUlReaderWriter.readBlock()
org.nfctools.test.MemoryMapUlReaderWriter.readBlock()

Examples of com.facebook.presto.block.rle.RunLengthBlockEncoding.readBlock()

        RunLengthEncodedBlock expectedBlock = new RunLengthEncodedBlock(value, 11);


        DynamicSliceOutput sliceOutput = new DynamicSliceOutput(1024);
        RunLengthBlockEncoding blockEncoding = new RunLengthBlockEncoding(new VariableWidthBlockEncoding(VARCHAR));
        blockEncoding.writeBlock(sliceOutput, expectedBlock);
        RunLengthEncodedBlock actualBlock = blockEncoding.readBlock(sliceOutput.slice().getInput());
        assertTrue(actualBlock.equalTo(0, expectedBlock, 0));
        BlockAssertions.assertBlockEquals(actualBlock, expectedBlock);
    }


    @Test

View Full Code Here

Examples of com.facebook.presto.block.rle.RunLengthBlockEncoding.readBlock()

        RunLengthEncodedBlock expectedBlock = new RunLengthEncodedBlock(value, 11);


        DynamicSliceOutput sliceOutput = new DynamicSliceOutput(1024);
        RunLengthBlockEncoding blockEncoding = new RunLengthBlockEncoding(new VariableWidthBlockEncoding());
        blockEncoding.writeBlock(sliceOutput, expectedBlock);
        RunLengthEncodedBlock actualBlock = blockEncoding.readBlock(sliceOutput.slice().getInput());
        assertTrue(positionEqualsPosition(VARCHAR, actualBlock, 0, expectedBlock, 0));
        BlockAssertions.assertBlockEquals(VARCHAR, actualBlock, expectedBlock);
    }


    @Test

View Full Code Here

Examples of com.facebook.presto.block.rle.RunLengthBlockEncoding.readBlock()

        RunLengthEncodedBlock expectedBlock = new RunLengthEncodedBlock(value, 11);


        DynamicSliceOutput sliceOutput = new DynamicSliceOutput(1024);
        RunLengthBlockEncoding blockEncoding = new RunLengthBlockEncoding(new VariableWidthBlockEncoding(VARCHAR));
        blockEncoding.writeBlock(sliceOutput, expectedBlock);
        RunLengthEncodedBlock actualBlock = blockEncoding.readBlock(sliceOutput.slice().getInput());
        assertTrue(actualBlock.equalTo(0, expectedBlock, 0));
        BlockAssertions.assertBlockEquals(actualBlock, expectedBlock);
    }


    @Test

View Full Code Here

Examples of com.facebook.presto.spi.block.BlockEncoding.readBlock()


        DynamicSliceOutput sliceOutput = new DynamicSliceOutput(1024);
        BlockEncoding blockEncoding = new RunLengthEncoder(sliceOutput).append(expectedBlock).finish();
        SliceInput sliceInput = sliceOutput.slice().getInput();


        Block block = blockEncoding.readBlock(sliceInput);
        assertInstanceOf(block, RunLengthEncodedBlock.class);
        RunLengthEncodedBlock rleBlock = (RunLengthEncodedBlock) block;
        assertTrue(rleBlock.equalTo(0, expectedBlock, 0));
        assertEquals(rleBlock.getPositionCount(), 2);
        assertEquals(rleBlock.getSlice(0).toStringUtf8(), "alice");

View Full Code Here

Examples of com.facebook.presto.spi.block.BlockEncoding.readBlock()

        RunLengthEncodedBlock rleBlock = (RunLengthEncodedBlock) block;
        assertTrue(rleBlock.equalTo(0, expectedBlock, 0));
        assertEquals(rleBlock.getPositionCount(), 2);
        assertEquals(rleBlock.getSlice(0).toStringUtf8(), "alice");


        block = blockEncoding.readBlock(sliceInput);
        assertInstanceOf(block, RunLengthEncodedBlock.class);
        rleBlock = (RunLengthEncodedBlock) block;
        assertTrue(rleBlock.equalTo(0, expectedBlock, 2));
        assertEquals(rleBlock.getPositionCount(), 4);
        assertEquals(rleBlock.getSlice(0).toStringUtf8(), "bob");

View Full Code Here

Examples of com.facebook.presto.spi.block.BlockEncoding.readBlock()

        rleBlock = (RunLengthEncodedBlock) block;
        assertTrue(rleBlock.equalTo(0, expectedBlock, 2));
        assertEquals(rleBlock.getPositionCount(), 4);
        assertEquals(rleBlock.getSlice(0).toStringUtf8(), "bob");


        block = blockEncoding.readBlock(sliceInput);
        assertInstanceOf(block, RunLengthEncodedBlock.class);
        rleBlock = (RunLengthEncodedBlock) block;
        assertTrue(rleBlock.equalTo(0, expectedBlock, 6));
        assertEquals(rleBlock.getPositionCount(), 6);
        assertEquals(rleBlock.getSlice(0).toStringUtf8(), "charlie");

View Full Code Here

Examples of com.facebook.presto.spi.block.BlockEncoding.readBlock()

                .build();


        DynamicSliceOutput sliceOutput = new DynamicSliceOutput(1024);
        BlockEncoding blockEncoding = new VariableWidthBlockEncoding(VARCHAR);
        blockEncoding.writeBlock(sliceOutput, expectedBlock);
        Block actualBlock = blockEncoding.readBlock(sliceOutput.slice().getInput());
        BlockAssertions.assertBlockEquals(actualBlock, expectedBlock);
    }


    @Test
    public void testCreateBlockWriter()

View Full Code Here

Examples of com.facebook.presto.spi.block.BlockEncoding.readBlock()

                .appendSlice(Slices.utf8Slice("dave"))
                .build();


        DynamicSliceOutput sliceOutput = new DynamicSliceOutput(1024);
        BlockEncoding blockEncoding = new UncompressedEncoder(sliceOutput).append(block).append(block).finish();
        Block actualBlock = blockEncoding.readBlock(sliceOutput.slice().getInput());
        BlockAssertions.assertBlockEquals(actualBlock, VARCHAR.createBlockBuilder(new BlockBuilderStatus())
                .appendSlice(Slices.utf8Slice("alice"))
                .appendSlice(Slices.utf8Slice("bob"))
                .appendSlice(Slices.utf8Slice("charlie"))
                .appendSlice(Slices.utf8Slice("dave"))

View Full Code Here

Examples of com.facebook.presto.spi.block.BlockEncoding.readBlock()

                .appendSlice(Slices.utf8Slice("dave"))
                .build();


        DynamicSliceOutput sliceOutput = new DynamicSliceOutput(1024);
        BlockEncoding blockEncoding = new DictionaryEncoder(new UncompressedEncoder(sliceOutput)).append(block).append(block).append(block).finish();
        Block actualBlock = blockEncoding.readBlock(sliceOutput.slice().getInput());
        assertBlockEquals(actualBlock, VARCHAR.createBlockBuilder(new BlockBuilderStatus())
                .appendSlice(Slices.utf8Slice("alice"))
                .appendSlice(Slices.utf8Slice("bob"))
                .appendSlice(Slices.utf8Slice("charlie"))
                .appendSlice(Slices.utf8Slice("dave"))

View Full Code Here

Examples of com.facebook.presto.spi.block.BlockEncoding.readBlock()

        DynamicSliceOutput compressedOutput = new DynamicSliceOutput(1024);
        Encoder encoder = BlocksFileEncoding.SNAPPY.createBlocksWriter(compressedOutput);


        encoder.append(block);
        BlockEncoding snappyEncoding = encoder.finish();
        Block actualBlock = snappyEncoding.readBlock(compressedOutput.slice().getInput());
        BlockAssertions.assertBlockEquals(actualBlock, block);
    }


    @Test
    public void testLotsOfStuff()

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.