本文整理了Java中io.airlift.slice.Slice.getInput()方法的一些代码示例，展示了Slice.getInput()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Slice.getInput()方法的具体详情如下：
包路径：io.airlift.slice.Slice
类名称：Slice
方法名：getInput

Slice.getInput介绍

[英]Creates a slice input backed by this slice. Any changes to this slice will be immediately visible to the slice input.
[中]创建由该切片支持的切片输入。对此切片的任何更改都将立即对切片输入可见。

代码示例

代码示例来源：origin: prestodb/presto

public void setBuffers(Slice lengthsBuffer, Slice dataBuffer, int uncompressedDataSize)
{
  this.lengthsInput = lengthsBuffer.getInput();
  this.dataBuffer = dataBuffer;
  this.uncompressedDataSize = uncompressedDataSize;
  compressed = (decompressor != null);
  currentPosition = 0;
  currentOffset = 0;
  runLength = 0;
  lastValueLength = 0;
}

代码示例来源：origin: prestodb/presto

public static JsonParser createJsonParser(JsonFactory factory, Slice json)
    throws IOException
{
  // Jackson tries to detect the character encoding automatically when using InputStream
  // so we pass an InputStreamReader instead.
  return factory.createParser(new InputStreamReader(json.getInput(), UTF_8));
}

代码示例来源：origin: prestodb/presto

public static GeometrySerializationType deserializeType(Slice shape)
{
  requireNonNull(shape, "shape is null");
  BasicSliceInput input = shape.getInput();
  verify(input.available() > 0);
  return GeometrySerializationType.getForCode(input.readByte());
}

代码示例来源：origin: prestodb/presto

@Nullable
public static Envelope deserializeEnvelope(Slice shape)
{
  requireNonNull(shape, "shape is null");
  BasicSliceInput input = shape.getInput();
  verify(input.available() > 0);
  int length = input.available() - 1;
  GeometrySerializationType type = GeometrySerializationType.getForCode(input.readByte());
  return getEnvelope(input, type, length);
}

代码示例来源：origin: prestodb/presto

@Setup
  public void setup()
  {
    byte[] bytes = new byte[256 * 64];
    ThreadLocalRandom.current().nextBytes(bytes);
    input = Slices.wrappedBuffer(bytes).getInput();
  }
}

代码示例来源：origin: prestodb/presto

public StripeFooter readStripeFooter(StripeInformation stripe, AggregatedMemoryContext systemMemoryUsage)
    throws IOException
{
  long offset = stripe.getOffset() + stripe.getIndexLength() + stripe.getDataLength();
  int tailLength = toIntExact(stripe.getFooterLength());
  // read the footer
  byte[] tailBuffer = new byte[tailLength];
  orcDataSource.readFully(offset, tailBuffer);
  try (InputStream inputStream = new OrcInputStream(orcDataSource.getId(), Slices.wrappedBuffer(tailBuffer).getInput(), decompressor, systemMemoryUsage, tailLength)) {
    return metadataReader.readStripeFooter(types, inputStream);
  }
}

代码示例来源：origin: prestodb/presto

public static FeatureUnitNormalizer deserialize(byte[] modelData)
{
  SliceInput input = Slices.wrappedBuffer(modelData).getInput();
  FeatureUnitNormalizer model = new FeatureUnitNormalizer();
  while (input.isReadable()) {
    int key = input.readInt();
    model.mins.put(key, input.readDouble());
    model.maxs.put(key, input.readDouble());
  }
  return model;
}

代码示例来源：origin: prestodb/presto

@Override
  public void deserialize(Block block, int index, LongDecimalWithOverflowState state)
  {
    if (!block.isNull(index)) {
      SliceInput slice = VARBINARY.getSlice(block, index).getInput();

      state.setOverflow(slice.readLong());
      state.setLongDecimal(Slices.copyOf(slice.readSlice(slice.available())));
    }
  }
}

代码示例来源：origin: prestodb/presto

private static Block copyBlock(Block block)
{
  DynamicSliceOutput sliceOutput = new DynamicSliceOutput(1024);
  BLOCK_ENCODING_SERDE.writeBlock(sliceOutput, block);
  return BLOCK_ENCODING_SERDE.readBlock(sliceOutput.slice().getInput());
}

代码示例来源：origin: prestodb/presto

private static Block copyBlockViaBlockSerde(Block block)
{
  DynamicSliceOutput sliceOutput = new DynamicSliceOutput(1024);
  BLOCK_ENCODING_SERDE.writeBlock(sliceOutput, block);
  return BLOCK_ENCODING_SERDE.readBlock(sliceOutput.slice().getInput());
}

代码示例来源：origin: prestodb/presto

@Override
  public void deserialize(Block block, int index, LongDecimalWithOverflowAndLongState state)
  {
    if (!block.isNull(index)) {
      SliceInput slice = VARBINARY.getSlice(block, index).getInput();

      state.setLong(slice.readLong());
      state.setOverflow(slice.readLong());
      state.setLongDecimal(Slices.copyOf(slice.readSlice(slice.available())));
    }
  }
}

代码示例来源：origin: prestodb/presto

@Override
protected DecimalInputStream createValueStream(Slice slice)
    throws OrcCorruptionException
{
  Optional<OrcDecompressor> orcDecompressor = createOrcDecompressor(ORC_DATA_SOURCE_ID, SNAPPY, COMPRESSION_BLOCK_SIZE);
  OrcInputStream input = new OrcInputStream(ORC_DATA_SOURCE_ID, slice.getInput(), orcDecompressor, newSimpleAggregatedMemoryContext(), slice.getRetainedSize());
  return new DecimalInputStream(input);
}

代码示例来源：origin: prestodb/presto

@Override
protected LongInputStreamDwrf createValueStream(Slice slice)
    throws OrcCorruptionException
{
  Optional<OrcDecompressor> orcDecompressor = createOrcDecompressor(ORC_DATA_SOURCE_ID, SNAPPY, COMPRESSION_BLOCK_SIZE);
  OrcInputStream input = new OrcInputStream(ORC_DATA_SOURCE_ID, slice.getInput(), orcDecompressor, newSimpleAggregatedMemoryContext(), slice.getRetainedSize());
  return new LongInputStreamDwrf(input, LONG, true, true);
}

代码示例来源：origin: prestodb/presto

@Override
protected LongInputStreamV1 createValueStream(Slice slice)
    throws OrcCorruptionException
{
  Optional<OrcDecompressor> orcDecompressor = createOrcDecompressor(ORC_DATA_SOURCE_ID, SNAPPY, COMPRESSION_BLOCK_SIZE);
  OrcInputStream input = new OrcInputStream(ORC_DATA_SOURCE_ID, slice.getInput(), orcDecompressor, newSimpleAggregatedMemoryContext(), slice.getRetainedSize());
  return new LongInputStreamV1(input, true);
}

代码示例来源：origin: prestodb/presto

@Override
protected BooleanInputStream createValueStream(Slice slice)
    throws OrcCorruptionException
{
  Optional<OrcDecompressor> orcDecompressor = createOrcDecompressor(ORC_DATA_SOURCE_ID, SNAPPY, COMPRESSION_BLOCK_SIZE);
  return new BooleanInputStream(new OrcInputStream(ORC_DATA_SOURCE_ID, slice.getInput(), orcDecompressor, newSimpleAggregatedMemoryContext(), slice.getRetainedSize()));
}

代码示例来源：origin: prestodb/presto

@Override
protected FloatInputStream createValueStream(Slice slice)
    throws OrcCorruptionException
{
  Optional<OrcDecompressor> orcDecompressor = createOrcDecompressor(ORC_DATA_SOURCE_ID, SNAPPY, COMPRESSION_BLOCK_SIZE);
  return new FloatInputStream(new OrcInputStream(ORC_DATA_SOURCE_ID, slice.getInput(), orcDecompressor, newSimpleAggregatedMemoryContext(), slice.getRetainedSize()));
}

代码示例来源：origin: prestodb/presto

@Override
protected ByteInputStream createValueStream(Slice slice)
    throws OrcCorruptionException
{
  Optional<OrcDecompressor> orcDecompressor = createOrcDecompressor(ORC_DATA_SOURCE_ID, SNAPPY, COMPRESSION_BLOCK_SIZE);
  return new ByteInputStream(new OrcInputStream(ORC_DATA_SOURCE_ID, slice.getInput(), orcDecompressor, newSimpleAggregatedMemoryContext(), slice.getRetainedSize()));
}

代码示例来源：origin: prestodb/presto

@Override
protected ByteArrayInputStream createValueStream(Slice slice)
    throws OrcCorruptionException
{
  Optional<OrcDecompressor> orcDecompressor = createOrcDecompressor(ORC_DATA_SOURCE_ID, SNAPPY, COMPRESSION_BLOCK_SIZE);
  return new ByteArrayInputStream(new OrcInputStream(ORC_DATA_SOURCE_ID, slice.getInput(), orcDecompressor, newSimpleAggregatedMemoryContext(), slice.getRetainedSize()));
}

代码示例来源：origin: prestodb/presto

@Override
protected DecimalInputStream createValueStream(Slice slice)
    throws OrcCorruptionException
{
  Optional<OrcDecompressor> orcDecompressor = createOrcDecompressor(ORC_DATA_SOURCE_ID, SNAPPY, COMPRESSION_BLOCK_SIZE);
  return new DecimalInputStream(new OrcInputStream(ORC_DATA_SOURCE_ID, slice.getInput(), orcDecompressor, newSimpleAggregatedMemoryContext(), slice.getRetainedSize()));
}

代码示例来源：origin: prestodb/presto

@Override
protected DoubleInputStream createValueStream(Slice slice)
    throws OrcCorruptionException
{
  Optional<OrcDecompressor> orcDecompressor = createOrcDecompressor(ORC_DATA_SOURCE_ID, SNAPPY, COMPRESSION_BLOCK_SIZE);
  return new DoubleInputStream(new OrcInputStream(ORC_DATA_SOURCE_ID, slice.getInput(), orcDecompressor, newSimpleAggregatedMemoryContext(), slice.getRetainedSize()));
}