private HiveConf createHiveConf(Class<?> clazz, String metaStoreUri) {
    HiveConf conf = new HiveConf(clazz);
    if (metaStoreUri != null) {
      conf.set(MetastoreConf.ConfVars.THRIFT_URIS.getHiveName(), metaStoreUri);
    }
    return conf;
  }
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