JsonImport

java.lang.Object

com.illumon.iris.importers.util.ImportBase

com.illumon.iris.importers.util.JsonImport

public class JsonImport
extends ImportBase

Tools for programmatically executing JSON batch imports.

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description
`static class`	`JsonImport.Builder`	The Builder class allows setting properties for a JSON import and provides a `JsonImport.Builder.build()` method which returns a JsonImport object that will use the configured properties to import batch data.

Field Summary

Fields

Modifier and Type Field Description

static com.fishlib.io.logger.Logger log

Fields inherited from class com.illumon.iris.importers.util.ImportBase
destinationDirectory, destinationPartitions, namespace, outputMode, schemaService, table

Method Summary

Modifier and Type	Method	Description
`static JsonImportBuilder`	`builder(String namespace, String table)`	Creates a new JsonImportBuilder object.
`long`	`run()`	Executes a JSON batch import as configured for the `JsonImport` object.

Methods inherited from class com.illumon.iris.importers.util.ImportBase

getFileList, getImportTableWriterFactory, getSourceFiles

Methods inherited from class java.lang.Object

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

Field Details
- log
  
  public static final com.fishlib.io.logger.Logger log
Method Details
- builder
  
  public static JsonImportBuilder builder(String namespace, String table)
  
  Creates a new JsonImportBuilder object. Method calls on this object can then be used to configure the import and run it.
  
  Parameters:
  
  namespace - The String name of the namespace into which data will be imported.
  
  table - The String name of the table into which data will be imported.
  
  Returns:
  
  A new JsonImportBuilder object.
- run
  
  public long run() throws IOException
  
  Executes a JSON batch import as configured for the JsonImport object.
  
  Specified by:
  
  run in class ImportBase
  
  Returns:
  
  A long of the number of rows imported.
  
  Throws:
  
  IOException - If the import cannot be executed or fails during processing.