The Schema type exposes the following members.

Constructors

  NameDescription
Public methodSchema()()()()
Create a new schema object
Public methodSchema(String)
Create a new schema object specifying a schema like "A,B:int,C:double" for user defined type schema string must contain C# name of the type do not use this method with CLR name of type (Type.FullName) In all other cases create empty schema and add columns using ColumnInfo(string name, Type type)
Public methodSchema(array<String>[]()[][])
Create a new schema object specifying a schema like {"A", "B:int" , "C:double"} for user defined type column string must contain C# name of the type do not use this method with CLR name of type (Type.FullName) In all other cases create empty schema and add columns using ColumnInfo(string name, Type type)

Methods

  NameDescription
Public methodAdd
Add another column to the schema
Public methodAddRange
Add more columns to the schema
Public methodAddScopeCEPColumns
Public methodClone
Create a new schema object that mirrors the current one The resulting schema will have the same column names and column types, in the same order, but it does not claim that output rows with this schema are identical to some input row.
Public methodCloneWithSource
Clone a schema and set the Source of each column to the matching input column. Input rows have to be passed through (or copied) to output rows with this schema unchanged.
Public methodContains
Returns true if there is a column named specified by name
Public methodGetString()()()()
Returns the string repesentation of this schema
Public methodGetString(Boolean)
Returns the string repesentation of this object
Public methodIndexOf
Get the position of the ColumnInfo with this name in this schema
Public methodMerge
Merge with other schema
Public methodPassThrough Obsolete.
Obsolete -- please use schema.CloneWithSource() instead. The user defined object will pass through input rows unchanged as output rows
Public methodRemoveScopeCEPColumns
Public methodSetTable
Sets the table.
Public methodToString
Returns string representation of this schema.
(Overrides ObjectToString()()()().)
Public methodTryToAddRange
Add more columns to the schema if not present already.

Properties

  NameDescription
Public propertyColumns
Enumerable of Schema columns
Public propertyCount
Returns the number of columns
Public propertyItem[([( Int32])])
Access the ith ColumnInfo from a Schema
Public propertyItem[([( String])])
Deprecated: please use IndexOf(name) instead Get the position of the ColumnInfo with this name in this schema Eventually this will be changed to give the actual ColumnInfo instead
Public propertyOrderingList
Rows in this RowSet are ordered by OrderingList (which is a sequence of (column,ASC/DESC) pairs) The semantics vary a bit across UDOs: For extractors and processors, each vertex output rows in OrderingList order, since there is a single invocation of the processor/extractor per vertex For reducers and combiners, the vertex calls the UDO multiple times, once per group of ON columns. Stream-based reducers/combiners sort the inputs on the ON columns. If those are pass-through, the output is sorted by the ON columns In addition to that sort, we attach the ordering list. Example: REDUCE A ON a, b USING SampleReducer Suppose that SampleReducer has "a" as a pass-through column and declares "c,a" as an OrderlingList Also, assume that the stream-based reducer sorts the input on "a,b". The output of the reducer, due the pass-through column, is sorted by "a". Additionally, it is sorted by "c" within each group (the last "a" in "c,a" is redundant) So the reducer would deliver sorting on "a,c"
Public propertyPartitioningSet
All columns in PartitioningSet with the same value are located in the same vertex RowSet
Public propertyTable
Not Supported. The name of the table. This is only set by the system for the inputs to combiners, both for Produces() and Combine(). For all schemas other than the inputs to a Combiner, schema.Table is null, since in all other cases column names are already distinct.

See Also