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

Input.readString介绍

[英]Reads the length and string of UTF8 characters, or null. This can read strings written by Output#writeString(String), Output#writeString(CharSequence), and Output#writeAscii(String).
[中]读取UTF8字符的长度和字符串，或null。这可以读取由Output#writeString（String）、Output#writeString（CharSequence）和Output#writeAscii（String）写入的字符串。

代码示例

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

@Override
public String readUTF() throws IOException {
  try {
    return input.readString();
  } catch (KryoException e) {
    throw new IOException(e);
  }
}

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

@Override
public String readUTF() throws IOException {
  try {
    return input.readString();
  } catch (KryoException e) {
    throw new IOException(e);
  }
}

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

@Override
  public Schema read(Kryo kryo, Input input, Class<Schema> type) {
    String schemaAsString = input.readString();
    // the parser seems to be stateful, to we need a new one for every type.
    Schema.Parser sParser = new Schema.Parser();
    return sParser.parse(schemaAsString);
  }
}

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

@Override
 public Path read(Kryo kryo, Input input, Class<Path> type) {
  return new Path(URI.create(input.readString()));
 }
}

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

@Override
  public PyString read(Kryo kryo, Input input, Class<PyString> type) {
    return new PyString(input.readString());
  }
}

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

public List<Object> deserializeStrings(Input input) {
  List<Object> values = new ArrayList<Object>();
  int size = input.readInt(true);
  for (int i = 0; i < size; i++) {
    values.add(input.readString());
  }
  return values;
}

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

@Override
  public GenericContainer read(Kryo kryo, Input input, Class<GenericContainer> aClass) {
    Schema theSchema = this.getSchema(input.readString());
    GenericDatumReader<GenericContainer> reader = new GenericDatumReader<>(theSchema);
    Decoder decoder = DecoderFactory
      .get()
      .directBinaryDecoder(input, null);

    GenericContainer foo;
    try {
      foo = reader.read(null, decoder);
    } catch (IOException e) {
      throw new RuntimeException(e);
    }
    return foo;
  }
}

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

@Override
 public Address read(Kryo kryo, Input input, Class<Address> type) {
  String host = input.readString();
  int port = input.readInt();
  return Address.from(host, port);
 }
}

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

@Override
  public WrappedString read(Kryo kryo, Input input, Class<WrappedString> type) {
    return new WrappedString(input.readString() + " " + System.identityHashCode(this));
  }
}

代码示例来源：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: orbit/orbit

private static Map<String, Object> readHeaders(Kryo kryo, Input in)
{
  int headers = in.readInt();
  if (headers == 0)
  {
    return Collections.emptyMap();
  }
  Map<String, Object> payload = new HashMap<>(headers);
  for (int i = 0; i < headers; i++)
  {
    String key = in.readString();
    byte valueTypeId = in.readByte();
    if (valueTypeId == ValueType.STRING.id)
    {
      payload.put(key, in.readString());
    }
    else if (valueTypeId == ValueType.INT.id)
    {
      payload.put(key, in.readInt());
    }
    else
    {
      payload.put(key, kryo.readClassAndObject(in));
    }
  }
  return payload;
}

代码示例来源：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: orbit/orbit

private static Object readObjectId(Kryo kryo, Input in)
{
  byte valueTypeIdForObjectId = in.readByte();
  if (valueTypeIdForObjectId == ValueType.STRING.id)
  {
    return in.readString();
  }
  else if (valueTypeIdForObjectId == ValueType.INT.id)
  {
    return in.readInt();
  }
  else
  {
    return kryo.readClassAndObject(in);
  }
}

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

@Override
public String readString() {
  return unshadedInput.readString();
}

代码示例来源：origin: spring-projects/spring-integration

@Override
public File read(Kryo kryo, Input input, Class<File> type) {
  String path  = input.readString();
  return new File(path);
}

代码示例来源：origin: magro/memcached-session-manager

@Override
public User read(Kryo kryo, Input input, Class<User> type) {
  final String password = input.readString();
  final String username = input.readString();
  
  final int size = input.readInt(true);
  final List<GrantedAuthority> authorities = new ArrayList<GrantedAuthority>(size);
  for (int i = 0; i < size; i++) {
    authorities.add((GrantedAuthority)_kryo.readClassAndObject(input));
  }
  final boolean accountNonExpired = input.readBoolean();
  final boolean accountNonLocked = input.readBoolean();
  final boolean credentialsNonExpired = input.readBoolean();
  final boolean enabled = input.readBoolean();
  
  return new User(username, password, enabled, accountNonExpired, credentialsNonExpired, accountNonLocked, authorities);
}

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

public Locale read (Kryo kryo, Input input, Class<Locale> type) {
  String language = input.readString();
  String country = input.readString();
  String variant = input.readString();
  return create(language, country, variant);
}

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

public StringBuffer read (Kryo kryo, Input input, Class<StringBuffer> type) {
  String value = input.readString();
  if (value == null) return null;
  return new StringBuffer(value);
}

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

public StringBuffer read (Kryo kryo, Input input, Class<StringBuffer> type) {
  String value = input.readString();
  if (value == null) return null;
  return new StringBuffer(value);
}