Examples of 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.

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

            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

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.