Examples of ChunkEncoder

com.ning.compress.lzf.ChunkEncoder
Class that handles actual encoding of individual chunks. Resulting chunks can be compressed or non-compressed; compression is only used if it actually reduces chunk size (including overhead of additional header bytes)
Note that instances are stateful and hence not thread-safe; one instance is meant to be used for processing a sequence of chunks where total length is known. @author Tatu Saloranta (tatu.saloranta@iki.fi)
org.apache.accumulo.core.file.rfile.bcfile.Chunk.ChunkEncoder
org.apache.hadoop.io.file.tfile.Chunk.ChunkEncoder
org.apache.hadoop.zebra.tfile.Chunk.ChunkEncoder
org.apache.http.impl.nio.codecs.ChunkEncoder
org.apache.http.nio.impl.codecs.ChunkEncoder
org.elasticsearch.common.compress.lzf.ChunkEncoder
Class that handles actual encoding of individual chunks. Resulting chunks can be compressed or non-compressed; compression is only used if it actually reduces chunk size (including overhead of additional header bytes) @author tatu@ning.com

Examples of org.apache.hadoop.io.file.tfile.Chunk.ChunkEncoder

      // unknown length
      if (length < 0) {
        if (valueBuffer == null) {
          valueBuffer = new byte[getChunkBufferSize(conf)];
        }
        ret = new ValueRegister(new ChunkEncoder(blkAppender, valueBuffer));
      } else {
        ret =
            new ValueRegister(new Chunk.SingleChunkEncoder(blkAppender, length));
      }

View Full Code Here

Examples of org.apache.hadoop.io.file.tfile.Chunk.ChunkEncoder

      // unknown length
      if (length < 0) {
        if (valueBuffer == null) {
          valueBuffer = new byte[getChunkBufferSize(conf)];
        }
        ret = new ValueRegister(new ChunkEncoder(blkAppender, valueBuffer));
      } else {
        ret =
            new ValueRegister(new Chunk.SingleChunkEncoder(blkAppender, length));
      }

View Full Code Here

Examples of org.apache.hadoop.io.file.tfile.Chunk.ChunkEncoder

      // unknown length
      if (length < 0) {
        if (valueBuffer == null) {
          valueBuffer = new byte[getChunkBufferSize(conf)];
        }
        ret = new ValueRegister(new ChunkEncoder(blkAppender, valueBuffer));
      } else {
        ret =
            new ValueRegister(new Chunk.SingleChunkEncoder(blkAppender, length));
      }

View Full Code Here

Examples of org.apache.hadoop.io.file.tfile.Chunk.ChunkEncoder

      // unknown length
      if (length < 0) {
        if (valueBuffer == null) {
          valueBuffer = new byte[getChunkBufferSize(conf)];
        }
        ret = new ValueRegister(new ChunkEncoder(blkAppender, valueBuffer));
      } else {
        ret =
            new ValueRegister(new Chunk.SingleChunkEncoder(blkAppender, length));
      }

View Full Code Here

Examples of org.apache.hadoop.io.file.tfile.Chunk.ChunkEncoder

      // unknown length
      if (length < 0) {
        if (valueBuffer == null) {
          valueBuffer = new byte[getChunkBufferSize(conf)];
        }
        ret = new ValueRegister(new ChunkEncoder(blkAppender, valueBuffer));
      } else {
        ret =
            new ValueRegister(new Chunk.SingleChunkEncoder(blkAppender, length));
      }

View Full Code Here

Examples of org.apache.hadoop.zebra.tfile.Chunk.ChunkEncoder

      // unknown length
      if (length < 0) {
        if (valueBuffer == null) {
          valueBuffer = new byte[getChunkBufferSize(conf)];
        }
        ret = new ValueRegister(new ChunkEncoder(blkAppender, valueBuffer));
      } else {
        ret =
            new ValueRegister(new Chunk.SingleChunkEncoder(blkAppender, length));
      }

View Full Code Here

Examples of org.apache.hadoop.zebra.tfile.Chunk.ChunkEncoder

      // unknown length
      if (length < 0) {
        if (valueBuffer == null) {
          valueBuffer = new byte[getChunkBufferSize(conf)];
        }
        ret = new ValueRegister(new ChunkEncoder(blkAppender, valueBuffer));
      } else {
        ret =
            new ValueRegister(new Chunk.SingleChunkEncoder(blkAppender, length));
      }

View Full Code Here

Examples of org.apache.http.impl.nio.codecs.ChunkEncoder

    }


    protected void prepareEncoder(final HttpMessage message) throws HttpException {
        long len = this.outgoingContentStrategy.determineLength(message);
        if (len == ContentLengthStrategy.CHUNKED) {
            this.contentEncoder = new ChunkEncoder(
                    this.session.channel(),
                    this.outbuf,
                    this.outTransportMetrics);
        } else if (len == ContentLengthStrategy.IDENTITY) {
            this.contentEncoder = new IdentityEncoder(

View Full Code Here

Examples of org.apache.http.impl.nio.codecs.ChunkEncoder

            final long len,
            final WritableByteChannel channel,
            final SessionOutputBuffer buffer,
            final HttpTransportMetricsImpl metrics) {
        if (len == ContentLengthStrategy.CHUNKED) {
            return new ChunkEncoder(channel, buffer, metrics);
        } else if (len == ContentLengthStrategy.IDENTITY) {
            return new IdentityEncoder(channel, buffer, metrics);
        } else {
            return new LengthDelimitedEncoder(channel, buffer, metrics, len);
        }

View Full Code Here

Examples of org.apache.http.impl.nio.codecs.ChunkEncoder

    }


    protected void prepareEncoder(final HttpMessage message) throws HttpException {
        long len = this.outgoingContentStrategy.determineLength(message);
        if (len == ContentLengthStrategy.CHUNKED) {
            this.contentEncoder = new ChunkEncoder(this.outbuf);
        } else if (len == ContentLengthStrategy.IDENTITY) {
            this.contentEncoder = new IdentityEncoder(this.session.channel());
        } else {
            this.contentEncoder = new LengthDelimitedEncoder(this.session.channel(), len);
        }

View Full Code Here

0 1 2 3

TOP

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.