org.pentaho.di.core.row
Interface RowMetaInterface

All Superinterfaces:

Cloneable

All Known Implementing Classes:

RowMeta

public interface RowMetaInterface
extends Cloneable

Method Summary

void	addRowMeta(RowMetaInterface rowMeta) Add a number of fields from another row (append to the end)
void	addValueMeta(int index, ValueMetaInterface meta) Add a metadata value on a certain location in the row.
void	addValueMeta(ValueMetaInterface meta) Add a metadata value, extends the array if needed.
void	clear() Clear the row metadata
RowMetaInterface	clone()
Object[]	cloneRow(Object[] objects)
Object[]	cloneRow(Object[] objects, Object[] cloneTo)
int	compare(Object[] rowData1, Object[] rowData2) Compare 2 rows with each other using all values in the rows and also considering the specified ascending clauses of the value metadata.
int	compare(Object[] rowData1, Object[] rowData2, int[] fieldnrs) Compare 2 rows with each other using certain values in the rows and also considering the specified ascending clauses of the value metadata.
int	compare(Object[] rowData1, 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	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	convertedValuesHashCode(Object[] rowData) Calculates a hashcode of the converted value of all objects in the supplied row.
boolean	equals(Object[] rowData1, Object[] rowData2, int[] fieldnrs) Compare 2 rows with each other for equality using certain values in the rows and also considering the case sensitivity flag.
boolean	exists(ValueMetaInterface meta) Check if a value is already present in this row with the same name
BigDecimal	getBigNumber(Object[] dataRow, int index) Get a BigNumber value from a row of data.
byte[]	getBinary(Object[] dataRow, int index) Get a Binary value from a row of data.
Boolean	getBoolean(Object[] dataRow, int index) Get a Boolean value from a row of data.
String	getDataXML(Object[] rowData)
Date	getDate(Object[] dataRow, int index) Get a Date value from a row of data.
Date	getDate(Object[] dataRow, String valueName, Date defaultValue)
String[]	getFieldNames() Get an array of the names of all the Values in the Row.
String[]	getFieldNamesAndTypes(int maxlen) Get an array of strings showing the name of the values in the row padded to a maximum length, followed by the types of the values.
Long	getInteger(Object[] dataRow, int index) Get an Integer value from a row of data.
Long	getInteger(Object[] dataRow, String valueName, Long defaultValue)
String	getMetaXML()
Double	getNumber(Object[] dataRow, int index) Get a Number value from a row of data.
Object[]	getRow(Node node) Convert an XML node into binary data using the row metadata supplied.
String	getString(Object[] row) Get the string representation of the data in a row of data
String	getString(Object[] dataRow, int index) Get a String value from a row of data.
String	getString(Object[] dataRow, String valueName, String defaultValue)
ValueMetaInterface	getValueMeta(int index) Get the value metadata on the specified index.
List<ValueMetaInterface>	getValueMetaList()
int	hashCode(Object[] rowData) Calculates a simple hashCode of all the native data objects in the supplied row.
int	indexOfValue(String valueName) Searches the index of a value meta with a given name
boolean	isEmpty()
boolean	isNull(Object[] dataRow, int index) Determines whether a value in a row is null.
void	mergeRowMeta(RowMetaInterface r) Merge the values of row r to this Row.
int	oldXORHashCode(Object[] rowData) Deprecated.
Object[]	readData(DataInputStream inputStream) De-serialize a row of data (no metadata is read) from an input stream
void	removeValueMeta(int index) Remove a value metadata object on a certain index in the row
void	removeValueMeta(String string) Remove a value with a certain name from the row metadata
ValueMetaInterface	searchValueMeta(String valueName) Searches for a value with a certain name in the value meta list
void	setValueMeta(int index, ValueMetaInterface valueMeta) Replaces a value meta entry in the row metadata with another one
void	setValueMetaList(List<ValueMetaInterface> valueMetaList)
int	size()
String	toStringMeta()
void	writeData(DataOutputStream outputStream, Object[] data) Write a serialized version of the supplied data to the outputStream (based on the metadata but not the metadata itself)
void	writeMeta(DataOutputStream outputStream) Write a serialized version of this class (Row Metadata) to the specified outputStream

Method Detail

getValueMetaList

List<ValueMetaInterface> getValueMetaList()

Returns:

the list of value Metadata

setValueMetaList

void setValueMetaList(List<ValueMetaInterface> valueMetaList)

Parameters:

valueMetaList - the list of valueMeta to set

exists

boolean exists(ValueMetaInterface meta)

Check if a value is already present in this row with the same name

Parameters:

meta - the value to check for existence

Returns:

true if a value with the same name already exists in the row

addValueMeta

void addValueMeta(ValueMetaInterface meta)

Add a metadata value, extends the array if needed. If a value with the same name already exists, it gets renamed.

Parameters:

meta - The metadata value to add

addValueMeta

void addValueMeta(int index,
                  ValueMetaInterface meta)

Add a metadata value on a certain location in the row. If a value with the same name already exists, it gets renamed. Remember to change the data row according to this.

Parameters:

index - The index where the metadata value needs to be put in the row

meta - The metadata value to add to the row

getValueMeta

ValueMetaInterface getValueMeta(int index)

Get the value metadata on the specified index.

Parameters:

index - The index to get the value metadata from

Returns:

The value metadata specified by the index.

setValueMeta

void setValueMeta(int index,
                  ValueMetaInterface valueMeta)

Replaces a value meta entry in the row metadata with another one

Parameters:

index - The index in the row to replace at

valueMeta - the metadata to replace with

getString

String getString(Object[] dataRow,
                 int index)
                 throws KettleValueException

Get a String value from a row of data. Convert data if this needed.

Parameters:

rowRow - the row of data

index - the index

Returns:

The string found on that position in the row

Throws:

KettleValueException - in case there was a problem converting the data.

getInteger

Long getInteger(Object[] dataRow,
                int index)
                throws KettleValueException

Get an Integer value from a row of data. Convert data if this needed.

Parameters:

rowRow - the row of data

index - the index

Returns:

The integer found on that position in the row

Throws:

KettleValueException - in case there was a problem converting the data.

getNumber

Double getNumber(Object[] dataRow,
                 int index)
                 throws KettleValueException

Get a Number value from a row of data. Convert data if this needed.

Parameters:

rowRow - the row of data

index - the index

Returns:

The number found on that position in the row

Throws:

KettleValueException - in case there was a problem converting the data.

getDate

Date getDate(Object[] dataRow,
             int index)
             throws KettleValueException

Get a Date value from a row of data. Convert data if this needed.

Parameters:

rowRow - the row of data

index - the index

Returns:

The date found on that position in the row

Throws:

KettleValueException - in case there was a problem converting the data.

getBigNumber

BigDecimal getBigNumber(Object[] dataRow,
                        int index)
                        throws KettleValueException

Get a BigNumber value from a row of data. Convert data if this needed.

Parameters:

rowRow - the row of data

index - the index

Returns:

The bignumber found on that position in the row

Throws:

KettleValueException - in case there was a problem converting the data.

getBoolean

Boolean getBoolean(Object[] dataRow,
                   int index)
                   throws KettleValueException

Get a Boolean value from a row of data. Convert data if this needed.

Parameters:

rowRow - the row of data

index - the index

Returns:

The boolean found on that position in the row

Throws:

KettleValueException - in case there was a problem converting the data.

getBinary

byte[] getBinary(Object[] dataRow,
                 int index)
                 throws KettleValueException

Get a Binary value from a row of data. Convert data if this needed.

Parameters:

rowRow - the row of data

index - the index

Returns:

The binary found on that position in the row

Throws:

KettleValueException - in case there was a problem converting the data.

cloneRow

Object[] cloneRow(Object[] objects,
                  Object[] cloneTo)
                  throws KettleValueException

Returns:

a cloned Object[] object.

Throws:

KettleValueException - in case something is not quite right with the expected data

cloneRow

Object[] cloneRow(Object[] objects)
                  throws KettleValueException

Returns:

a cloned Object[] object.

Throws:

KettleValueException - in case something is not quite right with the expected data

size

int size()

Returns:

the size of the metadata row

isEmpty

boolean isEmpty()

Returns:

true if there are no elements in the row metadata

isNull

boolean isNull(Object[] dataRow,
               int index)
               throws KettleValueException

Determines whether a value in a row is null. A value is null when the object is null. As such, you can just as good write dataRow[index]==null in your code.

Parameters:

dataRow - The row of data

index - the index to reference

Returns:

true if the value on the index is null.

Throws:

KettleValueException - in case there is a conversion error (only thrown in case of lazy conversion)

clone

RowMetaInterface clone()

Returns:

a copy of this RowMetaInterface object

getString

String getString(Object[] dataRow,
                 String valueName,
                 String defaultValue)
                 throws KettleValueException

Throws:

KettleValueException

getInteger

Long getInteger(Object[] dataRow,
                String valueName,
                Long defaultValue)
                throws KettleValueException

Throws:

KettleValueException

getDate

Date getDate(Object[] dataRow,
             String valueName,
             Date defaultValue)
             throws KettleValueException

Throws:

KettleValueException

searchValueMeta

ValueMetaInterface searchValueMeta(String valueName)

Searches for a value with a certain name in the value meta list

Parameters:

valueName - The value name to search for

Returns:

The value metadata or null if nothing was found

indexOfValue

int indexOfValue(String valueName)

Searches the index of a value meta with a given name

Parameters:

valueName - the name of the value metadata to look for

Returns:

the index or -1 in case we didn't find the value

addRowMeta

void addRowMeta(RowMetaInterface rowMeta)

Add a number of fields from another row (append to the end)

Parameters:

rowMeta - The row of metadata values to add

mergeRowMeta

void mergeRowMeta(RowMetaInterface r)

Merge the values of row r to this Row. The values that are not yet in the row are added unchanged. The values that are in the row are renamed to name[2], name[3], etc.

Parameters:

r - The row to be merged with this row

getFieldNames

String[] getFieldNames()

Get an array of the names of all the Values in the Row.

Returns:

an array of Strings: the names of all the Values in the Row.

writeMeta

void writeMeta(DataOutputStream outputStream)
               throws KettleFileException

Write a serialized version of this class (Row Metadata) to the specified outputStream

Parameters:

outputStream - the outputstream to write to

data - the data to write after the metadata

Throws:

KettleFileException - in case a I/O error occurs

writeData

void writeData(DataOutputStream outputStream,
               Object[] data)
               throws KettleFileException

Write a serialized version of the supplied data to the outputStream (based on the metadata but not the metadata itself)

Parameters:

outputStream - the outputstream to write to

data - the data to write after the metadata

Throws:

KettleFileException - in case a I/O error occurs

readData

Object[] readData(DataInputStream inputStream)
                  throws KettleFileException,
                         SocketTimeoutException

De-serialize a row of data (no metadata is read) from an input stream

Parameters:

inputStream - the inputstream to read from

Returns:

a new row of data

Throws:

KettleFileException - in case a I/O error occurs

SocketTimeoutException - In case there is a timeout during reading.

clear

void clear()

Clear the row metadata

removeValueMeta

void removeValueMeta(String string)
                     throws KettleValueException

Remove a value with a certain name from the row metadata

Parameters:

string - the name of the value metadata to remove

Throws:

KettleValueException - in case the value couldn't be found in the row metadata

removeValueMeta

void removeValueMeta(int index)

Remove a value metadata object on a certain index in the row

Parameters:

index - the index to remove the value metadata from

getString

String getString(Object[] row)
                 throws KettleValueException

Get the string representation of the data in a row of data

Parameters:

row - the row of data to convert to string

Returns:

the row of data in string form

Throws:

KettleValueException - in case of a conversion error

getFieldNamesAndTypes

String[] getFieldNamesAndTypes(int maxlen)

Get an array of strings showing the name of the values in the row padded to a maximum length, followed by the types of the values.

Parameters:

maxlen - The length to which the name will be padded.

Returns:

an array of strings: the names and the types of the fieldnames in the row.

compare

int compare(Object[] rowData1,
            Object[] rowData2,
            int[] fieldnrs)
            throws KettleValueException

Compare 2 rows with each other using certain values in the rows and also considering the specified ascending clauses of the value metadata.

Parameters:

rowData1 - The first row of data

rowData2 - The second row of data

fieldnrs - the fields to compare on (in that order)

Returns:

0 if the rows are considered equal, -1 is data1 is smaller, 1 if data2 is smaller.

Throws:

KettleValueException

equals

boolean equals(Object[] rowData1,
               Object[] rowData2,
               int[] fieldnrs)
               throws KettleValueException

Compare 2 rows with each other for equality using certain values in the rows and also considering the case sensitivity flag.

Parameters:

rowData1 - The first row of data

rowData2 - The second row of data

fieldnrs - the fields to compare on (in that order)

Returns:

true if the rows are considered equal, false if they are not.

Throws:

KettleValueException

compare

int compare(Object[] rowData1,
            Object[] rowData2,
            int[] fieldnrs1,
            int[] fieldnrs2)
            throws KettleValueException

Compare 2 rows with each other using certain values in the rows and also considering the specified ascending clauses of the value metadata.

Parameters:

rowData1 - The first row of data

rowData2 - The second row of data

fieldnrs1 - The indexes of the values to compare in the first row

fieldnrs2 - The indexes of the values to compare with in the second row

Returns:

0 if the rows are considered equal, -1 is data1 is smaller, 1 if data2 is smaller.

Throws:

KettleValueException

compare

int compare(Object[] rowData1,
            RowMetaInterface rowMeta2,
            Object[] rowData2,
            int[] fieldnrs1,
            int[] fieldnrs2)
            throws KettleValueException

Compare 2 rows with each other using certain values in the rows and also considering the specified ascending clauses of the value metadata.

Parameters:

rowData1 - The first row of data

rowMeta2 - the metadat of the second row of data

rowData2 - The second row of data

fieldnrs1 - The indexes of the values to compare in the first row

fieldnrs2 - The indexes of the values to compare with in the second row

Returns:

0 if the rows are considered equal, -1 is data1 is smaller, 1 if data2 is smaller.

Throws:

KettleValueException

compare

int compare(Object[] rowData1,
            Object[] rowData2)
            throws KettleValueException

Compare 2 rows with each other using all values in the rows and also considering the specified ascending clauses of the value metadata.

Parameters:

rowData1 - The first row of data

rowData2 - The second row of data

Returns:

0 if the rows are considered equal, -1 is data1 is smaller, 1 if data2 is smaller.

Throws:

KettleValueException

oldXORHashCode

int oldXORHashCode(Object[] rowData)
                   throws KettleValueException

Deprecated.

Calculate a hashCode of the content (not the index) of the data specified NOTE: This method uses a simple XOR of the individual hashCodes which can result in a lot of collisions for similar types of data (e.g. [A,B] == [B,A] and is not suitable for normal use. It is kept to provide backward compatibility with CombinationLookup.lookupValues()

Parameters:

rowData - The data to calculate a hashCode with

Returns:

the calculated hashCode

Throws:

KettleValueException - in case there is a data conversion error

hashCode

int hashCode(Object[] rowData)
             throws KettleValueException

Calculates a simple hashCode of all the native data objects in the supplied row. This method will return a better distribution of values for rows of numbers or rows with the same values in different positions. NOTE: This method performs against the native values, not the values returned by ValueMeta. This means that if you have two rows with different primitive values ['2008-01-01:12:30'] and ['2008-01-01:00:00'] that use a format object to change the value (as Date yyyy-MM-dd), the hashCodes will be different resulting in the two rows not being considered equal via the hashCode even though compare() or equals() might consider them to be.

Parameters:

rowData - The data to calculate a hashCode with

Returns:

the calculated hashCode

Throws:

KettleValueException - in case there is a data conversion error

convertedValuesHashCode

int convertedValuesHashCode(Object[] rowData)
                            throws KettleValueException

Calculates a hashcode of the converted value of all objects in the supplied row. This method returns distinct values for nulls of different data types and will return the same hashCode for different native values that have a ValueMeta converting them into the same value (e.g. ['2008-01-01:12:30'] and ['2008-01-01:00:00'] as Date yyyy-MM-dd)

Parameters:

rowData - The data to calculate a hashCode with

Returns:

the calculated hashCode

Throws:

KettleValueException - in case there is a data conversion error

toStringMeta

String toStringMeta()

Returns:

a string with a description of all the metadata values of the complete row of metadata

getMetaXML

String getMetaXML()
                  throws IOException

Returns:

an XML representation of the row metadata

Throws:

IOException - Thrown in case there is an (Base64/GZip) encoding problem

getDataXML

String getDataXML(Object[] rowData)
                  throws IOException

Parameters:

rowData - the row of data to serialize as XML

Returns:

an XML representation of the row data

Throws:

IOException - Thrown in case there is an (Base64/GZip) encoding problem

getRow

Object[] getRow(Node node)
                throws KettleException

Convert an XML node into binary data using the row metadata supplied.

Parameters:

rowMeta - The row metadata to reference

node - The data row node

Returns:

a row of data de-serialized from XML

Throws:

KettleException - Thrown in case there is an (Base64/GZip) decoding problem