WritableSequenceFile

public class WritableSequenceFile extends SequenceFile
  {
  protected Class<? extends Writable> writableType;

  public WritableSequenceFile( Class<? extends Writable> writableType, Fields fields )
    {
    super( fields );
    this.writableType = writableType;
    }

  @Override
  public void sinkInit( Tap tap, JobConf conf )
    {
    super.sinkInit( tap, conf );
    conf.setOutputValueClass( writableType );
    }

  @Override
  public Tuple source( Object key, Object value )
    {
    return new Tuple( value );
    }

  @Override
  public void sink( TupleEntry tupleEntry, OutputCollector outputCollector ) throws IOException
    {
    outputCollector.collect( Tuples.NULL, tupleEntry.getObject( getSinkFields() ) );
    }
  }