streamcruncher.api.artifact
Class RowSpec

java.lang.Object
  streamcruncher.api.artifact.RowSpec

All Implemented Interfaces:

java.io.Serializable

public class RowSpec
extends java.lang.Object
implements java.io.Serializable

The column-set definition of the Table of an Input/Output Event Stream.

See Also:

Serialized Form

Nested Class Summary

static class

RowSpec.Info Additional information can be appended to the Java type.

Field Summary

static java.lang.String	INFO_NAME_VALUE_SEPARATOR "="
static java.lang.String	INFO_SEPARATOR ":"

Constructor Summary

RowSpec(java.lang.String[] columnNames, java.lang.String[] columnNativeTypes)
Creates a RowSpec without id-column, timestamp-column and version-column i.e with -1 as their positions.

RowSpec(java.lang.String[] columnNames, java.lang.String[] columnNativeTypes, int idColumnPosition, int timestampColumnPosition)
Creates a RowSpec without version-column i.e with -1 as its position.

RowSpec(java.lang.String[] columnNames, java.lang.String[] columnNativeTypes, int idColumnPosition, int timestampColumnPosition, int versionColumnPosition)
Internal use.

Method Summary

static java.lang.String	addInfo(java.lang.String basicJavaType, RowSpec.Info info, java.lang.Object value) A convenience method to add additional information to the Type.
boolean	equals(java.lang.Object obj)
java.lang.String[]	getColumnNames()
java.lang.String[]	getColumnNativeTypes()
int	getIdColumnPosition()
int	getTimestampColumnPosition()
int	getVersionColumnPosition()
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Field Detail

INFO_SEPARATOR

public static final java.lang.String INFO_SEPARATOR

":"

See Also:

Constant Field Values

INFO_NAME_VALUE_SEPARATOR

public static final java.lang.String INFO_NAME_VALUE_SEPARATOR

"="

See Also:

Constant Field Values

Constructor Detail

RowSpec

public RowSpec(java.lang.String[] columnNames,
               java.lang.String[] columnNativeTypes)

Creates a RowSpec without id-column, timestamp-column and version-column i.e with -1 as their positions.

Parameters:

columnNames -

columnNativeTypes -

See Also:

RowSpec(String[], String[], int, int, int)

RowSpec

public RowSpec(java.lang.String[] columnNames,
               java.lang.String[] columnNativeTypes,
               int idColumnPosition,
               int timestampColumnPosition)

Creates a RowSpec without version-column i.e with -1 as its position.

Parameters:

columnNames -

columnNativeTypes -

idColumnPosition -

timestampColumnPosition -

See Also:

RowSpec(String[], String[], int, int, int)

RowSpec

public RowSpec(java.lang.String[] columnNames,
               java.lang.String[] columnNativeTypes,
               int idColumnPosition,
               int timestampColumnPosition,
               int versionColumnPosition)

Internal use.

Parameters:

columnNames - The first column must always hold the monotonically increasing Row-Ids.

columnNativeTypes - In the same order and number as the names.

idColumnPosition - Position of the Id column in the name/type array.

timestampColumnPosition - Position of a Timestamp-type column in the name/type array, which will be used as a reference for Time based Windows. Use -1 if the Events in this Stream will not be used for such Windows.

versionColumnPosition -

Method Detail

getIdColumnPosition

public int getIdColumnPosition()

Returns:

the idColumnPosition

getTimestampColumnPosition

public int getTimestampColumnPosition()

Returns:

the timestampColumnPosition

getVersionColumnPosition

public int getVersionColumnPosition()

Returns:

the versionColumnPosition

getColumnNames

public java.lang.String[] getColumnNames()

Returns:

Returns the columnNames.

getColumnNativeTypes

public java.lang.String[] getColumnNativeTypes()

Returns:

Returns the columnNativeTypes.

addInfo

public static java.lang.String addInfo(java.lang.String basicJavaType,
                                       RowSpec.Info info,
                                       java.lang.Object value)

A convenience method to add additional information to the Type.

Parameters:

basicJavaType - Ex: java.lang.String

info - Ex: RowSpec.Info.SIZE

value - Ex: 15

Returns:

The basic Java Type appended with additional information.

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object