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

Interface ProcessDataLocker

All Known Implementing Classes:

SimpleDataImportStreamProcessor

public interface ProcessDataLocker

Interface for Processors that support a locking processData method. Callers wrap their table-write logic in a Runnable and pass it to processData(Runnable), which executes the runnable under the processor's write lock.

Method Summary

Modifier and Type	Method	Description
void	processData(@NotNull Runnable runnable)	Execute runnable under the processor's write lock.

Method Details

processData

void processData(@NotNull
 @NotNull Runnable runnable)

Execute runnable under the processor's write lock.

Parameters:

runnable - a runnable that processes data for this stream

Throws:

ProcessingStateException - if the processor is not in a state that accepts data