Method data

lang/php/lib/DataFile/AvroDataIOReader.php:157–210

* @internal Would be nice to implement data() as an iterator, I think * @returns array of data from object container. */

()

     * @returns array of data from object container.
     */
    public function data()
    {
        $data = [];
        $decoder = $this->decoder;
        while (true) {
            if (0 == $this->block_count) {
                if ($this->isEof()) {
                    break;
                }

                if ($this->skipSync()) {
                    if ($this->isEof()) {
                        break;
                    }
                }

                $length = $this->readBlockHeader();
                if ($this->codec == AvroDataIO::DEFLATE_CODEC) {
                    $compressed = $decoder->read($length);
                    $datum = gzinflate($compressed);
                    $decoder = new AvroIOBinaryDecoder(new AvroStringIO($datum));
                } elseif ($this->codec === AvroDataIO::ZSTANDARD_CODEC) {
                    if (!extension_loaded('zstd')) {
                        throw new AvroException('Please install ext-zstd to use zstandard compression.');
                    }
                    $compressed = $decoder->read($length);
                    $datum = zstd_uncompress($compressed);
                    $decoder = new AvroIOBinaryDecoder(new AvroStringIO($datum));
                } elseif ($this->codec === AvroDataIO::SNAPPY_CODEC) {
                    if (!extension_loaded('snappy')) {
                        throw new AvroException('Please install ext-snappy to use snappy compression.');
                    }
                    $compressed = $decoder->read($length);
                    $crc32 = unpack('N', substr($compressed, -4))[1];
                    $datum = snappy_uncompress(substr($compressed, 0, -4));
                    if ($crc32 === crc32($datum)) {
                        $decoder = new AvroIOBinaryDecoder(new AvroStringIO($datum));
                    } else {
                        $decoder = new AvroIOBinaryDecoder(new AvroStringIO(snappy_uncompress($datum)));
                    }
                } elseif ($this->codec === AvroDataIO::BZIP2_CODEC) {
                    if (!extension_loaded('bz2')) {
                        throw new AvroException('Please install ext-bz2 to use bzip2 compression.');
                    }
                    $compressed = $decoder->read($length);
                    $datum = bzdecompress($compressed);
                    $decoder = new AvroIOBinaryDecoder(new AvroStringIO($datum));
                }
            }
            $data[] = $this->datum_reader->read($decoder);
            --$this->block_count;
        }
        return $data;
    }

    /**
     * @uses AvroIO::isEof()