computer-test/src/main/java/org/apache/hugegraph/computer/core/io/StreamGraphOutputInputTest.java [68:93]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        );
        ComputerContext context = ComputerContext.instance();
        GraphFactory graphFactory = context.graphFactory();

        Id longId = BytesId.of(100L);
        LongValue longValue = new LongValue(999L);
        Vertex vertex = graphFactory().createVertex(longId, longValue);
        vertex.addEdge(graphFactory.createEdge(BytesId.of(2L)));
        vertex.addEdge(graphFactory.createEdge("knows", BytesId.of(3L)));
        vertex.addEdge(graphFactory.createEdge("watch", BytesId.of(3L)));
        vertex.addEdge(graphFactory.createEdge("watch", "1111",
                                               BytesId.of(4L)));
        vertex.addEdge(graphFactory.createEdge("watch", "2222",
                                               BytesId.of(4L)));

        byte[] bytes;
        try (BytesOutput bao = IOFactory.createBytesOutput(
                               Constants.SMALL_BUF_SIZE)) {
            StreamGraphOutput output = newStreamGraphOutput(bao);
            output.writeEdges(vertex);
            bytes = bao.toByteArray();
            bytes = reweaveBytes(bytes);
        }

        try (BytesInput bai = IOFactory.createBytesInput(bytes)) {
            StreamGraphInput input = newStreamGraphInput(bai);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



computer-test/src/main/java/org/apache/hugegraph/computer/core/io/StreamGraphOutputInputTest.java [138:163]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        );
        ComputerContext context = ComputerContext.instance();
        GraphFactory graphFactory = context.graphFactory();

        Id longId = BytesId.of(100L);
        LongValue longValue = new LongValue(999L);
        Vertex vertex = graphFactory().createVertex(longId, longValue);
        vertex.addEdge(graphFactory.createEdge(BytesId.of(2L)));
        vertex.addEdge(graphFactory.createEdge("knows", BytesId.of(3L)));
        vertex.addEdge(graphFactory.createEdge("watch", BytesId.of(3L)));
        vertex.addEdge(graphFactory.createEdge("watch", "1111",
                                               BytesId.of(4L)));
        vertex.addEdge(graphFactory.createEdge("watch", "2222",
                                               BytesId.of(4L)));

        byte[] bytes;
        try (BytesOutput bao = IOFactory.createBytesOutput(
                               Constants.SMALL_BUF_SIZE)) {
            StreamGraphOutput output = newStreamGraphOutput(bao);
            output.writeEdges(vertex);
            bytes = bao.toByteArray();
            bytes = reweaveBytes(bytes);
        }

        try (BytesInput bai = IOFactory.createBytesInput(bytes)) {
            StreamGraphInput input = newStreamGraphInput(bai);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -