public class FastloadControlBuilder extends Object
Modifier and Type | Field and Description |
---|---|
static String |
DATAFILE_COLUMN_SEPERATOR |
static String |
DEFAULT_DATE_FORMAT |
static String |
DEFAULT_ERROR_TABLE1 |
static String |
DEFAULT_ERROR_TABLE2 |
static String |
DEFAULT_NULL_VALUE |
static String |
RECORD_FORMAT_UNFORMATTED |
static String |
RECORD_VARTEXT |
Constructor and Description |
---|
FastloadControlBuilder() |
Modifier and Type | Method and Description |
---|---|
FastloadControlBuilder |
beginLoading(String schemaName,
String table)
Issue begin loading with default error tables.
|
FastloadControlBuilder |
define(org.pentaho.di.core.row.RowMetaInterface targetTableFields,
StringListPluginProperty tableFieldList,
String dataFile) |
FastloadControlBuilder |
endLoading() |
FastloadControlBuilder |
insert(org.pentaho.di.core.row.RowMetaInterface targetTableFields,
StringListPluginProperty tableFieldList,
String tableName) |
FastloadControlBuilder |
line(String line)
Append line, nothing if line is blank.
|
FastloadControlBuilder |
logoff()
Append log off.
|
FastloadControlBuilder |
logon(String connectionString)
Append log on.
|
FastloadControlBuilder |
logon(String dbhost,
String user,
String password)
Append log on.
|
FastloadControlBuilder |
newline()
Append new line.
|
FastloadControlBuilder |
setErrorLimit(int errorLimit) |
FastloadControlBuilder |
setRecordFormat(String format) |
FastloadControlBuilder |
setSessions(int sessions) |
FastloadControlBuilder |
show()
show field definition.
|
String |
toString() |
public static final String DATAFILE_COLUMN_SEPERATOR
public static final String RECORD_FORMAT_UNFORMATTED
public static final String RECORD_VARTEXT
public static final String DEFAULT_ERROR_TABLE1
public static final String DEFAULT_ERROR_TABLE2
public static final String DEFAULT_DATE_FORMAT
public static final String DEFAULT_NULL_VALUE
public FastloadControlBuilder newline()
public FastloadControlBuilder logon(String connectionString) throws IllegalArgumentException
connectionString
- the connection string.IllegalArgumentException
- if connection string is blank.public FastloadControlBuilder logon(String dbhost, String user, String password) throws IllegalArgumentException
dbhost
- DB host, e.g localtduser
- the user.password
- the password.IllegalArgumentException
- if input is invalid.public FastloadControlBuilder setRecordFormat(String format) throws IllegalArgumentException
format
- the format.IllegalArgumentException
- if format is invalid.public FastloadControlBuilder setSessions(int sessions) throws IllegalArgumentException
sessions
- the sesssions.IllegalArgumentException
- if sessions <= 0public FastloadControlBuilder setErrorLimit(int errorLimit) throws IllegalArgumentException
errorLimit
- the errorLimit.IllegalArgumentException
- if errorLimit <= 0public FastloadControlBuilder define(org.pentaho.di.core.row.RowMetaInterface targetTableFields, StringListPluginProperty tableFieldList, String dataFile)
targetTableFields
- ...dataFile
- ...public FastloadControlBuilder insert(org.pentaho.di.core.row.RowMetaInterface targetTableFields, StringListPluginProperty tableFieldList, String tableName)
targetTableFields
- ...tableFieldList
- tableName
- ...public FastloadControlBuilder show()
public FastloadControlBuilder endLoading()
public FastloadControlBuilder beginLoading(String schemaName, String table) throws IllegalArgumentException
table
- the target table.IllegalArgumentException
- if table is invalid.public FastloadControlBuilder line(String line)
line
- line to append.public FastloadControlBuilder logoff()
public String toString()
toString
in class Object
Object.toString()