本文整理了Java中org.apache.tinkerpop.shaded.kryo.io.Output.writeInt()
方法的一些代码示例,展示了Output.writeInt()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Output.writeInt()
方法的具体详情如下:
包路径:org.apache.tinkerpop.shaded.kryo.io.Output
类名称:Output
方法名:writeInt
暂无
代码示例来源:origin: JanusGraph/janusgraph
@Override
public void write(Kryo kryo, Output output, P p) {
output.writeString(
p instanceof ConnectiveP ? (p instanceof AndP ? "and" : "or") : p.getBiPredicate().toString());
if (p instanceof ConnectiveP || p.getValue() instanceof Collection) {
output.writeByte((byte) 0);
final Collection<?> coll = p instanceof ConnectiveP ? ((ConnectiveP<?>) p).getPredicates()
: (Collection) p.getValue();
output.writeInt(coll.size());
coll.forEach(v -> kryo.writeClassAndObject(output, v));
} else {
output.writeByte((byte) 1);
kryo.writeClassAndObject(output, p.getValue());
}
}
代码示例来源:origin: apache/tinkerpop
@Override
public void writeInt(final int i) {
shadedOutput.writeInt(i);
}
代码示例来源:origin: hugegraph/hugegraph
private static void writeEntry(Kryo kryo,
Output output,
Map<HugeKeys, Object> schema) {
/* Write columns size and data */
output.writeInt(schema.keySet().size());
for (Map.Entry<HugeKeys, Object> entry : schema.entrySet()) {
kryo.writeObject(output, entry.getKey());
kryo.writeClassAndObject(output, entry.getValue());
}
}
代码示例来源:origin: apache/tinkerpop
@Override
public void write(final Kryo kryo, final Output output, final TinkerGraph graph) {
try (final ByteArrayOutputStream stream = new ByteArrayOutputStream()) {
GryoWriter.build().mapper(() -> kryo).create().writeGraph(stream, graph);
final byte[] bytes = stream.toByteArray();
output.writeInt(bytes.length);
output.write(bytes);
} catch (Exception io) {
throw new RuntimeException(io);
}
}
代码示例来源:origin: apache/tinkerpop
@Override
public void write(final Kryo kryo, final Output output, final TinkerGraph graph) {
try (final ByteArrayOutputStream stream = new ByteArrayOutputStream()) {
GryoWriter.build().mapper(() -> kryo).create().writeGraph(stream, graph);
final byte[] bytes = stream.toByteArray();
output.writeInt(bytes.length);
output.write(bytes);
} catch (Exception io) {
throw new RuntimeException(io);
}
}
代码示例来源:origin: apache/tinkerpop
@Override
public void write(final Kryo kryo, final Output output, final TinkerGraph graph) {
try (final ByteArrayOutputStream stream = new ByteArrayOutputStream()) {
GryoWriter.build().mapper(() -> kryo).create().writeGraph(stream, graph);
final byte[] bytes = stream.toByteArray();
output.writeInt(bytes.length);
output.write(bytes);
} catch (Exception io) {
throw new RuntimeException(io);
}
}
代码示例来源:origin: org.apache.tinkerpop/gremlin-core
@Override
public void writeInt(final int i) {
shadedOutput.writeInt(i);
}
代码示例来源:origin: com.baidu.hugegraph/hugegraph-core
private static void writeEntry(Kryo kryo,
Output output,
Map<HugeKeys, Object> schema) {
/* Write columns size and data */
output.writeInt(schema.keySet().size());
for (Map.Entry<HugeKeys, Object> entry : schema.entrySet()) {
kryo.writeObject(output, entry.getKey());
kryo.writeClassAndObject(output, entry.getValue());
}
}
代码示例来源:origin: org.apache.tinkerpop/tinkergraph-gremlin
@Override
public void write(final Kryo kryo, final Output output, final TinkerGraph graph) {
try (final ByteArrayOutputStream stream = new ByteArrayOutputStream()) {
GryoWriter.build().mapper(() -> kryo).create().writeGraph(stream, graph);
final byte[] bytes = stream.toByteArray();
output.writeInt(bytes.length);
output.write(bytes);
} catch (Exception io) {
throw new RuntimeException(io);
}
}
代码示例来源:origin: io.shiftleft/tinkergraph-gremlin
@Override
public void write(final Kryo kryo, final Output output, final TinkerGraph graph) {
try (final ByteArrayOutputStream stream = new ByteArrayOutputStream()) {
GryoWriter.build().mapper(() -> kryo).create().writeGraph(stream, graph);
final byte[] bytes = stream.toByteArray();
output.writeInt(bytes.length);
output.write(bytes);
} catch (Exception io) {
throw new RuntimeException(io);
}
}
代码示例来源:origin: org.apache.tinkerpop/tinkergraph-gremlin
@Override
public void write(final Kryo kryo, final Output output, final TinkerGraph graph) {
try (final ByteArrayOutputStream stream = new ByteArrayOutputStream()) {
GryoWriter.build().mapper(() -> kryo).create().writeGraph(stream, graph);
final byte[] bytes = stream.toByteArray();
output.writeInt(bytes.length);
output.write(bytes);
} catch (Exception io) {
throw new RuntimeException(io);
}
}
代码示例来源:origin: org.apache.tinkerpop/tinkergraph-gremlin
@Override
public void write(final Kryo kryo, final Output output, final TinkerGraph graph) {
try (final ByteArrayOutputStream stream = new ByteArrayOutputStream()) {
GryoWriter.build().mapper(() -> kryo).create().writeGraph(stream, graph);
final byte[] bytes = stream.toByteArray();
output.writeInt(bytes.length);
output.write(bytes);
} catch (Exception io) {
throw new RuntimeException(io);
}
}
代码示例来源:origin: io.shiftleft/tinkergraph-gremlin
@Override
public void write(final Kryo kryo, final Output output, final TinkerGraph graph) {
try (final ByteArrayOutputStream stream = new ByteArrayOutputStream()) {
GryoWriter.build().mapper(() -> kryo).create().writeGraph(stream, graph);
final byte[] bytes = stream.toByteArray();
output.writeInt(bytes.length);
output.write(bytes);
} catch (Exception io) {
throw new RuntimeException(io);
}
}
代码示例来源:origin: io.shiftleft/tinkergraph-gremlin
@Override
public void write(final Kryo kryo, final Output output, final TinkerGraph graph) {
try (final ByteArrayOutputStream stream = new ByteArrayOutputStream()) {
GryoWriter.build().mapper(() -> kryo).create().writeGraph(stream, graph);
final byte[] bytes = stream.toByteArray();
output.writeInt(bytes.length);
output.write(bytes);
} catch (Exception io) {
throw new RuntimeException(io);
}
}
代码示例来源:origin: pietermartin/sqlg
@Override
public void write(Kryo kryo, Output output) {
output.writeString(this.getSchemaTable().getSchema());
output.writeString(this.getSchemaTable().getTable());
if (hasSequenceId()) {
output.writeString("s");
output.writeLong(this.getID().sequenceId);
} else {
output.writeString("i");
output.writeInt(getIdentifiers().size());
for (Comparable identifier : getIdentifiers()) {
output.writeString((CharSequence) identifier);
}
}
}
代码示例来源:origin: org.umlg/sqlg-core
@Override
public void write(Kryo kryo, Output output) {
output.writeString(this.getSchemaTable().getSchema());
output.writeString(this.getSchemaTable().getTable());
if (hasSequenceId()) {
output.writeString("s");
output.writeLong(this.getID().sequenceId);
} else {
output.writeString("i");
output.writeInt(getIdentifiers().size());
for (Comparable identifier : getIdentifiers()) {
output.writeString((CharSequence) identifier);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!