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

Input.close介绍

[英]Closes the underlying InputStream, if any.
[中]关闭基础InputStream（如果有）。

代码示例

代码示例来源：origin: yu199195/Raincat

@Override
public <T> T deSerialize(final byte[] param, final Class<T> clazz) throws TransactionException {
  T object;
  try (ByteArrayInputStream inputStream = new ByteArrayInputStream(param)) {
    Kryo kryo = new Kryo();
    Input input = new Input(inputStream);
    object = kryo.readObject(input, clazz);
    input.close();
  } catch (IOException e) {
    throw new TransactionException("kryo deSerialize error" + e.getMessage());
  }
  return object;
}

代码示例来源：origin: yu199195/myth

@Override
public <T> T deSerialize(final byte[] param, final Class<T> clazz) throws MythException {
  T object;
  try (ByteArrayInputStream inputStream = new ByteArrayInputStream(param)) {
    Kryo kryo = new Kryo();
    Input input = new Input(inputStream);
    object = kryo.readObject(input, clazz);
    input.close();
  } catch (IOException e) {
    throw new MythException("kryo deSerialize error" + e.getMessage());
  }
  return object;
}

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

private static <T extends Serializable> T deserializeObjectFromKryo(byte[] bytes, Class<T> clazz) {
 Input inp = new Input(new ByteArrayInputStream(bytes));
 Kryo kryo = borrowKryo();
 T func = null;
 try {
  func = kryo.readObject(inp, clazz);
 } finally {
  releaseKryo(kryo);
 }
 inp.close();
 return func;
}

代码示例来源：origin: yu199195/hmily

/**
 * 反序列化.
 *
 * @param param 需要反序列化的byte []
 * @return 序列化对象
 * @throws HmilyException 异常
 */
@Override
public <T> T deSerialize(final byte[] param, final Class<T> clazz) throws HmilyException {
  T object;
  try (ByteArrayInputStream inputStream = new ByteArrayInputStream(param)) {
    Kryo kryo = new Kryo();
    Input input = new Input(inputStream);
    object = kryo.readObject(input, clazz);
    input.close();
  } catch (IOException e) {
    throw new HmilyException("kryo deSerialize error" + e.getMessage());
  }
  return object;
}

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

private static <T> T deserializeObjectByKryo(Kryo kryo, InputStream in, Class<T> clazz ) {
 Input inp = new Input(in);
 kryo.setClassLoader(Utilities.getSessionSpecifiedClassLoader());
 T t = kryo.readObject(inp,clazz);
 inp.close();
 return t;
}

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

in.close();

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

public synchronized void clear() {
 writeCursor = readCursor = rowsInReadBuffer = 0;
 readBufferUsed = false;
 if (parentFile != null) {
  if (input != null) {
   try {
    input.close();
   } catch (Throwable ignored) {
   }
   input = null;
  }
  if (output != null) {
   try {
    output.close();
   } catch (Throwable ignored) {
   }
   output = null;
  }
  try {
   FileUtil.fullyDelete(parentFile);
  } catch (Throwable ignored) {
  }
  parentFile = null;
  tmpFile = null;
 }
}

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

public void clear() {
 readCursor = rowsInReadBuffer = rowsOnDisk = 0;
 readBufferUsed = false;
 if (parentDir != null) {
  if (input != null) {
   try {
    input.close();
   } catch (Throwable ignored) {
   }
   input = null;
  }
  if (output != null) {
   try {
    output.close();
   } catch (Throwable ignored) {
   }
   output = null;
  }
  try {
   FileUtil.fullyDelete(parentDir);
  } catch (Throwable ignored) {
  }
  parentDir = null;
  tmpFile = null;
 }
}

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

public void clear() {
 readCursor = rowsInReadBuffer = rowsOnDisk = 0;
 readBufferUsed = false;
 if (parentDir != null) {
  if (input != null) {
   try {
    input.close();
   } catch (Throwable ignored) {
   }
   input = null;
  }
  if (output != null) {
   try {
    output.close();
   } catch (Throwable ignored) {
   }
   output = null;
  }
  try {
   FileUtil.fullyDelete(parentDir);
  } catch (Throwable ignored) {
  }
  parentDir = null;
  tmpFile = null;
 }
}

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

public BytesBytesMultiHashMap getHashMapFromDisk(int rowCount)
  throws IOException, ClassNotFoundException {
 if (hashMapSpilledOnCreation) {
  return new BytesBytesMultiHashMap(rowCount, loadFactor, wbSize, -1);
 } else {
  InputStream inputStream = Files.newInputStream(hashMapLocalPath);
  com.esotericsoftware.kryo.io.Input input = new com.esotericsoftware.kryo.io.Input(inputStream);
  Kryo kryo = SerializationUtilities.borrowKryo();
  BytesBytesMultiHashMap restoredHashMap = null;
  try {
   restoredHashMap = kryo.readObject(input, BytesBytesMultiHashMap.class);
  } finally {
   SerializationUtilities.releaseKryo(kryo);
  }
  if (rowCount > 0) {
   restoredHashMap.expandAndRehashToTarget(rowCount);
  }
  // some bookkeeping
  rowsOnDisk = 0;
  hashMapOnDisk = false;
  input.close();
  inputStream.close();
  Files.delete(hashMapLocalPath);
  return restoredHashMap;
 }
}

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

input.close();
input = null;

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

input.close();
input = null;

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

input.close();
input = null;

代码示例来源：origin: westnordost/StreetComplete

@Override public <T> T toObject(byte[] bytes, Class<T> type)
  {
    Input input = new Input(bytes);
    T result = kryo.get().readObject(input, type);
    input.close();
    return result;
  }
}

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

@Override
public <T> T decode(byte[] bytes, Class<T> type) throws IOException {
  Assert.notNull(bytes, "'bytes' cannot be null");
  final Input input = new Input(bytes);
  try {
    return decode(input, type);
  }
  finally {
    input.close();
  }
}

代码示例来源：origin: Dromara/soul

@Override
public Object deserialize(final byte[] bytes) throws ZkMarshallingError {
  Object object;
  try (ByteArrayInputStream inputStream = new ByteArrayInputStream(bytes)) {
    Kryo kryo = new Kryo();
    Input input = new Input(inputStream);
    object = kryo.readClassAndObject(input);
    input.close();
  } catch (IOException e) {
    throw new SerializerException("kryo deSerialize error" + e.getMessage());
  }
  return object;
}

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

@Override
public <T> T decode(InputStream inputStream, final Class<T> type) throws IOException {
  Assert.notNull(inputStream, "'inputStream' cannot be null");
  Assert.notNull(type, "'type' cannot be null");
  final Input input = (inputStream instanceof Input ? (Input) inputStream : new Input(inputStream));
  T result = null;
  try {
    result = this.pool.run(kryo -> doDecode(kryo, input, type));
  }
  finally {
    input.close();
  }
  return result;
}

代码示例来源：origin: stackoverflow.com

Kryo kryo = new Kryo();
// #### Store to disk...
Output output = new Output(new FileOutputStream("file.bin"));
SomeClass someObject = ...
kryo.writeObject(output, someObject);
output.close();
// ### Restore from disk...
Input input = new Input(new FileInputStream("file.bin"));
SomeClass someObject = kryo.readObject(input, SomeClass.class);
input.close();

代码示例来源：origin: org.apache.apex/apex-engine

@Override
public Object fromByteArray(Slice fragment)
{
 final Input input = new Input(fragment.buffer, fragment.offset, fragment.length);
 try {
  return kryo.readClassAndObject(input);
 } finally {
  input.close();
 }
}

代码示例来源：origin: net.dempsy/dempsy-serialization.kryo

@Override
  public void close() {
    output.close();
    input.close();
    input.setBuffer(park); // clean input
    output.setBuffer(park, Integer.MAX_VALUE); // clear output
    kryopool.offer(this);
  }
}