lib/index.js
function createFileEncoder(path, schema, opts) {
  var encoder = new containers.streams.BlockEncoder(schema, opts);
  encoder.pipe(fs.createWriteStream(path, {defaultEncoding: 'binary'}));
  return encoder;
}
function createFileEncoder(path, schema, opts) {
  var encoder = new containers.streams.BlockEncoder(schema, opts);
  encoder.pipe(fs.createWriteStream(path, {defaultEncoding: 'binary'}));
  return encoder;
}
function createFileEncoder ( path , schema , opts ) { var encoder = new containers . streams . BlockEncoder ( schema , opts ) ; encoder . pipe ( fs . createWriteStream ( path , { defaultEncoding : 'binary' } ) ) ; return encoder ; }
Writable stream of records to a local Avro file.
Writable stream of records to a local Avro file .