Uses of Class
com.streambase.sb.Schema
-
Packages that use Schema Package Description com.streambase.liveview.client Provides classes and interfaces fundamental to the TIBCO LiveView Java API.com.streambase.liveview.client.dynamictables Provides classes to configure table options.com.streambase.sb Provides classes and interfaces fundamental to the TIBCO StreamBase Java API.com.streambase.sb.client Provides classes and interfaces used to communicate with a StreamBase server.com.streambase.sb.feedsim Provides abstract classes to extend feedsim input sources.com.streambase.sb.monitor Provides classes and interfaces to monitor the behavior of a running StreamBase server.com.streambase.sb.operator Provides classes and interfaces to add custom operators to StreamBase applications.com.streambase.sb.operator.parameter Provides classes and interfaces to specify parameters for custom operators.com.streambase.sb.unittest Provides classes and interfaces used to author StreamBase Unit tests. -
-
Uses of Schema in com.streambase.liveview.client
Methods in com.streambase.liveview.client that return Schema Modifier and Type Method Description Schema
SendTupleInfo. getResponseOutputSchema()
Schema
QueryListenerWrapper. getSchema()
Getter for theSchema
for the query.Schema
TablePublisher. getSchema()
Schema needed to create tuples for the publish method.Schema
SendTupleInfo. getTargetInputSchema()
Methods in com.streambase.liveview.client with parameters of type Schema Modifier and Type Method Description void
TableAdminManager. createTable(String tableName, String description, Schema schema, String... primaryKeyFields)
Convenience form of the previous method, used if there is only a primary key.void
TableAdminManager. createTable(String tableName, String description, Schema schema, List<List<String>> indices)
Create a table on the server without any LVConf which represents it.Tuple
LiveViewConnection. sendTupleAction(StreamBaseURI sbUri, String targetInputStreamName, Tuple tuple, String responseOutputStreamName, Schema expectedResponseSchema, long timeout, TimeUnit unit)
Sends a tuple to an existing StreamBase application.void
QueryListenerWrapper. setSchema(Schema schema)
Setter for theSchema
for the query.Constructors in com.streambase.liveview.client with parameters of type Schema Constructor Description AbstractTable(Schema schema, String keyFieldNamesCSV)
AbstractTable(Schema schema, List<String> keyFieldNames)
SendTupleInfo(StreamBaseURI sbUri, String inputStreamName, String outputStreamName, Schema inputSchema, Schema outputSchema)
-
Uses of Schema in com.streambase.liveview.client.dynamictables
Methods in com.streambase.liveview.client.dynamictables with parameters of type Schema Modifier and Type Method Description TableConfig
TableConfig. setSchema(Schema sbSchema)
This method is used to set the schema for the table being configured. -
Uses of Schema in com.streambase.sb
Fields in com.streambase.sb declared as Schema Modifier and Type Field Description static Schema
Schema. EMPTY_SCHEMA
An empty schemastatic Schema
SchemaUtil. EMPTY_SCHEMA
static Schema
ControlStream. SCHEMA
Methods in com.streambase.sb that return Schema Modifier and Type Method Description static Schema
SchemaUtil. addFields(Schema base, Schema.Field... additionalFields)
Create a new schema augmenting the fields in the base schema with additional fieldsstatic Schema
SchemaUtil. addFields(Schema base, String newName, Schema.Field... additionalFields)
Create a new schema augmenting the fields in the base schema with additional fieldsstatic Schema
SchemaUtil. computeOutputSchema(LocatedItem loc, Schema[] schemas, Set<SchemaUtil.CoercionOptions> options, CapturedSchemas capturedSchemas, String errorPrefix)
static Schema
SchemaUtil. createSchema(String name, Schema definedHere, List<Schema> parentSchemas, Location loc)
Create a new schema with the given parent schemas and the given fields defined here.static Schema
SchemaUtil. createSchema(String name, Schema definedHere, List<Schema> parentSchemas, Location loc, List<StreamBaseException> storeExceptions)
Create a new schema with the given parent schemas and the given fields defined here.static Schema
SchemaUtil. createSchema(String name, Schema definedHere, List<String> parentSchemaNames, SchemaUtil.SchemaProvider provider, Location loc, List<StreamBaseException> storeExceptions)
Create a new schema with the given parent schema names and the given fields defined here.static Schema
SchemaUtil. createSchema(Element element, ByteOrder ord, SchemaUtil.SchemaProvider schemaProvider, List<StreamBaseException> errors)
static Schema
SchemaUtil. determineResultSchema(Schema res, Schema[] options)
Select the correct result schema for this field mapper.static Schema
SchemaUtil. expandCaptureFields(LocatedItem loc, Schema schema, Set<SchemaUtil.CoercionOptions> options, CapturedSchemas capturedSchemas)
Take a schema which might have capture field, and expand the field.Schema
SchemaMismatchException. getActualSchema()
Schema
BasicFunction. getArgumentSchema()
Schema
CompleteDataType.FunctionType. getArgumentSchema()
Schema
CompleteDataType. getArgumentSchema()
For function types, return the argument schema.Schema
Function. getArgumentSchema()
Returns Schema for the input argument types of the function.Schema
TupleCaptureTransformer. getCollapsedSchema()
static Schema
Schema. getErrorSchema()
Schema
TupleCaptureTransformer. getExpandedSchema()
Schema
SchemaMismatchException. getExpectedSchema()
Schema
Schema. getLocallyDefinedFields()
Schema
SchemaUtil.SchemaProvider. getNamedSchema(String name)
A request to provide a Schema for the given name.Schema
CompleteDataType. getSchema()
For tuple types, return the tuple's schema.Schema
CompleteDataType.TupleType. getSchema()
Schema
Schema.Field. getSchema()
Return the schema for this field.static Schema
SchemaUtil. getSchema(CompleteDataType cdt)
static Schema
SchemaUtil. getSchema(Schema.Field f)
Schema
StreamProperties. getSchema()
Return the stream's SchemaSchema
Tuple. getSchema()
Return the Schema for this TupleSchema
SchemaUtil.SchemaProvider. getSchemaByHash(byte[] hash)
request a schema by hashstatic Schema
SBUtils. newSchema(String xmlString, boolean hasHeader, ByteOrder order)
Deprecated.use the version without hasHeaderstatic Schema
SBUtils. newSchema(String xmlString, ByteOrder order)
static Schema
SBUtils. newSchema(String name, List<Schema.Field> fields, boolean hasHeader, ByteOrder order)
Deprecated.use the version without hasHeaderstatic Schema
SBUtils. newSchema(String name, List<Schema.Field> fields, ByteOrder order)
static Schema
SBUtils. newSchema(Element element, boolean hasHeader, ByteOrder order)
Deprecated.use the version without hasHeaderstatic Schema
SBUtils. newSchema(Element element, ByteOrder order)
static Schema
SchemaUtil. removeFields(Schema base, String... fieldNames)
Remove the fields by name from the schema.static Schema
SchemaUtil. sanitizeFieldNames(Schema origSchema)
Sanitize field names so that they are genericMethods in com.streambase.sb that return types with arguments of type Schema Modifier and Type Method Description List<Schema>
Schema. getParentSchemas()
static List<Schema>
SchemaUtil. getSchemasFromNames(List<String> names, SchemaUtil.SchemaProvider schemaProvider)
Given a schema provider, get all the schemas for the given schema namesstatic Map<byte[],Schema>
SchemaUtil. newSchemaMap()
create a Map<> with the approrate comparator for schemasMethods in com.streambase.sb with parameters of type Schema Modifier and Type Method Description static Schema
SchemaUtil. addFields(Schema base, Schema.Field... additionalFields)
Create a new schema augmenting the fields in the base schema with additional fieldsstatic Schema
SchemaUtil. addFields(Schema base, String newName, Schema.Field... additionalFields)
Create a new schema augmenting the fields in the base schema with additional fieldsstatic String
AbstractFunction. buildFunctionRep(String name, Schema argSchema, String returnType, String body)
static byte[]
SchemaUtil. buildHash(Schema schema, boolean includeFieldNames)
static Schema
SchemaUtil. computeOutputSchema(LocatedItem loc, Schema[] schemas, Set<SchemaUtil.CoercionOptions> options, CapturedSchemas capturedSchemas, String errorPrefix)
static void
SchemaUtil. copyAllDescriptionsForEquivalentFields(Schema source, Schema target)
For all fields insource
, when they are present intarget
, descriptions are copied.static Schema.Field
Schema. createFunctionField(String fieldName, Schema argumentSchema, CompleteDataType returnType)
Creates a new Field of type FUNCTION, with the given name, argument list and return type.static Schema
SchemaUtil. createSchema(String name, Schema definedHere, List<Schema> parentSchemas, Location loc)
Create a new schema with the given parent schemas and the given fields defined here.static Schema
SchemaUtil. createSchema(String name, Schema definedHere, List<Schema> parentSchemas, Location loc, List<StreamBaseException> storeExceptions)
Create a new schema with the given parent schemas and the given fields defined here.static Schema
SchemaUtil. createSchema(String name, Schema definedHere, List<String> parentSchemaNames, SchemaUtil.SchemaProvider provider, Location loc, List<StreamBaseException> storeExceptions)
Create a new schema with the given parent schema names and the given fields defined here.static Schema.Field
Schema. createTupleField(String name, Schema schema)
Creates a new Field of type TUPLE, with the given name and given schemastatic Element
SchemaUtil. createXmlElement(Schema schema, SchemaUtil.SchemaProvider schemaProvider, EnumSet<SchemaUtil.CopyOptions> options)
Create and return the XML for the specified schema.static Element
SchemaUtil. createXmlElement(Schema schema, Document document, SchemaUtil.SchemaProvider schemaProvider)
Create and return the XML for the specified schema.static Element
SchemaUtil. createXmlElement(Schema schema, Document document, SchemaUtil.SchemaProvider schemaProvider, EnumSet<SchemaUtil.CopyOptions> options)
Create and return the XML for the specified schema.static Element
SchemaUtil. createXmlElement(Schema schema, Node parent, SchemaUtil.SchemaProvider schemaProvider, EnumSet<SchemaUtil.CopyOptions> options)
Create and return the XML for the specified schema and add the XML as a child of the specified parent.static Schema
SchemaUtil. determineResultSchema(Schema res, Schema[] options)
Select the correct result schema for this field mapper.boolean
Schema. equalsNoCapture(Schema scm)
Compare schemas without capture fieldsstatic Schema
SchemaUtil. expandCaptureFields(LocatedItem loc, Schema schema, Set<SchemaUtil.CoercionOptions> options, CapturedSchemas capturedSchemas)
Take a schema which might have capture field, and expand the field.static List<String>
SchemaUtil. findCaptures(Schema s)
static CompleteDataType.FunctionType
CompleteDataType. forFunction(Schema argumentSchema, CompleteDataType returnType)
Return a function'sCompleteDataType
with the given argument schema and return typestatic CompleteDataType
CompleteDataType. forTuple(Schema schema)
Return a tuple complete data type with the specified schema.static int
SchemaUtil. getApproximateSize(Schema schema)
Calculates an estimate (does not account for variable-sized types) for the size of a tuple with this schema, including the header and null mask.static byte[]
SchemaUtil. getFieldTypeHash(Schema schema)
static List<String>
SchemaUtil. getParentSchemaNames(Schema schema)
Get the names of the parent schemas for the given schemastatic boolean
SchemaUtil. hasCapture(Schema s)
static boolean
SchemaUtil. hasMultiCapture(Schema s)
boolean
Schema. isSubsetOf(Schema schema)
Returns true if this schema's fields are a subset of the supplied schema's fields Does not recursively test nested schemas for subsetness.static boolean
SchemaUtil. isSuperSet(Schema expectedParent, Schema expectedChild)
boolean
Schema. isSupersetOf(Schema schema)
Returns true if this schema's fields are a superset of the supplied schema's fields Does not recursively test nested schemas for subsetness.static Schema
SchemaUtil. removeFields(Schema base, String... fieldNames)
Remove the fields by name from the schema.void
ReadOnlyTupleRep. reset(Schema newSchema, byte[] data, int offset, ByteArrayUtils bau)
reset this tuple with new data...void
SchemaUtil.SchemaTraversal. run(Schema schema, String path)
Run the schema visitorboolean
Schema. sameFieldsAs(Schema other)
Returns true if this schema has the same field types and names in the same order as another Schema.static boolean
SchemaUtil. sameFieldsIgnoreOrder(Schema one, Schema two)
Note: if you call this, and are thinking of throwing an exception when things don't match...static boolean
SchemaUtil. sameFieldsIncludingDescriptions(Schema one, Schema two)
Note: if you call this, and are thinking of throwing an exception when things don't match...boolean
Schema. sameFieldTypes(Schema other)
Returns true if this schema has the same field types in the same order as another Schemastatic Schema
SchemaUtil. sanitizeFieldNames(Schema origSchema)
Sanitize field names so that they are genericvoid
SchemaUtil.SchemaTraversal. visitSchema(Schema schema, String fieldPath)
This method will be called for each and every schemaMethod parameters in com.streambase.sb with type arguments of type Schema Modifier and Type Method Description static Schema
SchemaUtil. createSchema(String name, Schema definedHere, List<Schema> parentSchemas, Location loc)
Create a new schema with the given parent schemas and the given fields defined here.static Schema
SchemaUtil. createSchema(String name, Schema definedHere, List<Schema> parentSchemas, Location loc, List<StreamBaseException> storeExceptions)
Create a new schema with the given parent schemas and the given fields defined here.Constructors in com.streambase.sb with parameters of type Schema Constructor Description CompiledTuple(Schema schema)
ConstructorField(String name, DataType dataType, Schema s)
Deprecated.UseField(String, CompleteDataType)
instead with new Schema(name, CompleteDataType.forTuple(s)), orcreateTupleField(String, Schema)
FunctionType(Schema arguments, CompleteDataType returnType)
ConstructorReadOnlyCompositeTuple(Schema compositeSchema, Schema... baseSchemas)
Create a Tuple with the given compositeSchema.ReadOnlyCompositeTuple(Schema compositeSchema, Tuple... tuples)
Create a Tuple with the given compositeSchema.ReadOnlyTuple(Schema schema)
ReadOnlyTupleByIndexWrapper(Schema derived, Tuple baseTuple)
Create a Tuple WrapperReadOnlyTupleRep(Schema schema, byte[] data, int offset, ByteArrayUtils bau)
Create a ReadOnlyTupleRep from a serialized tupleReadOnlyTupleRep(Schema schema, byte[] data, int offset, ByteOrder b)
Create a ReadOnlyTupleRep from a serialized tupleSchema(Schema baseSchema)
Construct a Schema from another schemaSchema(String name, Schema baseSchema)
Construct a Schema with a new name from another schemaSchemaMismatchException(LocatedItem loc, String msg, Schema exp, Schema act)
TupleCopier(Schema sourceSchema, Schema destSchema, boolean strict)
Create the TupleCopier.TupleCopier(Schema sourceSchema, Schema destSchema, EnumSet<TupleCopier.Options> options)
Create the TupleCopier.TupleRep(Schema schema, ByteArrayUtils bau)
TupleRep(Schema schema, ByteOrder byteOrder)
TupleType(Schema schema)
Constructor -
Uses of Schema in com.streambase.sb.client
Methods in com.streambase.sb.client that return Schema Modifier and Type Method Description Schema
DequeueResult. getSchema()
Returns the schema for the tuples dequeued, may return nullSchema
StreamBaseClient. getSchemaByHash(byte[] hash)
Return the Schema object for the given hash valueSchema
XmlRpcAdmin. getSchemaByHash(long timeoutMS, byte[] hash)
Schema
StreamBaseClient. getSchemaByName(String name)
Return the Schema object for the given name.Schema
XmlRpcAdmin. getSchemaByName(long timeoutMS, String schemaName)
Schema
StreamBaseClient. getSchemaForStream(String streamName)
Return the schema of a stream. -
Uses of Schema in com.streambase.sb.feedsim
Methods in com.streambase.sb.feedsim that return Schema Modifier and Type Method Description abstract Schema
FeedSimTupleInputStream. getSchema()
This method must return the Schema of the data to be returned by readTuple() -
Uses of Schema in com.streambase.sb.monitor
Fields in com.streambase.sb.monitor declared as Schema Modifier and Type Field Description static Schema
StreamBaseMonitor. STAT_SCHEMA
The stats schema.static Schema
StreamBaseMonitor. STAT_SCHEMA_V3
The v3 stats schema.Methods in com.streambase.sb.monitor that return Schema Modifier and Type Method Description Schema
StreamBaseMonitor. getStatsSchema()
Get the stats schema -
Uses of Schema in com.streambase.sb.operator
Methods in com.streambase.sb.operator that return Schema Modifier and Type Method Description Schema
Operator. getDynamicVariablesSchema()
Retrieves a Schema containing information about every dynamic variable available to the module this operator is contained in.Schema
Operator. getInputSchema(int port)
Returns the schema of an input port.Schema
Operator. getNamedSchema(String name)
Schema
Operator. getOutputSchema(int outputPort)
Return the output schema for the given output port (zero-based).Schema[]
Operator. getProposedInputSchemas(String mainName)
Override to provide schemas that Studio will offer to users to import into their projects.Schema[]
Operator. getProposedOutputSchemas(String mainName)
Override to provide schemas that Studio will offer to users to import into their projects.Schema
Operator. getRuntimeInputSchema(int port)
Returns the schema of an input port at runtime.Schema
Operator. getRuntimeOutputSchema(int outputPort)
Return the output schema that should actually use toOperator.sendOutput(int, Tuple)
orOperator.sendOutputAsync(int, Tuple)
.Schema
TableAccessor. getSchema()
The schema for rows in this table.Schema
Operator. getSchemaForCapture(String captureName, int depth)
Finds the schema for the given capture name in the context that this operator is running under.Schema
Operator. getTypecheckInputSchema(int port)
Returns the schema of an input port that was set at application typecheck time.Schema
Operator. getTypecheckOutputSchema(int outputPort)
Return the output schema as set by typecheck.Schema
Operator. setOutputSchema(int port, Schema outputSchema)
Sets the output schema for the given output port (port #'s are zero based).Methods in com.streambase.sb.operator with parameters of type Schema Modifier and Type Method Description TupleCaptureTransformer
Operator. getTupleCaptureTransformer(Schema s)
Get a TupleCaptureTransformer capable of translating tuples with the given schema to the equivalent schema with all the capture fields expanded out, and translating expanded tuples back into tuples with the given schema This method may only be called at runtime; the exact schemas of any capture fields are not fully determined at typecheck time.PreparedQuery
TableAccessor. prepare(String predicate, Schema args)
Prepare an index-accessing query.Schema
Operator. setOutputSchema(int port, Schema outputSchema)
Sets the output schema for the given output port (port #'s are zero based). -
Uses of Schema in com.streambase.sb.operator.parameter
Methods in com.streambase.sb.operator.parameter that return Schema Modifier and Type Method Description Schema[]
StudioAssistSchemaFieldPicker. getSchemasForFieldPicker(String propertyName, Schema[] inputSchemas)
Assists Studio in presenting a schema field picker to the user, forString[]
property types withUIHints
that have setUIHints.setAssociateFieldPicker(boolean)
totrue
.Methods in com.streambase.sb.operator.parameter with parameters of type Schema Modifier and Type Method Description Schema[]
StudioAssistSchemaFieldPicker. getSchemasForFieldPicker(String propertyName, Schema[] inputSchemas)
Assists Studio in presenting a schema field picker to the user, forString[]
property types withUIHints
that have setUIHints.setAssociateFieldPicker(boolean)
totrue
. -
Uses of Schema in com.streambase.sb.unittest
Methods in com.streambase.sb.unittest that return Schema Modifier and Type Method Description Schema
Dequeuer. getSchema()
Schema
Enqueuer. getSchema()
Methods in com.streambase.sb.unittest with parameters of type Schema Modifier and Type Method Description abstract Tuple
AbstractTupleMaker. createTuple(Schema schema, T t)
Tuple
CSVTupleMaker. createTuple(Schema schema, String str)
Tuple
JSONSingleQuotesTupleMaker. createTuple(Schema schema, String str)
Tuple
JSONTupleMaker. createTuple(Schema schema, String str)
Tuple
ObjectArrayTupleMaker. createTuple(Schema schema, Object[] objs)
Tuple
TupleMaker. createTuple(Schema schema, T t)
create aTuple
s from an input objectList<Tuple>
AbstractTupleMaker. createTuples(Schema schema, Collection<T> ts)
List<Tuple>
AbstractTupleMaker. createTuples(Schema schema, T... ts)
List<Tuple>
TupleMaker. createTuples(Schema schema, Collection<T> t)
create multipleTuple
s from input objectsList<Tuple>
TupleMaker. createTuples(Schema schema, T... t)
create multipleTuple
s from input objects
-