org.apache.solr.common.util

Class Utils

java.lang.Object

org.apache.solr.common.util.Utils

public class Utils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Utils.InputStreamConsumer<T>

Field Summary

Fields

Modifier and Type	Field and Description
static Pattern	ARRAY_ELEMENT_INDEX
static Utils.InputStreamConsumer<?>	JAVABINCONSUMER
static Utils.InputStreamConsumer<?>	JSONCONSUMER
static Function<JSONParser,ObjectBuilder>	MAPOBJBUILDER
static Function<JSONParser,ObjectBuilder>	MAPWRITEROBJBUILDER
static Function	NEW_ARRAYLIST_FUN
static Function	NEW_ATOMICLONG_FUN
static Function	NEW_HASHMAP_FUN
static Function	NEW_HASHSET_FUN
static Function	NEW_LINKED_HASHMAP_FUN
static Function	NEW_SYNCHRONIZED_ARRAYLIST_FUN
static Function<Object,String>	OBJECT_TO_STRING Util function to convert Object to String Specially handles Date to string conversion
static Function<JSONParser,ObjectBuilder>	STANDARDOBJBUILDER

Constructor Summary

Constructors

Constructor and Description
Utils()

Method Summary

Modifier and Type	Method and Description
static void	consumeFully(org.apache.http.HttpEntity entity) If the passed entity has content, make sure it is fully read and closed.
static <T> T	executeGET(org.apache.http.client.HttpClient client, String url, Utils.InputStreamConsumer<T> consumer)
static void	forEachMapEntry(Object o, BiConsumer fun)
static void	forEachMapEntry(Object o, List<String> path, BiConsumer fun)
static void	forEachMapEntry(Object o, String path, BiConsumer fun)
static Object	fromJavabin(byte[] bytes)
static Object	fromJSON(byte[] utf8)
static Object	fromJSON(byte[] utf8, int offset, int length)
static Object	fromJSON(InputStream is)
static Object	fromJSON(InputStream is, Function<JSONParser,ObjectBuilder> objBuilderProvider)
static Object	fromJSON(Reader is)
static Object	fromJSONResource(String resourceName)
static Object	fromJSONString(String json)
static String	getBaseUrlForNodeName(String nodeName, String urlScheme)
static Collection	getDeepCopy(Collection c, int maxDepth, boolean mutable)
static Collection	getDeepCopy(Collection c, int maxDepth, boolean mutable, boolean sorted)
static Map	getDeepCopy(Map map, int maxDepth)
static Map	getDeepCopy(Map map, int maxDepth, boolean mutable)
static Map	getDeepCopy(Map map, int maxDepth, boolean mutable, boolean sorted)
static Map<String,Object>	getJson(DistribStateManager distribStateManager, String path)
static Map<String,Object>	getJson(SolrZkClient zkClient, String path, boolean retryOnConnLoss) Assumes data in ZooKeeper is a JSON string, deserializes it and returns as a Map
static JSONParser	getJSONParser(Reader reader)
static String	getMDCNode()
static Object	getObjectByPath(Object root, boolean onlyPrimitive, List<String> hierarchy)
static Object	getObjectByPath(Object root, boolean onlyPrimitive, String hierarchy)
static SpecProvider	getSpec(String name)
static <T> T	handleExp(org.slf4j.Logger logger, T def, Callable<T> c)
static Map<String,Object>	makeMap(boolean skipNulls, Object... keyVals)
static Map<String,Object>	makeMap(Object... keyVals)
static boolean	mergeJson(Map<String,Object> sink, Map<String,Object> input) Applies one json over other.
static Utils.InputStreamConsumer<ByteBuffer>	newBytesConsumer(int maxSize)
static String	parseMetricsReplicaName(String collectionName, String coreName)
static boolean	setObjectByPath(Object root, List<String> hierarchy, Object value)
static boolean	setObjectByPath(Object root, String hierarchy, Object value)
static long	time(TimeSource timeSource, TimeUnit unit)
static long	timeElapsed(TimeSource timeSource, long start, TimeUnit unit)
static InputStream	toJavabin(Object o)
static byte[]	toJSON(Object o)
static String	toJSONString(Object o)
static byte[]	toUTF8(CharArr out)
static void	writeJson(Object o, OutputStream os, boolean indent)
static Writer	writeJson(Object o, Writer writer, boolean indent)

Methods inherited from class java.lang.Object

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

Field Detail

NEW_HASHMAP_FUN

public static final Function NEW_HASHMAP_FUN

NEW_LINKED_HASHMAP_FUN

public static final Function NEW_LINKED_HASHMAP_FUN

NEW_ATOMICLONG_FUN

public static final Function NEW_ATOMICLONG_FUN

NEW_ARRAYLIST_FUN

public static final Function NEW_ARRAYLIST_FUN

NEW_SYNCHRONIZED_ARRAYLIST_FUN

public static final Function NEW_SYNCHRONIZED_ARRAYLIST_FUN

NEW_HASHSET_FUN

public static final Function NEW_HASHSET_FUN

STANDARDOBJBUILDER

public static final Function<JSONParser,ObjectBuilder> STANDARDOBJBUILDER

MAPWRITEROBJBUILDER

public static final Function<JSONParser,ObjectBuilder> MAPWRITEROBJBUILDER

MAPOBJBUILDER

public static final Function<JSONParser,ObjectBuilder> MAPOBJBUILDER

OBJECT_TO_STRING

public static final Function<Object,String> OBJECT_TO_STRING

Util function to convert Object to String Specially handles Date to string conversion

ARRAY_ELEMENT_INDEX

public static final Pattern ARRAY_ELEMENT_INDEX

JAVABINCONSUMER

public static final Utils.InputStreamConsumer<?> JAVABINCONSUMER

JSONCONSUMER

public static final Utils.InputStreamConsumer<?> JSONCONSUMER

Constructor Detail

Utils

public Utils()

Method Detail

getDeepCopy

public static Map getDeepCopy(Map map,
                              int maxDepth)

getDeepCopy

public static Map getDeepCopy(Map map,
                              int maxDepth,
                              boolean mutable)

getDeepCopy

public static Map getDeepCopy(Map map,
                              int maxDepth,
                              boolean mutable,
                              boolean sorted)

forEachMapEntry

public static void forEachMapEntry(Object o,
                                   String path,
                                   BiConsumer fun)

forEachMapEntry

public static void forEachMapEntry(Object o,
                                   List<String> path,
                                   BiConsumer fun)

forEachMapEntry

public static void forEachMapEntry(Object o,
                                   BiConsumer fun)

toJavabin

public static InputStream toJavabin(Object o)
                             throws IOException

Throws:

IOException

fromJavabin

public static Object fromJavabin(byte[] bytes)
                          throws IOException

Throws:

IOException

getDeepCopy

public static Collection getDeepCopy(Collection c,
                                     int maxDepth,
                                     boolean mutable)

getDeepCopy

public static Collection getDeepCopy(Collection c,
                                     int maxDepth,
                                     boolean mutable,
                                     boolean sorted)

writeJson

public static void writeJson(Object o,
                             OutputStream os,
                             boolean indent)
                      throws IOException

Throws:

IOException

writeJson

public static Writer writeJson(Object o,
                               Writer writer,
                               boolean indent)
                        throws IOException

Throws:

IOException

toJSON

public static byte[] toJSON(Object o)

toJSONString

public static String toJSONString(Object o)

toUTF8

public static byte[] toUTF8(CharArr out)

fromJSON

public static Object fromJSON(byte[] utf8)

fromJSON

public static Object fromJSON(byte[] utf8,
                              int offset,
                              int length)

makeMap

public static Map<String,Object> makeMap(Object... keyVals)

makeMap

public static Map<String,Object> makeMap(boolean skipNulls,
                                         Object... keyVals)

fromJSON

public static Object fromJSON(InputStream is)

fromJSON

public static Object fromJSON(Reader is)

fromJSON

public static Object fromJSON(InputStream is,
                              Function<JSONParser,ObjectBuilder> objBuilderProvider)

fromJSONResource

public static Object fromJSONResource(String resourceName)

getJSONParser

public static JSONParser getJSONParser(Reader reader)

fromJSONString

public static Object fromJSONString(String json)

getObjectByPath

public static Object getObjectByPath(Object root,
                                     boolean onlyPrimitive,
                                     String hierarchy)

setObjectByPath

public static boolean setObjectByPath(Object root,
                                      String hierarchy,
                                      Object value)

setObjectByPath

public static boolean setObjectByPath(Object root,
                                      List<String> hierarchy,
                                      Object value)

getObjectByPath

public static Object getObjectByPath(Object root,
                                     boolean onlyPrimitive,
                                     List<String> hierarchy)

consumeFully

public static void consumeFully(org.apache.http.HttpEntity entity)

If the passed entity has content, make sure it is fully read and closed.

Parameters:

entity - to consume or null

getJson

public static Map<String,Object> getJson(DistribStateManager distribStateManager,
                                         String path)
                                  throws InterruptedException,
                                         IOException,
                                         org.apache.zookeeper.KeeperException

Throws:

InterruptedException

IOException

org.apache.zookeeper.KeeperException

getJson

public static Map<String,Object> getJson(SolrZkClient zkClient,
                                         String path,
                                         boolean retryOnConnLoss)
                                  throws org.apache.zookeeper.KeeperException,
                                         InterruptedException

Assumes data in ZooKeeper is a JSON string, deserializes it and returns as a Map

Parameters:

zkClient - the zookeeper client

path - the path to the znode being read

retryOnConnLoss - whether to retry the operation automatically on connection loss, see ZkCmdExecutor.retryOperation(ZkOperation)

Returns:

a Map if the node exists and contains valid JSON or an empty map if znode does not exist or has a null data

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getSpec

public static SpecProvider getSpec(String name)

parseMetricsReplicaName

public static String parseMetricsReplicaName(String collectionName,
                                             String coreName)

mergeJson

public static boolean mergeJson(Map<String,Object> sink,
                                Map<String,Object> input)

Applies one json over other. The 'input' is applied over the sink The values in input isapplied over the values in 'sink' . If a value is 'null' that value is removed from sink

Parameters:

sink - the original json object to start with. Ensure that this Map is mutable

input - the json with new values

Returns:

whether there was any change made to sink or not.

getBaseUrlForNodeName

public static String getBaseUrlForNodeName(String nodeName,
                                           String urlScheme)

time

public static long time(TimeSource timeSource,
                        TimeUnit unit)

timeElapsed

public static long timeElapsed(TimeSource timeSource,
                               long start,
                               TimeUnit unit)

getMDCNode

public static String getMDCNode()

handleExp

public static <T> T handleExp(org.slf4j.Logger logger,
                              T def,
                              Callable<T> c)

newBytesConsumer

public static Utils.InputStreamConsumer<ByteBuffer> newBytesConsumer(int maxSize)

executeGET

public static <T> T executeGET(org.apache.http.client.HttpClient client,
                               String url,
                               Utils.InputStreamConsumer<T> consumer)
                        throws SolrException

Throws:

SolrException