public class FieldStreamDataSource extends DataSource<InputStream>
VariableResolver
This may be used with any EntityProcessor
which uses a DataSource
<InputStream
> eg: TikaEntityProcessor
Modifier and Type | Field and Description |
---|---|
protected String |
dataField |
protected VariableResolver |
vr |
Constructor and Description |
---|
FieldStreamDataSource() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Cleans up resources of this DataSource after use.
|
InputStream |
getData(String query)
Get records for the given query.The return type depends on the
implementation .
|
void |
init(Context context,
Properties initProps)
Initializes the DataSource with the
Context and
initialization properties. |
protected VariableResolver vr
protected String dataField
public void init(Context context, Properties initProps)
DataSource
Context
and
initialization properties.
This is invoked by the DataImporter
after creating an
instance of this class.init
in class DataSource<InputStream>
public InputStream getData(String query)
DataSource
getData
in class DataSource<InputStream>
query
- The query string. It can be a SQL for JdbcDataSource or a URL
for HttpDataSource or a file location for FileDataSource or a custom
format for your own custom DataSource.public void close()
DataSource
close
in class DataSource<InputStream>