Class JSONSplitter<T extends JSONWriteHandle>

Type Parameters:

T - The type of the handle used for each split payload

All Implemented Interfaces:

Splitter<T>

• Nested Class Summary

  Nested Classes
  Modifier and Type

  Class

  Description

  static class 

  JSONSplitter.ArrayVisitor

  The basic visitor only splits objects or arrays under top array.

  static interface 

  JSONSplitter.UriMaker

  UriMaker which generates URI for each split file

  static class 

  JSONSplitter.Visitor<T extends AbstractWriteHandle>

  The Visitor class is used to accumulate and inspect state during the depth-first traversal of the JSON tree and make the decision of how to split the JSON file.

• Constructor Summary

  Constructors
  Constructor

  Description

  JSONSplitter(JSONSplitter.Visitor<T> visitor)

  Construct a JSONSplitter which splits the JSON file according to the visitor.

• Method Summary

  All MethodsStatic MethodsInstance MethodsConcrete Methods

  Modifier and Type

  Method

  Description

  long

  getCount()

  Returns the number of splits.

  JSONSplitter.UriMaker

  getUriMaker()

  Get the UriMaker of the splitter

  JSONSplitter.Visitor<T>

  getVisitor()

  Get the visitor used in JSONSplitter class.

  static JSONSplitter<StringHandle>

  makeArraySplitter()

  Construct a simple JSONSplitter which split objects or arrays under an array.

  void

  setUriMaker(JSONSplitter.UriMaker uriMaker)

  Set the UriMaker to the splitter

  void

  setVisitor(JSONSplitter.Visitor<T> visitor)

  Set the visitor to select objects or arrays to split in JSONSplitter.

  Stream<T>

  split(com.fasterxml.jackson.core.JsonParser input)

  Take an input of JsonParser created from the JSON file and split it into a stream of handles to write to database.

  Stream<T>

  split(InputStream input)

  Takes an InputStream of a JSON file and split it into a steam of handles.

  Stream<DocumentWriteOperation>

  splitWriteOperations(com.fasterxml.jackson.core.JsonParser input, String splitFilename)

  Take an input of JsonParser created from the JSON file and split it into a stream of DocumentWriteOperations to write to database.

  Stream<DocumentWriteOperation>

  splitWriteOperations(InputStream input)

  Takes an InputStream of a JSON file and split it into a steam of DocumentWriteOperation to write to database.

  Stream<DocumentWriteOperation>

  splitWriteOperations(InputStream input, String splitFilename)

  Takes an InputStream of a JSON file and file name and split it into a steam of DocumentWriteOperation to write to database.

  Methods inherited from class java.lang.Object

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

• Constructor Details

  • JSONSplitter

    public JSONSplitter(JSONSplitter.Visitor<T> visitor)
    Construct a JSONSplitter which splits the JSON file according to the visitor.

    Parameters:

    visitor - describes how to spit the file

• Method Details

  • makeArraySplitter

    public static JSONSplitter<StringHandle> makeArraySplitter()
    Construct a simple JSONSplitter which split objects or arrays under an array.

    Returns:

    a JSONSplitter class which splits each object or array into a separate payload

  • getVisitor

    public JSONSplitter.Visitor<T> getVisitor()
    Get the visitor used in JSONSplitter class.

    Returns:

    the visitor used in JSONSplitter class

  • setVisitor

    public void setVisitor(JSONSplitter.Visitor<T> visitor)
    Set the visitor to select objects or arrays to split in JSONSplitter.

    Parameters:

    visitor - the visitor describes the rule to split the JSON file

  • getCount

    public long getCount()
    Returns the number of splits.

    Specified by:

    getCount in interface Splitter<T extends JSONWriteHandle>

    Returns:

    the number of splits

  • split

    public Stream<T> split(InputStream input) throws IOException
    Takes an InputStream of a JSON file and split it into a steam of handles.

    Specified by:

    split in interface Splitter<T extends JSONWriteHandle>

    Parameters:

    input - is the incoming InputStream of a JSON file.

    Returns:

    a stream of handles to write to database

    Throws:

    IOException - if the input cannot be split

  • splitWriteOperations

    public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input) throws Exception
    Takes an InputStream of a JSON file and split it into a steam of DocumentWriteOperation to write to database.

    Specified by:

    splitWriteOperations in interface Splitter<T extends JSONWriteHandle>

    Parameters:

    input - is the incoming input stream of a JSON file

    Returns:

    a stream of DocumentWriteOperation to write to database

    Throws:

    Exception - if the input cannot be split

  • splitWriteOperations

    public Stream<DocumentWriteOperation> splitWriteOperations(InputStream input, String splitFilename) throws Exception
    Takes an InputStream of a JSON file and file name and split it into a steam of DocumentWriteOperation to write to database.

    Specified by:

    splitWriteOperations in interface Splitter<T extends JSONWriteHandle>

    Parameters:

    input - is the incoming input stream of a JSON file

    splitFilename - is the name of input file, including name and extension. It is used to generate URLs for split files.The splitFilename could either be provided here or in user-defined UriMaker.

    Returns:

    a stream of DocumentWriteOperation to write to database

    Throws:

    Exception - if the input cannot be split

  • split

    public Stream<T> split(com.fasterxml.jackson.core.JsonParser input) throws IOException
    Take an input of JsonParser created from the JSON file and split it into a stream of handles to write to database.

    Parameters:

    input - JsonParser created from the JSON file

    Returns:

    a stream of handles to write to database

    Throws:

    IOException - if the input cannot be split

  • splitWriteOperations

    public Stream<DocumentWriteOperation> splitWriteOperations(com.fasterxml.jackson.core.JsonParser input, String splitFilename)
    Take an input of JsonParser created from the JSON file and split it into a stream of DocumentWriteOperations to write to database.

    Parameters:

    input - JsonParser created from the JSON file

    splitFilename - is the name of input file, including name and extension. It is used to generate URLs for split files.The splitFilename could either be provided here or in user-defined UriMaker.

    Returns:

    a stream of DocumentWriteOperation to write to database

  • getUriMaker

    public JSONSplitter.UriMaker getUriMaker()
    Get the UriMaker of the splitter

    Returns:

    the UriMaker of the splitter

  • setUriMaker

    public void setUriMaker(JSONSplitter.UriMaker uriMaker)
    Set the UriMaker to the splitter

    Parameters:

    uriMaker - the uriMaker to generate URI of each split file.

Copyright (c) 2010-2025 Progress Software Corporation and/or its subsidiaries or affiliates. All Rights Reserved.