@Override
    public void init(final StreamingConnection connection, final long minWriteId, final long maxWriteID)
      throws StreamingException {
      delegate.init(connection, minWriteId, maxWriteID);
    }
This is test-only wrapper around the real RecordWriter.
It can simulate faults from lower levels to test error handling logic.
streaming/src/test/org/apache/hive/streaming/TestStreaming.java