public class SQLDataRecordSource extends StreamingDataRecordSource
showProgress, verbose| Constructor and Description |
|---|
SQLDataRecordSource() |
SQLDataRecordSource(DatabaseConnectionConfig database,
java.lang.String query) |
SQLDataRecordSource(DatabaseConnection connection,
java.lang.String query) |
| Modifier and Type | Method and Description |
|---|---|
DataRecordFetcher |
createFetcher()
Creates a new fetcher to gather data for a new iteration.
|
java.lang.String |
getQuery() |
void |
setQuery(java.lang.String newQuery) |
copyStateFrom, createInputStream, getPath, getPaths, setInputStream, setPath, setPaths, toCogclone, close, getAfterActions, getBeforeActions, getShowProgress, getTransforms, isVerbose, iterator, setAfterActions, setBeforeActions, setShowProgress, setTransforms, setVerbosepublic SQLDataRecordSource()
public SQLDataRecordSource(DatabaseConnectionConfig database, java.lang.String query)
public SQLDataRecordSource(DatabaseConnection connection, java.lang.String query)
public DataRecordFetcher createFetcher()
DataRecordSourcecreateFetcher in class DataRecordSourcepublic java.lang.String getQuery()
public void setQuery(java.lang.String newQuery)