public static < T > ParquetWriterFactory < T > forReflectRecord ( Class < T > type ) { final String schemaString = ReflectData . get ( ) . getSchema ( type ) . toString ( ) ; final ParquetBuilder < T > builder = ( out ) - > createAvroParquetWriter ( schemaString , ReflectData . get ( ) , out ) ; return new ParquetWriterFactory <> ( builder ) ; }
Creates a ParquetWriterFactory for the given type . The Parquet writers will use Avro to reflectively create a schema for the type and use that schema to write the columnar data .