* @param mixed $datum */
($datum)
| 170 | * @param mixed $datum |
| 171 | */ |
| 172 | public function append($datum) |
| 173 | { |
| 174 | $this->datum_writer->write($datum, $this->buffer_encoder); |
| 175 | $this->block_count++; |
| 176 | |
| 177 | if ($this->buffer->length() >= AvroDataIO::SYNC_INTERVAL) { |
| 178 | $this->writeBlock(); |
| 179 | } |
| 180 | } |
| 181 | |
| 182 | /** |
| 183 | * Writes a block of data to the AvroIO object container. |