Package | Description |
---|---|
com.zementis.adapa.models.batch |
Utility classes for processing data from CSV files in a batch mode.
|
com.zementis.adapa.models.batch.parallel |
Utility classes for processing data from CSV files using concurrent threads.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RecordIterator<R extends Record>
Extend a
CloseableIterator of Record 's with a method to list the names the fields in the produced
records. |
Modifier and Type | Method and Description |
---|---|
static CloseableIterator<OutputRecord> |
BatchApply.applyModel(ModelsServiceProvider modelsServiceProvider,
String modelName,
CloseableIterator<? extends Record> inputRecordIterator,
ApplySettings applySettings)
Apply a model to several records, provided through an iterator.
|
static CloseableIterator<Set<OutputRecord>> |
BatchApply.applyModels(ModelsServiceProvider modelsServiceProvider,
Set<String> modelNames,
CloseableIterator<? extends Record> inputRecordIterator,
ApplySettings applySettings)
Apply a set of models to several records, provided through an iterator.
|
static <R extends OutputRecord> |
CSVHelper.createBulkWriteIterator(Iterator<Set<R>> inputIterator,
Map<String,List<String>> fieldNames,
String groupFieldName,
Map<String,OutputStream> ouputStreams) |
static <R extends Record> |
CSVHelper.createWriteIterator(Iterator<R> inputIterator,
List<String> fieldNames,
String groupFieldName,
OutputStream os) |
Modifier and Type | Method and Description |
---|---|
static CloseableIterator<OutputRecord> |
BatchApply.applyModel(ModelsServiceProvider modelsServiceProvider,
String modelName,
CloseableIterator<? extends Record> inputRecordIterator,
ApplySettings applySettings)
Apply a model to several records, provided through an iterator.
|
static CloseableIterator<Set<OutputRecord>> |
BatchApply.applyModels(ModelsServiceProvider modelsServiceProvider,
Set<String> modelNames,
CloseableIterator<? extends Record> inputRecordIterator,
ApplySettings applySettings)
Apply a set of models to several records, provided through an iterator.
|
Modifier and Type | Method and Description |
---|---|
static CloseableIterator<OutputRecord> |
ParallelBatchApply.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>> |
ParallelBatchApply.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.
|
Copyright © 2005–2016 Zementis, Inc.. All rights reserved.