Examples of toStream()

Examples of com.orientechnologies.orient.core.serialization.OSerializableStream.toStream()

68
69
70
71
72
73
74
75
76
77
78
                throw new OSerializationException("Can't serialize the object since it's not implements the OSerializableStream interface");

      OSerializableStream stream = (OSerializableStream) iValue;
      iOutput.append(iValue.getClass().getName());
      iOutput.append(OStreamSerializerHelper.SEPARATOR);
      iOutput.append(OBinaryProtocol.bytes2string(stream.toStream()));
    }
    return iOutput;
  }

  public String getName() {
View Full Code Here

Examples of com.orientechnologies.orient.core.serialization.serializer.record.ORecordSerializer.toStream()

108
109
110
111
112
113
114
115
116
117
118
    assertEquals(doc.fieldType("integer"), OType.INTEGER);
    assertEquals(doc.fieldType("link"), OType.LINK);
    assertEquals(doc.fieldType("string"), OType.STRING);
    assertEquals(doc.fieldType("binary"), OType.BINARY);
    ORecordSerializer ser = ODatabaseDocumentTx.getDefaultSerializer();
    byte[] bytes = ser.toStream(doc, false);
    doc = new ODocument();
    ser.fromStream(bytes, doc, null);
    assertEquals(doc.fieldType("integer"), OType.INTEGER);
    assertEquals(doc.fieldType("string"), OType.STRING);
    assertEquals(doc.fieldType("binary"), OType.BINARY);
View Full Code Here

Examples of com.orientechnologies.orient.core.serialization.serializer.stream.OStreamSerializer.toStream()

677
678
679
680
681
682
683
684
685
686
687
    final OMemoryStream outStream = new OMemoryStream(outBuffer);
    try {
      outStream.jump(offset);

      for (int i = 0; i < oldSize; ++i)
        outStream.set(valueSerializer.toStream(oldValues[i]));

      return outStream.toByteArray();

    } finally {
      outStream.close();
View Full Code Here

Examples of com.orientechnologies.orient.core.serialization.serializer.string.OStringBuilderSerializable.toStream()

440
441
442
443
444
445
446
447
448
449
450
          iRecord.field(iName, coll);
      } else
        // LAZY SET
        coll = (OStringBuilderSerializable) iValue;

      coll.toStream(iOutput);

      PROFILER.stopChrono(PROFILER.getProcessMetric("serializer.record.string.linkSet2string"), "Serialize linkset to string",
          timer);
      break;
    }
View Full Code Here

Examples of com.sun.mail.util.SharedByteArrayOutputStream.toStream()

812
813
814
815
816
817
818
819
820
821
822
      } catch (IOException cex) { }
      throw iioex;
  }
  if (b < 0)
      throw new EOFException("EOF on socket");
  return buf.toStream();
    }

    /**
     * Temporarily turn off protocol tracing, e.g., to prevent
     * tracing the authentication sequence, including the password.
View Full Code Here

Examples of edu.byu.ece.rapidSmith.bitstreamTools.bitstream.Bitstream.toStream()

83
84
85
86
87
88
89
90
91
92
93
      System.out.println(bitstream.toXMLString());
      System.exit(1);     
    }
    // Print full bitstream
    PrintWriter pw = new PrintWriter(System.out);
    bitstream.toStream(true, true, pw);
    pw.flush();
    pw.close();       
    }

 
View Full Code Here

Examples of org.fcrepo.server.storage.types.TupleArrayTripleIterator.toStream()

264
265
266
267
268
269
270
271
272
273
274
            TupleArrayTripleIterator iter =
                    new TupleArrayTripleIterator(new ArrayList<RelationshipTuple>(Arrays
                            .asList(tuples)));
            ByteArrayOutputStream os = new ByteArrayOutputStream();
            try {
                iter.toStream(os, RDFFormat.NOTATION_3, false);
            } catch (TrippiException e) {
                e.printStackTrace();
            }
            term = new String(os.toByteArray());
        } else if (javaType != null && javaType.equals("java.lang.String")) {
View Full Code Here

Examples of org.fcrepo.server.utilities.FilteredTripleIterator.toStream()

289
290
291
292
293
294
295
296
297
298
299
            map.put(RDF.prefix, RDF.uri);

            try {
                TripleIterator triples =
                        new FilteredTripleIterator(map, toAdd, true);
                triples.toStream(out, RDFFormat.RDF_XML, false);
            } catch (TrippiException e) {
                throw new GeneralException(e.getMessage(), e);
            }

            dsxml = new XMLDatastreamProcessor(dsId);
View Full Code Here

Examples of org.trippi.TripleIterator.toStream()

289
290
291
292
293
294
295
296
297
298
299
            map.put(RDF.prefix, RDF.uri);

            try {
                TripleIterator triples =
                        new FilteredTripleIterator(map, toAdd, true);
                triples.toStream(out, RDFFormat.RDF_XML, false);
            } catch (TrippiException e) {
                throw new GeneralException(e.getMessage(), e);
            }

            dsxml = new XMLDatastreamProcessor(dsId);
View Full Code Here

Examples of storm.trident.fluent.GroupedStream.toStream()

209
210
211
212
213
214
215
216
217
218
219
        List<Fields> fullGroupFields = new ArrayList<Fields>();
        for(int i=0; i<groupedStreams.size(); i++) {
            GroupedStream gs = groupedStreams.get(i);
            Fields groupFields = gs.getGroupFields();
            fullGroupFields.add(groupFields);
            streams.add(gs.toStream().partitionBy(groupFields));
            fullInputFields.add(TridentUtils.fieldsUnion(groupFields, inputFields.get(i)));
           
        }
        return multiReduce(fullInputFields, streams, new GroupedMultiReducerExecutor(function, fullGroupFields, inputFields), outputFields);
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.