public final class ParallelBatchApply extends Object
Modifier and Type | Method and Description |
---|---|
static CloseableIterator<OutputRecord> |
applyModel(ModelsServiceProvider modelsServiceProvider,
String modelName,
Iterator<? extends Record> inputRecordIterator,
ApplySettings applySettings,
ExecutorService executorService)
Apply a model to several records, provided through an iterator.
|
static CloseableIterator<Set<OutputRecord>> |
applyModels(ModelsServiceProvider modelsServiceProvider,
Set<String> modelNames,
Iterator<? extends Record> inputRecordIterator,
ApplySettings applySettings,
ExecutorService executorService)
Apply a set of models to several records, provided through an iterator.
|
public static CloseableIterator<OutputRecord> applyModel(ModelsServiceProvider modelsServiceProvider, String modelName, Iterator<? extends Record> inputRecordIterator, ApplySettings applySettings, ExecutorService executorService)
modelsServiceProvider
- the connection to usemodelName
- the name of the model to applyinputRecordIterator
- the iterator of the input recordsapplySettings
- the applySettings
to useexecutorService
- the ExecutorService
to use.public static CloseableIterator<Set<OutputRecord>> applyModels(ModelsServiceProvider modelsServiceProvider, Set<String> modelNames, Iterator<? extends Record> inputRecordIterator, ApplySettings applySettings, ExecutorService executorService)
modelsServiceProvider
- the service to usemodelNames
- the names of the model to applyinputRecordIterator
- the iterator of the input recordsapplySettings
- the ApplySettings
to useexecutorService
- the ExecutorService
to use.Copyright © 2005–2016 Zementis, Inc.. All rights reserved.