Examples of toByteArray()

Examples of org.apache.tez.mapreduce.protos.MRRuntimeProtos.MRSplitProto.toByteArray()

247
248
249
250
251
252
253
254
255
256
257
    // Re-serialize the splits after grouping.
    int count = 0;
    for (InputSplit inputSplit : finalSplits) {
      MRSplitProto serializedSplit = MRHelpers.createSplitProto(inputSplit);
      RootInputDataInformationEvent diEvent = new RootInputDataInformationEvent(
          count, serializedSplit.toByteArray());
      diEvent.setTargetIndex(count);
      count++;
      taskEvents.add(diEvent);
    }
View Full Code Here

Examples of org.apache.tez.runtime.library.shuffle.impl.ShuffleUserPayloads.DataMovementEventPayloadProto.toByteArray()

129
130
131
132
133
134
135
136
137
138
139
    payloadBuilder.setHost(host);
    payloadBuilder.setPort(shufflePort);
    payloadBuilder.setPathComponent(outputContext.getUniqueIdentifier());
    payloadBuilder.setRunDuration((int) ((endTime - startTime) / 1000));
    DataMovementEventPayloadProto payloadProto = payloadBuilder.build();
    byte[] payloadBytes = payloadProto.toByteArray();

    long outputSize = outputContext.getCounters()
        .findCounter(TaskCounter.MAP_OUTPUT_BYTES).getValue();
    VertexManagerEventPayloadProto.Builder vmBuilder = VertexManagerEventPayloadProto
        .newBuilder();
View Full Code Here

Examples of org.apache.wicket.util.io.ByteArrayOutputStream.toByteArray()

174
175
176
177
178
179
180
181
182
183
184
  {
    ByteArrayOutputStream output = new ByteArrayOutputStream();
    for (IResourceStream curStream : resources)
      IOUtils.copy(curStream.getInputStream(), output);

    byte[] bytes = output.toByteArray();

    if (getCompressor() != null)
    {
      String nonCompressed = new String(bytes, "UTF-8");
      bytes = getCompressor().compress(nonCompressed).getBytes("UTF-8");
View Full Code Here

Examples of org.apache.xbean.asm.ClassWriter.toByteArray()

66
67
68
69
70
71
72
73
74
75
76
        BufferedInputStream bis = new BufferedInputStream(bais);

        ClassWriter cw = new BCClassWriter(ClassWriter.COMPUTE_FRAMES, bc.getClassLoader());
        ClassReader cr = new ClassReader(bis);
        cr.accept(cw, 0);
        return cw.toByteArray();
    }

    private static class BCClassWriter extends ClassWriter {
        private final ClassLoader _loader;
View Full Code Here

Examples of org.apache.xbean.asm4.ClassWriter.toByteArray()

90
91
92
93
94
95
96
97
98
99
100
        BufferedInputStream bis = new BufferedInputStream(bais);

        ClassWriter cw = new BCClassWriter(ClassWriter.COMPUTE_FRAMES, bc.getClassLoader());
        ClassReader cr = new ClassReader(bis);
        cr.accept(cw, 0);
        return cw.toByteArray();
    }

    private static class BCClassWriter extends ClassWriter {
        private final ClassLoader _loader;
View Full Code Here

Examples of org.apache.xbean.asm5.ClassWriter.toByteArray()

90
91
92
93
94
95
96
97
98
99
100
        BufferedInputStream bis = new BufferedInputStream(bais);

        ClassWriter cw = new BCClassWriter(ClassWriter.COMPUTE_FRAMES, bc.getClassLoader());
        ClassReader cr = new ClassReader(bis);
        cr.accept(cw, 0);
        return cw.toByteArray();
    }

    private static class BCClassWriter extends ClassWriter {
        private final ClassLoader _loader;
View Full Code Here

Examples of org.apache.xerces.utils.UTF8DataChunk.toByteArray()

393
394
395
396
397
398
399
400
401
402
403
                loadNextByte();
            } else {
                fCurrentChunk = saveChunk;
                fCurrentIndex = saveIndex;
                fCurrentOffset = saveOffset;
                fMostRecentData = saveChunk.toByteArray();
                fMostRecentByte = b0;
            }
            return true; // [#x20-#xD7FF]
        }
        int b2 = loadNextByte();
View Full Code Here

Examples of org.apache.xml.security.stax.impl.util.UnsynchronizedByteArrayOutputStream.toByteArray()

390
391
392
393
394
395
396
397
398
399
400
    @Override
    public void doFinal() throws XMLStreamException {
        if (getTransformer() != null) {
            UnsynchronizedByteArrayOutputStream baos = (UnsynchronizedByteArrayOutputStream)getOutputStream();
            getTransformer().transform(new UnsynchronizedByteArrayInputStream(baos.toByteArray()));
            getTransformer().doFinal();
        }
    }

    protected static void outputAttrToWriter(final String prefix, final String name, final String value, final OutputStream writer,
View Full Code Here

Examples of org.arch.compress.jsnappy.SnappyBuffer.toByteArray()

116
117
118
119
120
121
122
123
124
125
126
    }

    end = System.currentTimeMillis();
    SnappyBuffer resume = SnappyDecompressor.decompress(afterCompress);
    System.out.println("Snappy Decompress cost " + (end - start) + "ms");
    assertArrayEquals(cmp, resume.toByteArray());
    // Snappy.compress(uncompressed, uncompressedOffset, uncompressedLength,
    // compressed, compressedOffset)
  }

  @Test
View Full Code Here

Examples of org.bson.io.BasicOutputBuffer.toByteArray()

34
35
36
37
38
39
40
41
42
43
44
    public byte[] encode( BSONObject o ){
        BasicOutputBuffer buf = new BasicOutputBuffer();
        set( buf );
        putObject( o );
        done();
        return buf.toByteArray();
    }

    public void set( OutputBuffer out ){
        if ( _buf != null )
            throw new IllegalStateException( "in the middle of something" );
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.