org.thales.punch.libraries.storm.impl

Class CompressionHelper

java.lang.Object

org.thales.punch.libraries.storm.impl.CompressionHelper

public class CompressionHelper
extends Object

This class provides methods to compress/decompress hasn maps. We use it to enrich storm topology contexts with the resources files (grok patterns, enrichments files etc..) that are possibly big.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
CompressionHelper()

Method Summary

Modifier and Type	Method and Description
static byte[]	compress(String string)
static Map<String,Object>	compressResources(Map<String,Object> resources) Compress all the String resources.
static String	decompress(byte[] input)
static Map<String,Object>	uncompressResources(Map<String,Object> resources) Take a resource map, and if items are marked as compressed, uncompress them.

Methods inherited from class java.lang.Object

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

Constructor Detail

CompressionHelper

public CompressionHelper()

Method Detail

compressResources

public static Map<String,Object> compressResources(Map<String,Object> resources)

Compress all the String resources. Big files can be in there and they take room.

Parameters:

resources - the resources map

Returns:

a Map with compressed resources.

uncompressResources

public static Map<String,Object> uncompressResources(Map<String,Object> resources)

Take a resource map, and if items are marked as compressed, uncompress them. Compressing resources helps keeping topology jars small.

Parameters:

resources - the resource map

Returns:

a resource map with uncompressed items

compress

public static byte[] compress(String string)
                       throws IOException

Throws:

IOException

decompress

public static String decompress(byte[] input)
                         throws IOException

Throws:

IOException