public static ParquetWriterFactory < GenericRecord > forGenericRecord ( Schema schema ) { final String schemaString = schema . toString ( ) ; final ParquetBuilder < GenericRecord > builder = ( out ) - > createAvroParquetWriter ( schemaString , GenericData . get ( ) , out ) ; return new ParquetWriterFactory <> ( builder ) ; }
Creates a ParquetWriterFactory that accepts and writes Avro generic types . The Parquet writers will use the given schema to build and write the columnar data .