本文整理了Java中java.io.DataInputStream.readLong()
方法的一些代码示例,展示了DataInputStream.readLong()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。DataInputStream.readLong()
方法的具体详情如下:
包路径:java.io.DataInputStream
类名称:DataInputStream
方法名:readLong
[英]See the general contract of the readLong
method of DataInput
.
Bytes for this operation are read from the contained input stream.
[中]参见readLong
方法DataInput
的总合同。
此操作的字节从包含的输入流中读取。
代码示例来源:origin: apache/geode
public AuthIds(byte[] bytes) throws Exception {
DataInputStream dis = new DataInputStream(new ByteArrayInputStream(bytes));
if (bytes.length == 8) {
// only connectionid
connectionId = dis.readLong();
} else if (bytes.length == 16) {
// first connectionId and then uniqueID
connectionId = dis.readLong();
uniqueId = dis.readLong();
} else {
throw new Exception("Auth ids are not in right form");
}
}
代码示例来源:origin: apache/incubator-pinot
private void loadCreationMeta(File crcFile)
throws IOException {
if (crcFile.exists()) {
final DataInputStream ds = new DataInputStream(new FileInputStream(crcFile));
_crc = ds.readLong();
_creationTime = ds.readLong();
ds.close();
}
}
代码示例来源:origin: apache/nifi
private String readUUID(final DataInputStream in, final int serializationVersion) throws IOException {
if (serializationVersion < 8) {
final long msb = in.readLong();
final long lsb = in.readLong();
return new UUID(msb, lsb).toString();
} else {
// before version 8, we serialized UUID's as two longs in order to
// write less data. However, in version 8 we changed to just writing
// out the string because it's extremely expensive to call UUID.fromString.
// In the end, since we generally compress, the savings in minimal anyway.
final String uuid = in.readUTF();
if (!UUID_PATTERN.matcher(uuid).matches()) {
throw new IOException("Failed to parse Provenance Event Record: expected a UUID but got: " + uuid);
}
return uuid;
}
}
代码示例来源:origin: addthis/stream-lib
public static QDigest deserialize(byte[] b) {
ByteArrayInputStream bis = new ByteArrayInputStream(b);
DataInputStream s = new DataInputStream(bis);
try {
long size = s.readLong();
double compressionFactor = s.readDouble();
long capacity = s.readLong();
int count = s.readInt();
QDigest d = new QDigest(compressionFactor);
d.size = size;
d.capacity = capacity;
for (int i = 0; i < count; ++i) {
long k = s.readLong();
long n = s.readLong();
d.node2count.put(k, n);
}
return d;
} catch (IOException e) {
throw new RuntimeException(e);
}
}
代码示例来源:origin: aNNiMON/Lightweight-Stream-API
@Test
public void testSafeWithOnFailedConsumer() throws IOException {
final ByteArrayOutputStream baos = new ByteArrayOutputStream(30);
final DataOutputStream dos = new DataOutputStream(baos);
LongConsumer consumer = LongConsumer.Util.safe(new UnsafeConsumer(dos), new LongConsumer() {
@Override
public void accept(long value) {
baos.write(0);
}
});
consumer.accept(10L);
consumer.accept(20L);
consumer.accept(-5L);
consumer.accept(-8L);
consumer.accept(500L);
final byte[] result = baos.toByteArray();
DataInputStream dis = new DataInputStream(new ByteArrayInputStream(result));
assertThat(dis.readLong(), is(10L));
assertThat(dis.readLong(), is(20L));
assertThat(dis.readByte(), is((byte) 0));
assertThat(dis.readByte(), is((byte) 0));
assertThat(dis.readLong(), is(500L));
}
代码示例来源:origin: RoaringBitmap/RoaringBitmap
private long[][] deserialize(final String bitsetResource) throws IOException {
final DataInputStream dos = new DataInputStream(
new GZIPInputStream(this.getClass().getResourceAsStream(bitsetResource)));
try {
final long[][] bitset = new long[dos.readInt()][];
for (int i = 0; i < bitset.length; i++) {
final int wordSize = dos.readInt();
// for duplication, to make bitsets wider
final int clone = 0;
final long words[] = new long[wordSize * (clone + 1)];
for (int j = 0; j < wordSize; j++) {
words[j] = dos.readLong();
}
// duplicate long[] n times to the right
for (int j = 0; j < clone; j++) {
System.arraycopy(words, 0, words, (j + 1) * wordSize, wordSize);
}
bitset[i] = words;
}
return bitset;
} finally {
if (dos != null) {
dos.close();
}
}
}
}
代码示例来源:origin: apache/nifi
@Override
public SwapSummary getSwapSummary(final DataInputStream in, final String swapLocation, final ResourceClaimManager claimManager) throws IOException {
final int swapEncodingVersion = in.readInt();
if (swapEncodingVersion > SWAP_ENCODING_VERSION) {
final String errMsg = "Cannot swap FlowFiles in from " + swapLocation + " because the encoding version is "
+ swapEncodingVersion + ", which is too new (expecting " + SWAP_ENCODING_VERSION + " or less)";
throw new IOException(errMsg);
}
final int numRecords;
final long contentSize;
Long maxRecordId = null;
try {
in.readUTF(); // ignore Connection ID
numRecords = in.readInt();
contentSize = in.readLong();
if (numRecords == 0) {
return StandardSwapSummary.EMPTY_SUMMARY;
}
if (swapEncodingVersion > 7) {
maxRecordId = in.readLong();
}
} catch (final EOFException eof) {
logger.warn("Found premature End-of-File when reading Swap File {}. EOF occurred before any FlowFiles were encountered", swapLocation);
return StandardSwapSummary.EMPTY_SUMMARY;
}
final QueueSize queueSize = new QueueSize(numRecords, contentSize);
final SwapContents swapContents = deserializeFlowFiles(in, queueSize, maxRecordId, swapEncodingVersion, claimManager, swapLocation);
return swapContents.getSummary();
}
代码示例来源:origin: robovm/robovm
Class<?> type = element.field.getType();
if (type == int.class) {
element.fieldValue = input.readInt();
} else if (type == byte.class) {
element.fieldValue = input.readByte();
} else if (type == char.class) {
element.fieldValue = input.readChar();
element.fieldValue = input.readBoolean();
} else if (type == long.class) {
element.fieldValue = input.readLong();
} else if (type == float.class) {
element.fieldValue = input.readFloat();
代码示例来源:origin: apache/incubator-gobblin
DataInputStream dis = new DataInputStream(new FileInputStream(outputFile));
for (int i = 0; i < 3; i++) {
long size = dis.readLong();
Assert.assertEquals(size, records[i].length + 1);
for (int j = 0; j < size - 1; j++) {
Assert.assertEquals(dis.readByte(), records[i][j]);
Assert.assertEquals(dis.readByte(), '\n');
代码示例来源:origin: wildfly/wildfly
boolean handleRequest(DataInputStream in, DataOutputStream out) throws IOException {
while(true) {
byte type=(byte)in.read();
if(type == -1)
return false;
switch(type) {
case START:
int num=in.readInt();
startTest(num);
break;
case RECEIVE_ASYNC:
case RECEIVE_SYNC:
long val=in.readLong();
int len=in.readInt();
byte data[]=new byte[len];
in.readFully(data, 0, data.length);
receiveData(val, data);
if(type == RECEIVE_SYNC) {
out.writeLong(System.currentTimeMillis());
out.flush();
}
break;
default:
System.err.println("type " + type + " not known");
}
}
}
代码示例来源:origin: deeplearning4j/nd4j
String compressionAlgorithm = s.readUTF();
long compressedLength = s.readLong();
long originalLength = s.readLong();
long numberOfElements = s.readLong();
temp[i] = s.readByte();
代码示例来源:origin: libgdx/libgdx
protected long parseSize (final DataInputStream din, final byte type, final boolean useIntOnError, final long defaultValue)
throws IOException {
if (type == 'i') return (long)readUChar(din);
if (type == 'I') return (long)readUShort(din);
if (type == 'l') return (long)readUInt(din);
if (type == 'L') return din.readLong();
if (useIntOnError) {
long result = (long)((short)type & 0xFF) << 24;
result |= (long)((short)din.readByte() & 0xFF) << 16;
result |= (long)((short)din.readByte() & 0xFF) << 8;
result |= (long)((short)din.readByte() & 0xFF);
return result;
}
return defaultValue;
}
代码示例来源:origin: addthis/stream-lib
public static CountMinSketch deserialize(byte[] data) {
ByteArrayInputStream bis = new ByteArrayInputStream(data);
DataInputStream s = new DataInputStream(bis);
try {
CountMinSketch sketch = new CountMinSketch();
sketch.size = s.readLong();
sketch.depth = s.readInt();
sketch.width = s.readInt();
sketch.eps = 2.0 / sketch.width;
sketch.confidence = 1 - 1 / Math.pow(2, sketch.depth);
sketch.hashA = new long[sketch.depth];
sketch.table = new long[sketch.depth][sketch.width];
for (int i = 0; i < sketch.depth; ++i) {
sketch.hashA[i] = s.readLong();
for (int j = 0; j < sketch.width; ++j) {
sketch.table[i][j] = s.readLong();
}
}
return sketch;
} catch (IOException e) {
// Shouldn't happen
throw new RuntimeException(e);
}
}
代码示例来源:origin: apache/nifi
@Override
public Long deserialize(final byte[] input) throws DeserializationException, IOException {
if ( input == null || input.length == 0 ) {
return null;
}
final DataInputStream dis = new DataInputStream(new ByteArrayInputStream(input));
return dis.readLong();
}
代码示例来源:origin: org.apache.commons/commons-compress
private StartHeader readStartHeader(final long startHeaderCrc) throws IOException {
final StartHeader startHeader = new StartHeader();
// using Stream rather than ByteBuffer for the benefit of the
// built-in CRC check
try (DataInputStream dataInputStream = new DataInputStream(new CRC32VerifyingInputStream(
new BoundedSeekableByteChannelInputStream(channel, 20), 20, startHeaderCrc))) {
startHeader.nextHeaderOffset = Long.reverseBytes(dataInputStream.readLong());
startHeader.nextHeaderSize = Long.reverseBytes(dataInputStream.readLong());
startHeader.nextHeaderCrc = 0xffffFFFFL & Integer.reverseBytes(dataInputStream.readInt());
return startHeader;
}
}
代码示例来源:origin: apache/nifi
private SnapshotHeader validateHeader(final DataInputStream dataIn) throws IOException {
final String snapshotClass = dataIn.readUTF();
logger.debug("Snapshot Class Name for {} is {}", storageDirectory, snapshotClass);
if (!snapshotClass.equals(HashMapSnapshot.class.getName())) {
throw new IOException("Write-Ahead Log Snapshot located at " + storageDirectory + " was written using the "
+ snapshotClass + " class; cannot restore using " + getClass().getName());
}
final int snapshotVersion = dataIn.readInt();
logger.debug("Snapshot version for {} is {}", storageDirectory, snapshotVersion);
if (snapshotVersion > getVersion()) {
throw new IOException("Write-Ahead Log Snapshot located at " + storageDirectory + " was written using version "
+ snapshotVersion + " of the " + snapshotClass + " class; cannot restore using Version " + getVersion());
}
final String serdeEncoding = dataIn.readUTF(); // ignore serde class name for now
logger.debug("Serde encoding for Snapshot at {} is {}", storageDirectory, serdeEncoding);
final int serdeVersion = dataIn.readInt();
logger.debug("Serde version for Snapshot at {} is {}", storageDirectory, serdeVersion);
final long maxTransactionId = dataIn.readLong();
logger.debug("Max Transaction ID for Snapshot at {} is {}", storageDirectory, maxTransactionId);
final int numRecords = dataIn.readInt();
logger.debug("Number of Records for Snapshot at {} is {}", storageDirectory, numRecords);
final SerDe<T> serde = serdeFactory.createSerDe(serdeEncoding);
serde.readHeader(dataIn);
return new SnapshotHeader(serde, serdeVersion, maxTransactionId, numRecords);
}
代码示例来源:origin: libgdx/libgdx
return new JsonValue((long)readUChar(din));
else if (type == 'i')
return new JsonValue(oldFormat ? (long)din.readShort() : (long)din.readByte());
else if (type == 'I')
return new JsonValue(oldFormat ? (long)din.readInt() : (long)din.readShort());
else if (type == 'l')
return new JsonValue((long)din.readInt());
else if (type == 'L')
return new JsonValue(din.readLong());
else if (type == 'd')
return new JsonValue(din.readFloat());
代码示例来源:origin: alibaba/Sentinel
FileInputStream in = new FileInputStream(idxFileName);
in.getChannel().position(offsetInIndex);
DataInputStream indexIn = new DataInputStream(in);
long offset;
try {
long second;
lastPosition.offsetInIndex = in.getChannel().position();
while ((second = indexIn.readLong()) < beginSecond) {
offset = indexIn.readLong();
lastPosition.offsetInIndex = in.getChannel().position();
offset = indexIn.readLong();
lastPosition.metricFileName = metricFileName;
lastPosition.indexFileName = idxFileName;
代码示例来源:origin: apache/incubator-gobblin
DataInputStream dis = new DataInputStream(new FileInputStream(outputFile));
for (int i = 0; i < 3; i++) {
long size = dis.readLong();
Assert.assertEquals(size, records[i].length);
for (int j = 0; j < size; j++) {
Assert.assertEquals(dis.readByte(), records[i][j]);
代码示例来源:origin: apache/hbase
/**
* Read the root-level metadata of a multi-level block index. Based on
* {@link #readRootIndex(DataInput, int)}, but also reads metadata
* necessary to compute the mid-key in a multi-level index.
*
* @param blk the HFile block
* @param numEntries the number of root-level index entries
* @throws IOException
*/
public void readMultiLevelIndexRoot(HFileBlock blk,
final int numEntries) throws IOException {
DataInputStream in = readRootIndex(blk, numEntries);
// after reading the root index the checksum bytes have to
// be subtracted to know if the mid key exists.
int checkSumBytes = blk.totalChecksumBytes();
if ((in.available() - checkSumBytes) < MID_KEY_METADATA_SIZE) {
// No mid-key metadata available.
return;
}
midLeafBlockOffset = in.readLong();
midLeafBlockOnDiskSize = in.readInt();
midKeyEntry = in.readInt();
}
内容来源于网络,如有侵权,请联系作者删除!