#Java - Code Snippets for '#Storm.trident.state.State'

#Java - Code Snippets for '#Storm.trident.state.State' - 1 code snippet(s) found

Sample 1. Code Sample / Example / Snippet of org.apache.storm.trident.state.StateFactory

    protected StormTopology getTopology() throws IOException {

        final TridentTopology tridentTopology = new TridentTopology();

        final SolrFieldsSpout spout = new SolrFieldsSpout();

        final Stream stream = tridentTopology.newStream("SolrFieldsSpout", spout);

        final StateFactory solrStateFactory = new SolrStateFactory(getSolrConfig(), getSolrMapper());

        stream.partitionPersist(solrStateFactory, spout.getOutputFields(),  new SolrUpdater(), new Fields());

        return tridentTopology.build();

    }

_{Like Feedback org.apache.storm.trident.state.StateFactory}

Search Java Code Snippets