class PutHiveStreaming extends AbstractHiveAnalyzer {

    @Override
    public DataSetRefs analyze(AnalysisContext context, ProvenanceEventRecord event) {

        final URI uri = parseUri(event.getTransitUri());
        final String clusterName = context.getClusterResolver().fromHostNames(uri.getHost());
        final Set<Tuple<String, String>> outputTables = parseTableNames(null, event.getAttribute(ATTR_OUTPUT_TABLES));
        if (outputTables.isEmpty()) {
            return null;
        }

        final DataSetRefs refs = new DataSetRefs(event.getComponentId());
        outputTables.forEach(tableName -> {
            final Referenceable ref = createTableRef(clusterName, tableName);
            refs.addOutput(ref);
        });
        return refs;
    }

}