Method openFile

lang/php/lib/DataFile/AvroDataIO.php:134–167

* @param string $file_path file_path of file to open * @param string $mode one of AvroFile::READ_MODE or AvroFile::WRITE_MODE * @param string $schemaJson JSON of writer's schema * @param string $codec compression codec * @returns AvroDataIOWriter instance of AvroDataIOWriter * * @throws AvroDataIOException if $writers_schema is not provided * or if an inv

(
        $file_path,
        $mode = AvroFile::READ_MODE,
        $schemaJson = null,
        $codec = self::NULL_CODEC
    )

     *         or if an invalid $mode is given.
     */
    public static function openFile(
        $file_path,
        $mode = AvroFile::READ_MODE,
        $schemaJson = null,
        $codec = self::NULL_CODEC
    ) {
        $schema = !is_null($schemaJson)
            ? AvroSchema::parse($schemaJson) : null;

        $io = false;
        switch ($mode) {
            case AvroFile::WRITE_MODE:
                if (is_null($schema)) {
                    throw new AvroDataIOException('Writing an Avro file requires a schema.');
                }
                $file = new AvroFile($file_path, AvroFile::WRITE_MODE);
                $io = self::openWriter($file, $schema, $codec);
                break;
            case AvroFile::READ_MODE:
                $file = new AvroFile($file_path, AvroFile::READ_MODE);
                $io = self::openReader($file, $schema);
                break;
            default:
                throw new AvroDataIOException(
                    sprintf(
                        "Only modes '%s' and '%s' allowed. You gave '%s'.",
                        AvroFile::READ_MODE,
                        AvroFile::WRITE_MODE,
                        $mode
                    )
                );
        }
        return $io;
    }

    /**
     * @param AvroIO $io