Examples of io.airlift.slice.DynamicSliceOutput.slice()

Class io.airlift.slice.DynamicSliceOutput

Examples of io.airlift.slice.DynamicSliceOutput.slice()

io.airlift.slice.DynamicSliceOutput.slice()

                // write digest
                currentValue.getDigest().serialize(sliceOutput);
                // write percentile
                sliceOutput.appendDouble(currentValue.getPercentile());


                Slice slice = sliceOutput.slice();
                output.append(slice);
            }
        }


        @Override

View Full Code Here

                // write digest
                digest.serialize(sliceOutput);
                // write percentile
                sliceOutput.appendDouble(percentile);


                Slice slice = sliceOutput.slice();
                out.append(slice);
            }


            return out.build();
        }

View Full Code Here

            else {
                DynamicSliceOutput sliceOutput = new DynamicSliceOutput(currentValue.getDigest().estimatedSerializedSizeInBytes());
                currentValue.getDigest().serialize(sliceOutput);
                sliceOutput.appendDouble(currentValue.getPercentile());


                output.append(sliceOutput.slice());
            }
        }


        @Override
        public void evaluateFinal(int groupId, BlockBuilder output)

View Full Code Here

                // write digest
                digest.serialize(sliceOutput);
                // write percentile
                sliceOutput.appendDouble(percentile);


                Slice slice = sliceOutput.slice();
                out.append(slice);
            }


            return out.build();
        }

View Full Code Here

                // write digest
                currentValue.getDigest().serialize(sliceOutput);
                // write percentile
                sliceOutput.appendDouble(currentValue.getPercentile());


                Slice slice = sliceOutput.slice();
                output.appendSlice(slice);
            }
        }


        @Override

View Full Code Here

                // write digest
                digest.serialize(sliceOutput);
                // write percentile
                sliceOutput.appendDouble(percentile);


                Slice slice = sliceOutput.slice();
                out.appendSlice(slice);
            }


            return out.build();
        }

View Full Code Here

            else {
                DynamicSliceOutput sliceOutput = new DynamicSliceOutput(currentValue.getDigest().estimatedSerializedSizeInBytes());
                currentValue.getDigest().serialize(sliceOutput);
                sliceOutput.appendDouble(currentValue.getPercentile());


                output.appendSlice(sliceOutput.slice());
            }
        }


        @Override
        public void evaluateFinal(int groupId, BlockBuilder output)

View Full Code Here

                // write digest
                digest.serialize(sliceOutput);
                // write percentile
                sliceOutput.appendDouble(percentile);


                Slice slice = sliceOutput.slice();
                out.appendSlice(slice);
            }


            return out.build();
        }

View Full Code Here

        uncompressedBlock = block;
        uncompressedBlockEncoding = block.getEncoding();


        DynamicSliceOutput sliceOutput = new DynamicSliceOutput(Ints.checkedCast(uncompressedBlock.getSizeInBytes() + ENCODING_BUFFER_OVERHEAD.toBytes()));
        uncompressedBlockEncoding.writeBlock(sliceOutput, uncompressedBlock);
        Slice uncompressedSlice = sliceOutput.slice();


        byte[] compressedBytes = new byte[Snappy.maxCompressedLength(uncompressedSlice.length())];
        int actualLength = Snappy.compress(uncompressedSlice.getBytes(), 0, uncompressedSlice.length(), compressedBytes, 0);
        compressedSlice = Slices.wrappedBuffer(Arrays.copyOf(compressedBytes, actualLength));
    }

View Full Code Here


            DynamicSliceOutput dynamicSliceOutput = new DynamicSliceOutput(ESTIMATED_JSON_OUTPUT_SIZE);
            try (JsonGenerator jsonGenerator = JSON_FACTORY.createJsonGenerator(dynamicSliceOutput)) {
                jsonGenerator.copyCurrentStructure(jsonParser);
            }
            return dynamicSliceOutput.slice();
        }
    }


    public static class JsonSizeExtractor
            implements JsonExtractor<Long>

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.