public RecordWriter getRecordWriter() {
    return recordWriter;
  }
Add Write notification events if it is enabled.
@throws StreamingException File operation errors or HMS errors.
streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java