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

Input.readLong介绍

[英]Reads an 8 byte long.
[中]读取一个8字节长的。

代码示例

代码示例来源：origin: apache/incubator-dubbo

@Override
public long readLong() throws IOException {
  try {
    return input.readLong();
  } catch (KryoException e) {
    throw new IOException(e);
  }
}

代码示例来源：origin: apache/incubator-dubbo

@Override
public long readLong() throws IOException {
  try {
    return input.readLong();
  } catch (KryoException e) {
    throw new IOException(e);
  }
}

代码示例来源：origin: apache/hive

@Override
public java.sql.Date read(Kryo kryo, Input input, Class<java.sql.Date> clazz) {
 return new java.sql.Date(input.readLong());
}

代码示例来源：origin: apache/storm

@Override
  public RichSpoutBatchId read(Kryo kryo, Input input, Class type) {
    long l = input.readLong();
    return new RichSpoutBatchId(l);
  }
}

代码示例来源：origin: apache/storm

public static MessageId deserialize(Input in) throws IOException {
  int numAnchors = in.readInt(true);
  Map<Long, Long> anchorsToIds = new HashMap<>();
  for (int i = 0; i < numAnchors; i++) {
    anchorsToIds.put(in.readLong(), in.readLong());
  }
  return new MessageId(anchorsToIds);
}

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

private static NodeAddress readNodeAddress(Input in)
{
  long most = in.readLong();
  long least = in.readLong();
  return most != 0L && least != 0L ? new NodeAddressImpl(new UUID(most, least)) : null;
}

代码示例来源：origin: alibaba/jstorm

@Override
  public RichSpoutBatchId read(Kryo kryo, Input input, Class type) {
    long l = input.readLong();
    return new RichSpoutBatchId(l);
  }
}

代码示例来源：origin: alibaba/jstorm

public static MessageId deserialize(Input in) throws IOException {
    int numAnchors = in.readInt(true);
    if (numAnchors == 0) {
      return null;
    }
    Map<Long, Long> anchorsToIds = new HashMap<>();
    for (int i = 0; i < numAnchors; i++) {
      anchorsToIds.put(in.readLong(), in.readLong());
    }
    return new MessageId(anchorsToIds);
  }
}

代码示例来源：origin: apache/hive

@Override
public Timestamp read(Kryo kryo, Input input, Class<Timestamp> clazz) {
 Timestamp ts = new Timestamp(input.readLong());
 ts.setNanos(input.readInt());
 return ts;
}

代码示例来源：origin: apache/flink

@Override
  public TestClass read(Kryo kryo, Input input, Class<TestClass> aClass) {
    return new TestClass(input.readLong());
  }
}

代码示例来源：origin: apache/hive

@Override
 public TimestampTZ read(Kryo kryo, Input input, Class<TimestampTZ> type) {
  long seconds = input.readLong();
  int nanos = input.readInt();
  String zoneId = input.readString();
  return new TimestampTZ(seconds, nanos, ZoneId.of(zoneId));
 }
}

代码示例来源：origin: alibaba/jstorm

@Override
public TradeCustomer read(Kryo kryo, Input input, Class<TradeCustomer> arg2) {
  Pair custormer = kryo.readObject(input, Pair.class);
  Pair trade = kryo.readObject(input, Pair.class);
  long timeStamp = input.readLong();
  String buffer = input.readString();
  TradeCustomer inner = new TradeCustomer(timeStamp, trade, custormer, buffer);
  return inner;
}

代码示例来源：origin: alibaba/jstorm

@Override
public Pair read(Kryo kryo, Input input, Class<Pair> arg2) {
  long value = input.readLong();
  String key = input.readString();
  Pair inner = new Pair();
  inner.setKey(key);
  inner.setValue(value);
  return inner;
}

代码示例来源：origin: alibaba/jstorm

timeStamp = input.readLong();
isBatchTuple = input.readBoolean();
taskId = input.readInt(true);
if (isBatchTuple) {
  if(_isTransactionTuple) {
    batchId = input.readLong(true);

代码示例来源：origin: qiujiayu/AutoLoadCache

@Override
@SuppressWarnings("unchecked")
public CacheWrapper read(Kryo kryo, Input input, Class<CacheWrapper> type) {
  int expire = input.readInt(true);
  long lastLoadTime = input.readLong(true);
  Object o = kryo.readClassAndObject(input);
  CacheWrapper cacheWrapper = new CacheWrapper();
  cacheWrapper.setCacheObject(o);
  cacheWrapper.setExpire(expire);
  cacheWrapper.setLastLoadTime(lastLoadTime);
  return cacheWrapper;
}

代码示例来源：origin: apache/tinkerpop

@Override
public long readLong() {
  return unshadedInput.readLong();
}

代码示例来源：origin: alibaba/jstorm

long batchId = kryoInput.readLong(true);

代码示例来源：origin: apache/metron

@Override
 public void read(Kryo kryo, Input input) {
  int digestSize = input.readInt();
  byte[] digestBytes = input.readBytes(digestSize);
  ByteBuffer digestBuff = ByteBuffer.wrap(digestBytes);
  digest = AVLTreeDigest.fromBytes(digestBuff);
  n = input.readLong();
  sum = input.readDouble();
  sumOfSquares = input.readDouble();
  sumOfLogs = input.readDouble();
  min = input.readDouble();
  max = input.readDouble();
  M1 = input.readDouble();
  M2 = input.readDouble();
  M3 = input.readDouble();
  M4 = input.readDouble();
 }
}

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

/**
 * {@inheritDoc}
 */
@Override
public Timestamp read(Kryo kryo, Input input, Class<Timestamp> type) {
  return new Timestamp(input.readLong(true));
}

代码示例来源：origin: com.esotericsoftware/kryo

public void read (Input input, Object object) {
  if (varIntsEnabled)
    unsafe().putLong(object, offset, input.readLong(false));
  else
    unsafe().putLong(object, offset, input.readLong());
}