Package | Description |
---|---|
org.pentaho.di.core | |
org.pentaho.di.core.database |
Contains all the different database dialects as well as the DatabaseMeta class (definition) and the Database class (execution)
|
org.pentaho.di.core.hash | |
org.pentaho.di.core.jdbc | |
org.pentaho.di.core.logging |
This package contains the Log4j Kettle appenders and Kettle layout as well as the Kettle Log Message.
|
org.pentaho.di.core.namedcluster.model | |
org.pentaho.di.core.row | |
org.pentaho.di.core.sql | |
org.pentaho.di.core.util | |
org.pentaho.di.core.variables |
Modifier and Type | Method and Description |
---|---|
RowMetaInterface |
DBCache.get(DBCacheEntry entry)
Get the fields as a row generated by a database cache entry
|
RowMetaInterface |
RowMetaAndData.getRowMeta() |
RowMetaInterface |
RowSet.getRowMeta() |
Modifier and Type | Method and Description |
---|---|
boolean |
Condition.evaluate(RowMetaInterface rowMeta,
Object[] r)
Evaluate the condition...
|
void |
DBCache.put(DBCacheEntry entry,
RowMetaInterface fields) |
boolean |
BlockingListeningRowSet.putRow(RowMetaInterface rowMeta,
Object[] rowData) |
boolean |
BlockingBatchingRowSet.putRow(RowMetaInterface rowMeta,
Object[] rowData) |
boolean |
RowSet.putRow(RowMetaInterface rowMeta,
Object[] rowData)
Offer a row of data to this rowset providing for the description (metadata) of the row.
|
boolean |
QueueRowSet.putRow(RowMetaInterface rowMeta,
Object[] rowData) |
boolean |
BlockingRowSet.putRow(RowMetaInterface rowMeta,
Object[] rowData) |
boolean |
SingleRowRowSet.putRow(RowMetaInterface rowMeta,
Object[] rowData) |
boolean |
BlockingListeningRowSet.putRowWait(RowMetaInterface rowMeta,
Object[] rowData,
long time,
TimeUnit tu) |
boolean |
BlockingBatchingRowSet.putRowWait(RowMetaInterface rowMeta,
Object[] rowData,
long time,
TimeUnit tu)
We need to wait until
|
boolean |
RowSet.putRowWait(RowMetaInterface rowMeta,
Object[] rowData,
long time,
TimeUnit tu)
Offer a row of data to this rowset providing for the description (metadata) of the row.
|
boolean |
QueueRowSet.putRowWait(RowMetaInterface rowMeta,
Object[] rowData,
long time,
TimeUnit tu) |
boolean |
BlockingRowSet.putRowWait(RowMetaInterface rowMeta,
Object[] rowData,
long time,
TimeUnit tu) |
boolean |
SingleRowRowSet.putRowWait(RowMetaInterface rowMeta,
Object[] rowData,
long time,
TimeUnit tu) |
void |
RowMetaAndData.setRowMeta(RowMetaInterface rowMeta) |
void |
RowSet.setRowMeta(RowMetaInterface rowMeta) |
Constructor and Description |
---|
RowMetaAndData(RowMetaInterface rowMeta,
Object... data) |
Modifier and Type | Method and Description |
---|---|
RowMetaInterface |
Database.getParameterMetaData(PreparedStatement ps) |
RowMetaInterface |
Database.getParameterMetaData(String sql,
RowMetaInterface inform,
Object[] data) |
RowMetaInterface |
Database.getQueryFields(String sql,
boolean param) |
RowMetaInterface |
Database.getQueryFields(String sql,
boolean param,
RowMetaInterface inform,
Object[] data) |
RowMetaInterface |
Database.getReturnRowMeta() |
RowMetaInterface |
Database.getTableFields(String tablename) |
Modifier and Type | Method and Description |
---|---|
Result |
Database.execStatement(String rawsql,
RowMetaInterface params,
Object[] data) |
Result |
Database.execStatements(String script,
RowMetaInterface params,
Object[] data)
Execute a series of SQL statements, separated by ;
We are already connected...
|
String |
Database.fieldSubstitute(String aString,
RowMetaInterface rowMeta,
Object[] rowData) |
String |
DatabaseMeta.fieldSubstitute(String aString,
RowMetaInterface rowMeta,
Object[] rowData) |
String |
Database.getAlterTableStatement(String tableName,
RowMetaInterface fields,
String tk,
boolean use_autoinc,
String pk,
boolean semicolon) |
String |
Database.getCreateTableStatement(String tableName,
RowMetaInterface fields,
String tk,
boolean use_autoinc,
String pk,
boolean semicolon)
Generates SQL
|
String |
Database.getDDL(String tablename,
RowMetaInterface fields) |
String |
Database.getDDL(String tablename,
RowMetaInterface fields,
String tk,
boolean use_autoinc,
String pk) |
String |
Database.getDDL(String tableName,
RowMetaInterface fields,
String tk,
boolean use_autoinc,
String pk,
boolean semicolon) |
String |
Database.getDDLCreationTable(String tableName,
RowMetaInterface fields)
Return SQL CREATION statement for a Table
|
String |
Database.getInsertStatement(String tableName,
RowMetaInterface fields) |
String |
Database.getInsertStatement(String schemaName,
String tableName,
RowMetaInterface fields) |
int |
DatabaseMeta.getNrReservedWords(RowMetaInterface fields)
Checks the fields specified for reserved words
|
RowMetaAndData |
Database.getOneRow(String sql,
RowMetaInterface param,
Object[] data) |
RowMetaInterface |
Database.getParameterMetaData(String sql,
RowMetaInterface inform,
Object[] data) |
RowMetaInterface |
Database.getQueryFields(String sql,
boolean param,
RowMetaInterface inform,
Object[] data) |
Object[] |
Database.getRow(ResultSet rs,
ResultSetMetaData dummy,
RowMetaInterface rowInfo)
Get a row from the resultset.
|
List<Object[]> |
Database.getRows(String sql,
RowMetaInterface params,
Object[] data,
int fetch_mode,
boolean lazyConversion,
int limit,
ProgressMonitorListener monitor)
Reads the result of an SQL query into an ArrayList.
|
String |
Database.getSQLOutput(String schemaName,
String tableName,
RowMetaInterface fields,
Object[] r,
String dateFormat)
Return SQL statement (INSERT INTO TableName ...
|
void |
Database.insertRow(String tableName,
RowMetaInterface fields,
Object[] data) |
void |
Database.insertRow(String schemaName,
String tableName,
RowMetaInterface fields,
Object[] data) |
ResultSet |
Database.openQuery(PreparedStatement ps,
RowMetaInterface params,
Object[] data) |
ResultSet |
Database.openQuery(String sql,
RowMetaInterface params,
Object[] data)
Open a query on the database with a set of parameters stored in a Kettle Row
|
ResultSet |
Database.openQuery(String sql,
RowMetaInterface params,
Object[] data,
int fetch_mode) |
ResultSet |
Database.openQuery(String sql,
RowMetaInterface params,
Object[] data,
int fetch_mode,
boolean lazyConversion) |
void |
Database.prepareInsert(RowMetaInterface rowMeta,
String tableName)
Prepare inserting values into a table, using the fields & values in a Row
|
void |
Database.prepareInsert(RowMetaInterface rowMeta,
String schemaName,
String tableName)
Prepare inserting values into a table, using the fields & values in a Row
|
void |
DatabaseMeta.quoteReservedWords(RowMetaInterface fields)
Changes the names of the fields to their quoted equivalent if this is needed
|
boolean |
DatabaseMeta.replaceReservedWords(RowMetaInterface fields)
Checks the fields specified for reserved words and quotes them.
|
void |
Database.setProcValues(RowMetaInterface rowMeta,
Object[] data,
int[] argnrs,
String[] argdir,
boolean result) |
void |
Database.setValues(RowMetaInterface rowMeta,
Object[] data) |
void |
Database.setValues(RowMetaInterface rowMeta,
Object[] data,
PreparedStatement ps) |
void |
Database.setValues(RowMetaInterface rowMeta,
Object[] data,
PreparedStatement ps,
int ignoreThisValueIndex)
Sets the values of the preparedStatement pstmt.
|
void |
Database.setValuesInsert(RowMetaInterface rowMeta,
Object[] data) |
void |
Database.setValuesLookup(RowMetaInterface rowMeta,
Object[] data) |
void |
Database.setValuesUpdate(RowMetaInterface rowMeta,
Object[] data) |
Modifier and Type | Method and Description |
---|---|
static int |
ByteArrayHashIndex.generateHashCode(byte[] key,
RowMetaInterface rowMeta) |
Constructor and Description |
---|
ByteArrayHashIndex(RowMetaInterface keyRowMeta) |
ByteArrayHashIndex(RowMetaInterface keyRowMeta,
int size)
Create a Byte array hash index to store row
|
ByteArrayHashMap(int initialCapacity,
float loadFactor,
RowMetaInterface keyMeta)
Constructs an empty ByteArrayHashMap with the specified initial capacity and load factor.
|
ByteArrayHashMap(int initialCapacity,
RowMetaInterface keyMeta)
Constructs an empty ByteArrayHashMap with the specified initial capacity and the default load factor
(0.75).
|
ByteArrayHashMap(RowMetaInterface keyMeta)
Constructs an empty HashMap with the default initial capacity (16) and the default load factor (0.75).
|
Modifier and Type | Method and Description |
---|---|
RowMetaInterface |
ThinServiceInformation.getServiceFields() |
Modifier and Type | Method and Description |
---|---|
void |
ThinServiceInformation.setServiceFields(RowMetaInterface serviceFields) |
Constructor and Description |
---|
RowsResultSet(RowMetaInterface rowMeta,
List<Object[]> rows) |
ThinResultSetMetaData(String serviceName,
RowMetaInterface rowMeta) |
ThinServiceInformation(String name,
RowMetaInterface serviceFields) |
Modifier and Type | Method and Description |
---|---|
List<RowMetaInterface> |
LogTableCoreInterface.getRecommendedIndexes() |
Modifier and Type | Method and Description |
---|---|
String |
NamedCluster.fieldSubstitute(String aString,
RowMetaInterface rowMeta,
Object[] rowData) |
Modifier and Type | Class and Description |
---|---|
class |
RowMeta |
Modifier and Type | Method and Description |
---|---|
RowMetaInterface |
RowMetaInterface.clone()
Clone this RowMetaInterface object.
|
RowMetaInterface |
RowMetaInterface.cloneToType(int targetType)
This method copies the row metadata and sets all values to the specified type (usually String)
|
RowMetaInterface |
RowMeta.cloneToType(int targetType)
This method copies the row metadata and sets all values to the specified type (usually String)
|
RowMetaInterface |
RowBuffer.getRowMeta() |
Modifier and Type | Method and Description |
---|---|
void |
RowMetaInterface.addRowMeta(RowMetaInterface rowMeta)
Add a number of fields from another row (append to the end).
|
void |
RowMeta.addRowMeta(RowMetaInterface rowMeta) |
int |
RowMetaInterface.compare(Object[] rowData1,
RowMetaInterface rowMeta2,
Object[] rowData2,
int[] fieldnrs1,
int[] fieldnrs2)
Compare 2 rows with each other using certain values in the rows and also considering the specified ascending
clauses of the value metadata.
|
int |
RowMeta.compare(Object[] rowData1,
RowMetaInterface rowMeta2,
Object[] rowData2,
int[] fieldnrs1,
int[] fieldnrs2)
Compare 2 rows with each other using certain values in the rows and also considering the specified ascending
clauses of the value metadata.
|
static Row |
RowMeta.createOriginalRow(RowMetaInterface rowMeta,
Object[] rowData) |
static byte[] |
RowMeta.extractData(RowMetaInterface metadata,
Object[] row)
Serialize a row of data to byte[]
|
static Object[] |
RowMeta.getRow(RowMetaInterface metadata,
byte[] data)
Create a row of data bases on a serialized format (byte[])
|
void |
RowMetaInterface.mergeRowMeta(RowMetaInterface r)
Merge the values of row r to this Row.
|
void |
RowMeta.mergeRowMeta(RowMetaInterface r)
Merge the values of row r to this Row.
|
void |
RowBuffer.setRowMeta(RowMetaInterface rowMeta) |
Constructor and Description |
---|
RowBuffer(RowMetaInterface rowMeta) |
RowBuffer(RowMetaInterface rowMeta,
List<Object[]> buffer) |
Modifier and Type | Method and Description |
---|---|
RowMetaInterface |
SQL.getRowMeta() |
RowMetaInterface |
IifFunction.getServiceFields() |
RowMetaInterface |
SQLFields.getServiceFields() |
RowMetaInterface |
SQLCondition.getServiceFields() |
Modifier and Type | Method and Description |
---|---|
List<SQLField> |
SQLCondition.extractHavingFields(List<SQLField> selectFields,
List<SQLField> aggFields,
RowMetaInterface rowMeta)
Extract the list of having fields from this having condition
|
void |
SQL.parse(RowMetaInterface rowMeta) |
void |
SQL.setRowMeta(RowMetaInterface rowMeta) |
void |
SQLFields.setServiceFields(RowMetaInterface serviceFields) |
void |
SQLCondition.setServiceFields(RowMetaInterface serviceFields) |
Constructor and Description |
---|
IifFunction(String tableAlias,
String conditionClause,
String trueValueString,
String falseValueString,
RowMetaInterface serviceFields) |
SQLCondition(String tableAlias,
String conditionSql,
RowMetaInterface serviceFields) |
SQLCondition(String tableAlias,
String conditionSql,
RowMetaInterface serviceFields,
SQLFields selectFields) |
SQLField(String tableAlias,
String fieldClause,
RowMetaInterface serviceFields) |
SQLField(String tableAlias,
String fieldClause,
RowMetaInterface serviceFields,
boolean orderField) |
SQLField(String tableAlias,
String fieldClause,
RowMetaInterface serviceFields,
boolean orderField,
SQLFields selectFields) |
SQLFields(String tableAlias,
RowMetaInterface serviceFields,
String fieldsClause) |
SQLFields(String tableAlias,
RowMetaInterface serviceFields,
String fieldsClause,
boolean orderClause) |
SQLFields(String tableAlias,
RowMetaInterface serviceFields,
String fieldsClause,
boolean orderClause,
SQLFields selectFields) |
Modifier and Type | Method and Description |
---|---|
static String |
StringUtil.substituteField(String aString,
RowMetaInterface rowMeta,
Object[] rowData)
Substitutes field values in
aString . |
Modifier and Type | Method and Description |
---|---|
String |
Variables.fieldSubstitute(String aString,
RowMetaInterface rowMeta,
Object[] rowData)
Substitutes field values in
aString . |
String |
VariableSpace.fieldSubstitute(String aString,
RowMetaInterface rowMeta,
Object[] rowData)
Substitutes field values in
aString . |