org.msgpack.value.Value.asIntegerValue()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(9.3k)|赞(0)|评价(0)|浏览(92)

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

Value.asIntegerValue介绍

[英]Returns the value as IntegerValue. Otherwise throws MessageTypeCastException. Note that you can't use instanceof or cast ((IntegerValue) thisValue) to check type of a value because type of a mutable value is variable.
[中]将值作为IntegerValue返回。否则抛出MessageTypeCastException。请注意，不能使用instanceof或强制转换((IntegerValue) thisValue)来检查值的类型，因为可变值的类型是可变的。

代码示例

代码示例来源：origin: embulk/embulk

@Test
public void testOrdinaryInteger() throws Exception {
  final JsonParser parser = new JsonParser();
  final Value msgpackValue = parser.parse("12345");
  assertTrue(msgpackValue.getValueType().isNumberType());
  assertTrue(msgpackValue.getValueType().isIntegerType());
  assertFalse(msgpackValue.getValueType().isFloatType());
  assertFalse(msgpackValue.getValueType().isStringType());
  assertEquals(12345, msgpackValue.asIntegerValue().asInt());
}

代码示例来源：origin: apache/attic-polygene-java

@Override
  public Short deserialize( Value value, BiFunction<Value, ValueType, Object> deserialize )
  {
    return value.asIntegerValue().asShort();
  }
}

代码示例来源：origin: apache/attic-polygene-java

@Override
  public Integer deserialize( Value value, BiFunction<Value, ValueType, Object> deserialize )
  {
    return value.asIntegerValue().asInt();
  }
}

代码示例来源：origin: apache/attic-polygene-java

@Override
  public Long deserialize( Value value, BiFunction<Value, ValueType, Object> deserialize )
  {
    return value.asIntegerValue().asLong();
  }
}

代码示例来源：origin: apache/attic-polygene-java

@Override
  public Byte deserialize( Value value, BiFunction<Value, ValueType, Object> deserialize )
  {
    return value.asIntegerValue().asByte();
  }
}

代码示例来源：origin: org.msgpack/msgpack-core

@Override
public boolean equals(Object o)
{
  if (o == this) {
    return true;
  }
  if (!(o instanceof Value)) {
    return false;
  }
  Value v = (Value) o;
  if (!v.isIntegerValue()) {
    return false;
  }
  IntegerValue iv = v.asIntegerValue();
  return value.equals(iv.toBigInteger());
}

代码示例来源：origin: org.msgpack/msgpack-core

@Override
public boolean equals(Object o)
{
  if (o == this) {
    return true;
  }
  if (!(o instanceof Value)) {
    return false;
  }
  Value v = (Value) o;
  if (!v.isIntegerValue()) {
    return false;
  }
  IntegerValue iv = v.asIntegerValue();
  if (!iv.isInLongRange()) {
    return false;
  }
  return value == iv.toLong();
}

代码示例来源：origin: io.digdag/digdag-standards

private boolean isTruthy(Value firstCol)
  {
    // Anything that is not NULL and not FALSE or 0 is considered truthy.
    switch (firstCol.getValueType()) {
      case NIL:
        return false;
      case BOOLEAN:
        return firstCol.asBooleanValue().getBoolean();
      case INTEGER:
        return firstCol.asIntegerValue().asLong() != 0;
      default:
        return true;
    }
  }
}

代码示例来源：origin: io.digdag/digdag-standards

private boolean fetchJobResult(int rows, TDJobOperator job)
{
  Optional<ArrayValue> firstRow = pollingRetryExecutor(state, RESULT)
      .retryUnless(TDOperator::isDeterministicClientException)
      .withErrorMessage("Failed to download result of job '%s'", job.getJobId())
      .withRetryInterval(retryInterval)
      .run(s -> job.getResult(
          ite -> ite.hasNext()
              ? Optional.of(ite.next())
              : Optional.absent()));
  if (!firstRow.isPresent()) {
    throw new TaskExecutionException("Got unexpected empty result for count job: " + job.getJobId());
  }
  ArrayValue row = firstRow.get();
  if (row.size() != 1) {
    throw new TaskExecutionException("Got unexpected result row size for count job: " + row.size());
  }
  Value count = row.get(0);
  IntegerValue actualRows;
  try {
    actualRows = count.asIntegerValue();
  }
  catch (MessageTypeCastException e) {
    throw new TaskExecutionException("Got unexpected value type count job: " + count.getValueType());
  }
  return BigInteger.valueOf(rows).compareTo(actualRows.asBigInteger()) <= 0;
}

代码示例来源：origin: io.digdag/digdag-standards

private Object value(Value value)
  {
    switch (value.getValueType()) {
      case NIL:
        return null;
      case BOOLEAN:
        return value.asBooleanValue().getBoolean();
      case INTEGER:
        return value.asIntegerValue().toLong();
      case FLOAT:
        return value.asFloatValue().toFloat();
      case STRING:
        return value.asStringValue().toString();
      case BINARY:
      case ARRAY:
      case MAP:
      case EXTENSION:
      default:
        throw new UnsupportedOperationException("Unsupported column type: " + value.getValueType());
    }
  }
}

代码示例来源：origin: komamitsu/fluency

ageEventsSum.addAndGet(val.asIntegerValue().asInt());

代码示例来源：origin: komamitsu/fluency

@Test
public void ingestWithAck()
    throws IOException
{
  FluentdIngester.Config config = new FluentdIngester.Config();
  config.setAckResponseMode(true);
  Ingester ingester = new FluentdIngester(config, fluentdSender);
  ingester.ingest(TAG, ByteBuffer.wrap(DATA));
  ArgumentCaptor<byte[]> ackTokenArgumentCaptor = ArgumentCaptor.forClass(byte[].class);
  verify(fluentdSender, times(1))
      .sendWithAck(byteBuffersArgumentCaptor.capture(), ackTokenArgumentCaptor.capture());
  List<ByteBuffer> byteBuffers = byteBuffersArgumentCaptor.getAllValues().get(0);
  byte[] ingested = getIngestedData(byteBuffers);
  MessageUnpacker unpacker = MessagePack.newDefaultUnpacker(ingested);
  ImmutableArrayValue arrayValue = unpacker.unpackValue().asArrayValue();
  assertEquals(3, arrayValue.size());
  assertEquals(TAG, arrayValue.get(0).asStringValue().asString());
  assertArrayEquals(DATA, arrayValue.get(1).asRawValue().asByteArray());
  Map<Value, Value> options = arrayValue.get(2).asMapValue().map();
  assertEquals(2, options.size());
  assertEquals(DATA.length, options.get(ValueFactory.newString("size")).asIntegerValue().asInt());
  String ackToken = options.get(ValueFactory.newString("chunk")).asRawValue().asString();
  UUID uuidFromAckToken = UUID.fromString(ackToken);
  List<byte[]> ackTokenArgumentCaptorAllValues = ackTokenArgumentCaptor.getAllValues();
  assertEquals(1, ackTokenArgumentCaptorAllValues.size());
  assertEquals(uuidFromAckToken,
      UUID.fromString(new String(ackTokenArgumentCaptorAllValues.get(0), CHARSET)));
}

代码示例来源：origin: komamitsu/fluency

long timestampMillis;
  if (timestampValue.isIntegerValue()) {
    timestampMillis = timestampValue.asIntegerValue().asLong() * 1000;
assertEquals(map.get(KEY_OPTION_SIZE).asIntegerValue().asLong(), packedBytes.length);

代码示例来源：origin: komamitsu/fluency

@Test
public void ingestWithoutAck()
    throws IOException
{
  Ingester ingester = new FluentdIngester(new FluentdIngester.Config(), fluentdSender);
  ingester.ingest(TAG, ByteBuffer.wrap(DATA));
  verify(fluentdSender, times(1)).send(byteBuffersArgumentCaptor.capture());
  List<ByteBuffer> byteBuffers = byteBuffersArgumentCaptor.getAllValues().get(0);
  byte[] ingested = getIngestedData(byteBuffers);
  MessageUnpacker unpacker = MessagePack.newDefaultUnpacker(ingested);
  ImmutableArrayValue arrayValue = unpacker.unpackValue().asArrayValue();
  assertEquals(3, arrayValue.size());
  assertEquals(TAG, arrayValue.get(0).asStringValue().asString());
  assertArrayEquals(DATA, arrayValue.get(1).asRawValue().asByteArray());
  Map<Value, Value> options = arrayValue.get(2).asMapValue().map();
  assertEquals(1, options.size());
  assertEquals(DATA.length,
      options.get(ValueFactory.newString("size")).asIntegerValue().asInt());
}

代码示例来源：origin: komamitsu/fluency

Map<Value, Value> map = unpacker.unpackValue().asMapValue().map();
assertEquals(2, map.size());
assertEquals(rawValue.asByteArray().length, map.get(KEY_OPTION_SIZE).asIntegerValue().asInt());
assertNotNull(map.get(KEY_OPTION_CHUNK).asRawValue().asString());

代码示例来源：origin: komamitsu/fluency

@Theory
public void testWithAckResponseButNotReceiveToken(final boolean sslEnabled)
    throws Throwable
{
  Exception exception = new ConfigurableTestServer(sslEnabled).run(
      clientSocket -> {
        MessageUnpacker unpacker = MessagePack.newDefaultUnpacker(clientSocket.getInputStream());
        assertEquals(3, unpacker.unpackArrayHeader());
        assertEquals("foo.bar", unpacker.unpackString());
        ImmutableRawValue rawValue = unpacker.unpackValue().asRawValue();
        Map<Value, Value> map = unpacker.unpackValue().asMapValue().map();
        assertEquals(2, map.size());
        assertEquals(rawValue.asByteArray().length, map.get(KEY_OPTION_SIZE).asIntegerValue().asInt());
        assertNotNull(map.get(KEY_OPTION_CHUNK).asRawValue().asString());
        unpacker.close();
      },
      serverPort -> {
        FluencyBuilderForFluentd builder = new FluencyBuilderForFluentd();
        builder.setSslEnabled(sslEnabled);
        builder.setAckResponseMode(true);
        try (Fluency fluency = builder.build(serverPort)) {
          fluency.emit("foo.bar", new HashMap<>());
        }
      }, 5000);
  assertEquals(exception.getClass(), TimeoutException.class);
}

代码示例来源：origin: komamitsu/fluency

@Theory
public void testWithoutAckResponse(final boolean sslEnabled)
    throws Throwable
{
  Exception exception = new ConfigurableTestServer(sslEnabled).run(
      clientSocket -> {
        MessageUnpacker unpacker = MessagePack.newDefaultUnpacker(clientSocket.getInputStream());
        assertEquals(3, unpacker.unpackArrayHeader());
        assertEquals("foo.bar", unpacker.unpackString());
        ImmutableRawValue rawValue = unpacker.unpackValue().asRawValue();
        Map<Value, Value> map = unpacker.unpackValue().asMapValue().map();
        assertEquals(1, map.size());
        assertEquals(rawValue.asByteArray().length, map.get(KEY_OPTION_SIZE).asIntegerValue().asInt());
        unpacker.close();
      },
      serverPort -> {
        FluencyBuilderForFluentd builder = new FluencyBuilderForFluentd();
        builder.setSslEnabled(sslEnabled);
        try (Fluency fluency = builder.build(serverPort)) {
          fluency.emit("foo.bar", new HashMap<>());
        }
      }, 5000);
  assertNull(exception);
}

代码示例来源：origin: komamitsu/fluency

Map<Value, Value> map = unpacker.unpackValue().asMapValue().map();
assertEquals(2, map.size());
assertEquals(rawValue.asByteArray().length, map.get(KEY_OPTION_SIZE).asIntegerValue().asInt());
String ackResponseToken = map.get(KEY_OPTION_CHUNK).asRawValue().asString();
assertNotNull(ackResponseToken);

内容来源于网络，如有侵权，请联系作者删除！

Value

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com