@Override protected void prepareWrite(WritableByteChannel channel) throws Exception {
  os=Channels.newOutputStream(channel);
}

@ Override protected void prepareWrite ( WritableByteChannel channel ) throws Exception { os = Channels . newOutputStream ( channel ) ; }
creates the output stream that elements will be written to .
