Package | Description |
---|---|
com.neurosys.etl.excel.readers | |
com.neurosys.etl.readers | |
com.neurosys.etl.service | |
com.neurosys.modules.etl.admin.wicket.pages.panels |
Modifier and Type | Class and Description |
---|---|
class |
ExcelContextualReader<T>
Reads an Excel sheet with Context in mind, supporting things like Look Aheads etc.
|
class |
ExcelRowByRowReader<T>
Parse an Excel File Row by Row; the Row is represented by A simple List of values.
|
Modifier and Type | Class and Description |
---|---|
class |
ChainIterativeReader<TUPLE_IN,RECORD_OUT,STATE>
Chain multiple
BaseIterativeProcessor s |
class |
ExecuteJobReader
Simply executes a Job
If the BaseIterativeProcessor.getTransformer() is a TransformerChain then the first level chain elements are each considered a Different Job and each passed the BaseIterativeProcessor.getParams()
If the BaseIterativeProcessor.getTransformer() return any String or List of String then those will be added to BaseIterativeProcessor.getMessages()
TODO: Add unit test case for Single & multiple Jobs in TransformerChain |
class |
FileReader<T,S>
For a given Root Folder (
File as a Resource ), read each file in all the directories (nested optional); and for each file return
a n entity of type T. |
Modifier and Type | Method and Description |
---|---|
protected void |
ETLRunner.init(AbstractReader<IN,T,Serializable> reader,
ETLMeta meta)
All Thread/Reading init based activities
|
protected void |
ETLRunner.injectContext(AbstractReader<IN,T,Serializable> reader)
Inject context data into
ParamsAware and ReaderAware like transformer implementation. |
protected void |
ETLRunner.processGeneratedEntity(T entity,
AbstractReader<IN,T,Serializable> reader,
ETLMeta meta,
ETLRunnerOptions options)
Process the final Entity produced from the ETL Process.
This is a convenient way to simply provide Transformer based processing over input/reader produced output as AbstractReader are not required at times. |
void |
ETLRunner.run(AbstractReader<IN,T,Serializable> reader,
ETLMeta meta,
ETLRunnerOptions options) |
protected void |
ETLRunner.setupJob(AbstractReader<IN,T,Serializable> job,
ETLMeta meta,
ETLRunnerOptions options) |
protected void |
ETLRunner.threadInit(AbstractReader<IN,T,Serializable> reader,
ETLMeta meta)
Init before the thread runs.
|
Modifier and Type | Method and Description |
---|---|
AbstractReader<IN,T,Serializable> |
ReaderProcess.getReader() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
ETLUpload.filter(User user,
AbstractReader reader)
By default Filter Authorizable Process that are not meant for current user
|
void |
ReaderProcess.setReader(AbstractReader<IN,T,Serializable> reader) |
Constructor and Description |
---|
ReaderProcess(org.springframework.context.ConfigurableApplicationContext context,
AbstractReader<IN,T,Serializable> reader,
String anyUploadedResource,
Progression progression,
org.apache.wicket.markup.html.panel.Panel feedback,
Boolean onlyVerify,
ETLMeta<FacetMeta> meta,
String processId) |
Copyright © 2018. All rights reserved.