com.adaptris.core.services.splitter.json

Class LargeJsonArraySplitter

java.lang.Object

com.adaptris.core.services.splitter.MessageSplitterImp

com.adaptris.core.services.splitter.json.LargeJsonArraySplitter

All Implemented Interfaces:

MessageSplitter

Direct Known Subclasses:

BatchedJsonArraySplitter, JsonMetadataSplitter, LargeJsonArrayPathSplitter

public class LargeJsonArraySplitter
extends MessageSplitterImp

Split an arbitrarily large JSON array.

Note: tested with an 85Mb file containing an array of >15k JSON objects

In the adapter configuration file this class is aliased as large-json-array-splitter which is the preferred alternative to the fully qualified classname when building your configuration.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	LargeJsonArraySplitter.GeneratorConfig
protected class	LargeJsonArraySplitter.JsonSplitGenerator

Nested classes/interfaces inherited from class com.adaptris.core.services.splitter.MessageSplitterImp

MessageSplitterImp.SplitMessageIterator

Field Summary

Fields inherited from class com.adaptris.core.services.splitter.MessageSplitterImp

logR

Constructor Summary

Constructors

Constructor and Description
LargeJsonArraySplitter()

Method Summary

Modifier and Type	Method and Description
protected LargeJsonArraySplitter.JsonSplitGenerator	createSplitter(LargeJsonArraySplitter.GeneratorConfig cfg)
java.lang.Integer	getBufferSize()
void	setBufferSize(java.lang.Integer b) Set the internal buffer size.
CloseableIterable<AdaptrisMessage>	splitMessage(AdaptrisMessage msg)
LargeJsonArraySplitter	withBufferSize(java.lang.Integer i)
LargeJsonArraySplitter	withMessageFactory(AdaptrisMessageFactory fac)

Methods inherited from class com.adaptris.core.services.splitter.MessageSplitterImp

copyMetadata, getCopyMetadata, getCopyObjectMetadata, getMessageFactory, selectFactory, setCopyMetadata, setCopyObjectMetadata, setMessageFactory

Methods inherited from class java.lang.Object

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

Constructor Detail

LargeJsonArraySplitter

public LargeJsonArraySplitter()

Method Detail

getBufferSize

public java.lang.Integer getBufferSize()

setBufferSize

public void setBufferSize(java.lang.Integer b)

Set the internal buffer size.

This is used when; the default buffer size matches the default buffer size in BufferedReader and BufferedWriter , changes to the buffersize will impact performance and memory usage depending on the underlying operating system/disk.

Parameters:

b - the buffer size (default is 8192).

withBufferSize

public LargeJsonArraySplitter withBufferSize(java.lang.Integer i)

withMessageFactory

public LargeJsonArraySplitter withMessageFactory(AdaptrisMessageFactory fac)

splitMessage

public CloseableIterable<AdaptrisMessage> splitMessage(AdaptrisMessage msg)
                                                throws CoreException

Throws:

CoreException

createSplitter

protected LargeJsonArraySplitter.JsonSplitGenerator createSplitter(LargeJsonArraySplitter.GeneratorConfig cfg)