public static ElasticSearchConnection getConnection(Map stormConf,
            String boltType) {
    """
	Creates a connection with a default listener. The values for bolt type
	are [indexer,status,metrics]
    """
        BulkProcessor.Listener listener = new BulkProcessor.Listener() {
            @Override
            public void afterBulk(long arg0, BulkRequest arg1, BulkResponse arg2) {
            }

            @Override
            public void afterBulk(long arg0, BulkRequest arg1, Throwable arg2) {
            }

            @Override
            public void beforeBulk(long arg0, BulkRequest arg1) {
            }
        };
        return getConnection(stormConf, boltType, listener);
    }
public static ElasticSearchConnection getConnection(Map stormConf,
            String boltType) {
        BulkProcessor.Listener listener = new BulkProcessor.Listener() {
            @Override
            public void afterBulk(long arg0, BulkRequest arg1, BulkResponse arg2) {
            }

            @Override
            public void afterBulk(long arg0, BulkRequest arg1, Throwable arg2) {
            }

            @Override
            public void beforeBulk(long arg0, BulkRequest arg1) {
            }
        };
        return getConnection(stormConf, boltType, listener);
    }
public static ElasticSearchConnection getConnection ( Map stormConf , String boltType ) { BulkProcessor . Listener listener = new BulkProcessor . Listener ( ) { @ Override public void afterBulk ( long arg0 , BulkRequest arg1 , BulkResponse arg2 ) { } @ Override public void afterBulk ( long arg0 , BulkRequest arg1 , Throwable arg2 ) { } @ Override public void beforeBulk ( long arg0 , BulkRequest arg1 ) { } } ; return getConnection ( stormConf , boltType , listener ) ; }
Creates a connection with a default listener. The values for bolt type
are [indexer,status,metrics]
Creates a connection with a default listener . The values for bolt type are [ indexer status metrics ]