org.apache.streams.elasticsearch

Class ElasticsearchMetadataUtil

java.lang.Object

org.apache.streams.elasticsearch.ElasticsearchMetadataUtil

public class ElasticsearchMetadataUtil
extends Object

Utility class for handling Elasticsearch Metadata maps.

Constructor Summary

Constructors

Constructor and Description
ElasticsearchMetadataUtil()

Method Summary

Modifier and Type	Method and Description
static Map<String,Object>	asMap(com.fasterxml.jackson.databind.JsonNode node) get JsonNode as Map.
static String	getId(Map<String,Object> metadata) get id to use based on supplied parameters.
static String	getId(StreamsDatum datum) get id to use based on supplied parameters.
static String	getIndex(Map<String,Object> metadata, ElasticsearchReaderConfiguration config) get Index to use based on supplied parameters.
static String	getIndex(Map<String,Object> metadata, ElasticsearchWriterConfiguration config) get Index to use based on supplied parameters.
static String	getType(Map<String,Object> metadata, ElasticsearchReaderConfiguration config) get Type to use based on supplied parameters.
static String	getType(Map<String,Object> metadata, ElasticsearchWriterConfiguration config) get Type to use based on supplied parameters.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ElasticsearchMetadataUtil

public ElasticsearchMetadataUtil()

Method Detail

getIndex

public static String getIndex(Map<String,Object> metadata,
                              ElasticsearchWriterConfiguration config)

get Index to use based on supplied parameters.

Parameters:

metadata - metadata

config - config

Returns:

result

getIndex

public static String getIndex(Map<String,Object> metadata,
                              ElasticsearchReaderConfiguration config)

get Index to use based on supplied parameters.

Parameters:

metadata - metadata

config - config

Returns:

result

getType

public static String getType(Map<String,Object> metadata,
                             ElasticsearchWriterConfiguration config)

get Type to use based on supplied parameters.

Parameters:

metadata - metadata

config - config

Returns:

result

getType

public static String getType(Map<String,Object> metadata,
                             ElasticsearchReaderConfiguration config)

get Type to use based on supplied parameters.

Parameters:

metadata - metadata

config - config

Returns:

result

getId

public static String getId(StreamsDatum datum)

get id to use based on supplied parameters.

Parameters:

datum - datum

Returns:

result

getId

public static String getId(Map<String,Object> metadata)

get id to use based on supplied parameters.

Parameters:

metadata - metadata

Returns:

result

asMap

public static Map<String,Object> asMap(com.fasterxml.jackson.databind.JsonNode node)

get JsonNode as Map.

Parameters:

node - node

Returns:

result