StreamFactory = new StreamFactory().withDefaultZkHost(zookeeper)
        .withFunctionName("search", CloudSolrStream.class)
        .withFunctionName("select", SelectStream.class)
        .withFunctionName("merge", MergeStream.class)
        .withFunctionName("sort", SortStream.class)
        .withFunctionName("tuple", TupStream.class)
        .withFunctionName("rollup", RollupStream.class)
        .withFunctionName("hashJoin", HashJoinStream.class)
        .withFunctionName("count", CountMetric.class)
        .withFunctionName("facet", FacetStream.class)
        .withFunctionName("sum", SumMetric.class)
        .withFunctionName("unique", UniqueStream.class)
        .withFunctionName("significantTerms", SignificantTermsStream.class)
        .withFunctionName("stats", StatsStream.class)
        .withFunctionName("innerJoin", InnerJoinStream.class)
        .withFunctionName("issnMerge", IssnMergeStream.class)
        .withFunctionName("intersect", IntersectStream.class)
        .withFunctionName("boostByEra", BoostBooksByEraExpression.class)
        .withFunctionName("determineRRec", DetermineRepresentativeRecord.class)
        .withFunctionName("plist", ParallelListStream.class)
        .withFunctionName("let", LetStream.class);