org.thales.punch.libraries.punchlang.resource.builder

Class AbstractJsonResourceBuilder

java.lang.Object

org.thales.punch.libraries.punchlang.resource.builder.AbstractJsonResourceBuilder

All Implemented Interfaces:

ToIntFunction<String>, IResourceBuilder

Direct Known Subclasses:

JsonToMapInPlaceResourceBuilder, JsonToMapResourceBuilder

public abstract class AbstractJsonResourceBuilder
extends Object
implements IResourceBuilder, ToIntFunction<String>

Abstract class to load a remote JSON resource using a streaming strategy.

This class deals with the JSON streaming part and invoke the IResourceTuple.addKeyValue(String, Tuple) method for each read value.

Author:

dimi

Nested Class Summary

Nested classes/interfaces inherited from interface org.thales.punch.libraries.punchlang.api.IResourceBuilder

IResourceBuilder.CompactionType

Constructor Summary

Constructors

Constructor and Description
AbstractJsonResourceBuilder(String hashKey, boolean lowerCaseKeys) Ctor.

Method Summary

Modifier and Type	Method and Description
int	applyAsInt(String value) The callback invoked by the streaming JSON parser.
Tuple	onEnd() Callback that tells you the scan is done.
void	onStream(Reader in) Callback for you to stream the remote resource file.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.thales.punch.libraries.punchlang.api.IResourceBuilder

onStart, prepare

Constructor Detail

AbstractJsonResourceBuilder

public AbstractJsonResourceBuilder(String hashKey,
                                   boolean lowerCaseKeys)

Ctor.

Parameters:

supplier - the tuple supplier. It is invoked at every resource loading.

isLazy - true to make the tuple contain only strings, to avoid costly inner tuples. This is backed by special tuple implementations.

hashKey - the key to be used as a hash key for the resource tuple.

lowerCaseKeys - true to convert all keys to lower case

Method Detail

applyAsInt

public int applyAsInt(String value)

The callback invoked by the streaming JSON parser.

Specified by:

applyAsInt in interface ToIntFunction<String>

onStream

public void onStream(Reader in)
              throws IOException

Description copied from interface: IResourceBuilder

Callback for you to stream the remote resource file.

Specified by:

onStream in interface IResourceBuilder

Parameters:

in - the input stream to consume the resource file

Throws:

IOException - in case of IO error

onEnd

public Tuple onEnd()

Description copied from interface: IResourceBuilder

Callback that tells you the scan is done. You can safely terminate and return the building of your resource.

You should typically free any temporary storage, if any, used to build your resource.

Specified by:

onEnd in interface IResourceBuilder

Returns:

the built resource.