Examples of com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

Package com.amazonaws.services.kinesis.connectors.elasticsearch

Examples of com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject
ElasticsearchObject defines the information needed by the ElasticsearchEmitter to properly index the record. It is to be instantiated by the ElasticsearchTransformer as the final output. Information should be passed in via the constructor during the fromClass transformation.

            String message = "Error parsing record to JSON";
            LOG.error(message, e);
            throw new IOException(message, e);
        }


        ElasticsearchObject elasticsearchObject = new ElasticsearchObject(index, type, id, source);
        elasticsearchObject.setCreate(create);


        return elasticsearchObject;
    }

View Full Code Here

TOP

Related Classes of com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

com.fasterxml.jackson.databind.ObjectMapper

samples.elasticsearch.KinesisMessageModelElasticsearchTransformer

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.