Package com.illumon.iris.importers

Class BinaryStoreImporter

java.lang.Object

com.illumon.iris.importers.BaseImporter<BinaryStoreImporter.Arguments>

com.illumon.iris.importers.BinaryStoreImporter

public class BinaryStoreImporter
extends BaseImporter<BinaryStoreImporter.Arguments>

Simple importer to consume binary row-oriented log files and produce database tables. Effectively like a tailer and a data importer server for offline data (minus the distribution components). TODO: Add support for user ImportState.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BinaryStoreImporter.Arguments	Argument structure for BinaryStoreImporter.

Field Summary

Fields inherited from class com.illumon.iris.importers.BaseImporter

log

Method Summary

Modifier and Type	Method	Description
static void	doImport(com.fishlib.io.logger.Logger log, BinaryStoreImporter.Arguments args)	Construct a new BinaryStoreImporter and use it to import data according to args.
protected void	finishImport()	Wrap up the import process.
static void	main(String... args)
static void	parseArgsAndDoImport(com.fishlib.io.logger.Logger log, String... args)	Parse the supplied String command-line arguments into an BinaryStoreImporter.Arguments instance, construct a new BinaryStoreImporter, and use it to import data according to args.
static BinaryStoreImporter.Arguments	parseArguments(String... args)	Parse the supplied String command-line arguments into an BinaryStoreImporter.Arguments instance.
void	processData()	Import the data - e.g.

Methods inherited from class com.illumon.iris.importers.BaseImporter

doImport, getImporterArguments, getTableDefinition, getTableWriter

Methods inherited from class java.lang.Object

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

Method Details

processData

public void processData()

Description copied from class: BaseImporter

Import the data - e.g. read the rows from the data source. The Overriding class does the actual import using arguments, tableWriter, and tableListenerFactory

Specified by:

processData in class BaseImporter<BinaryStoreImporter.Arguments>

finishImport

protected void finishImport()

Description copied from class: BaseImporter

Wrap up the import process. Close the tableWriter and any other finalization tasks. Implementors should not need to override this.

Overrides:

finishImport in class BaseImporter<BinaryStoreImporter.Arguments>

parseArguments

public static BinaryStoreImporter.Arguments parseArguments(@NotNull
 String... args)

Parse the supplied String command-line arguments into an BinaryStoreImporter.Arguments instance.

Parameters:

args - The command-line arguments

Returns:

The BinaryStoreImporter.Arguments structure

doImport

public static void doImport(@NotNull
 com.fishlib.io.logger.Logger log,
 @NotNull
 BinaryStoreImporter.Arguments args)

Construct a new BinaryStoreImporter and use it to import data according to args.

Parameters:

log - The Logger to use

args - The BinaryStoreImporter.Arguments specifying what to import

parseArgsAndDoImport

public static void parseArgsAndDoImport(@NotNull
 com.fishlib.io.logger.Logger log,
 @NotNull
 String... args)

Parse the supplied String command-line arguments into an BinaryStoreImporter.Arguments instance, construct a new BinaryStoreImporter, and use it to import data according to args.

Parameters:

log - The Logger to use

args - The command-line arguments

main

public static void main(String... args)