@Override
    public Path getDeltaFileLocation(List<String> partitionValues,
        Integer bucketId, Long minWriteId, Long maxWriteId, Integer statementId,
        Table table) throws StreamingException {
      return null;
    }
allows testing of "unexpected" errors

@throws StreamingIOFailure
streaming/src/test/org/apache/hive/streaming/TestStreaming.java