Package com.illumon.iris.db.tables.dataimport.logtailer

Interface IDataImportServer

All Known Implementing Classes:

DataImportServer

public interface IDataImportServer

An interface to expose methods of the DataImportServer that need to be available for mocking in unit tests.

Method Summary

Modifier and Type	Method	Description
SimpleDataImportStreamProcessor	createSimpleProcessor(String description, FullTableLocationKey streamKey, Runnable closeCallback, SimpleDataImportStreamProcessor.OnReject onReject)
SchemaService	getSchemaService()
TableDataService	getTableDataService()
boolean	isShutdown()
void	shutdown()
void	startInWorker()

Method Details

startInWorker

void startInWorker() throws IOException

Throws:

IOException

shutdown

void shutdown()

isShutdown

boolean isShutdown()

getTableDataService

TableDataService getTableDataService()

getSchemaService

SchemaService getSchemaService()

createSimpleProcessor

SimpleDataImportStreamProcessor createSimpleProcessor(@NotNull String description, @NotNull FullTableLocationKey streamKey, @NotNull Runnable closeCallback, @NotNull SimpleDataImportStreamProcessor.OnReject onReject)