com.boomi.util.json.splitter

Class JsonSplitter

java.lang.Object

com.boomi.util.json.splitter.JsonSplitter

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Payload>

Direct Known Subclasses:

JsonArraySplitter, JsonRootArraySplitter

public abstract class JsonSplitter
extends Object
implements Iterable<Payload>, Closeable

Utility for efficiently splitting/stripping a json document into one or more json object nodes. Provides a customization point for altering the content of the output data (see findNextNodeStart()).

While iterating the caller must properly consume the Payload instances before the next iteration. Failure to do so will result in the iterator returning the same Payload again.

The implementations of this class should be careful about handling the JsonParser, especially if it uses a different JsonGenerator, since the method JsonGenerator.copyCurrentStructure(JsonParser) is called by the payload implementation that this class uses.

This class must be closed in order to free underlying resources.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JsonSplitter(InputStream inputStream)
protected	JsonSplitter(JsonParser parser)

Method Summary

Modifier and Type	Method and Description
void	close()
protected JsonGenerator	createGenerator(OutputStream out)
protected abstract JsonToken	findNextNodeStart()
protected JsonParser	getParser()
protected void	initialize()
Iterator<Payload>	iterator()
protected JsonToken	waitForToken(JsonToken expectedToken)
protected JsonToken	waitForTokens(Set<JsonToken> tokenSet)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

JsonSplitter

protected JsonSplitter(InputStream inputStream)
                throws IOException

Throws:

IOException

JsonSplitter

protected JsonSplitter(JsonParser parser)

Method Detail

getParser

protected final JsonParser getParser()

iterator

public Iterator<Payload> iterator()

Specified by:

iterator in interface Iterable<Payload>

waitForToken

protected final JsonToken waitForToken(JsonToken expectedToken)
                                throws IOException

Throws:

IOException

waitForTokens

protected final JsonToken waitForTokens(Set<JsonToken> tokenSet)
                                 throws IOException

Throws:

IOException

createGenerator

protected JsonGenerator createGenerator(OutputStream out)
                                 throws IOException

Throws:

IOException

initialize

protected void initialize()
                   throws IOException

Throws:

IOException

findNextNodeStart

protected abstract JsonToken findNextNodeStart()
                                        throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable