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.com.tibco.ep.tcs.runtime.config This package contains all the classes and interfaces that manage TIBCO Cloud Streaming flow and block configuration. -
-
Uses of Schema in com.streambase.liveview.client
Methods in com.streambase.liveview.client that return Schema Modifier and Type Method Description SchemaSendTupleInfo. getResponseOutputSchema()SchemaQueryListenerWrapper. getSchema()Getter for theSchemafor the query.SchemaTablePublisher. getSchema()Schema needed to create tuples for the publish method.SchemaSendTupleInfo. getTargetInputSchema()Methods in com.streambase.liveview.client with parameters of type Schema Modifier and Type Method Description voidTableAdminManager. createTable(String tableName, String description, Schema schema, String... primaryKeyFields)Convenience form of the previous method, used if there is only a primary key.voidTableAdminManager. createTable(String tableName, String description, Schema schema, List<List<String>> indices)Create a table on the server without any LVConf which represents it.TupleLiveViewConnection. sendTupleAction(StreamBaseURI sbUri, String targetInputStreamName, Tuple tuple, String responseOutputStreamName, Schema expectedResponseSchema, long timeout, TimeUnit unit)Sends a tuple to an existing StreamBase application.voidQueryListenerWrapper. setSchema(Schema schema)Setter for theSchemafor 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 TableConfigTableConfig. 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 SchemaSchema. EMPTY_SCHEMAAn empty schemastatic SchemaSchemaUtil. EMPTY_SCHEMAAn empty schemastatic SchemaControlStream. SCHEMAControl stream schemaFields in com.streambase.sb with type parameters of type Schema Modifier and Type Field Description static ConcurrentMap<Schema,String>SchemaUtil. NULL_VALUE_EXPR_BY_SCHEMANull value expression cacheMethods in com.streambase.sb that return Schema Modifier and Type Method Description static SchemaSchemaUtil. addFields(Schema base, Schema.Field... additionalFields)Create a new schema augmenting the fields in the base schema with additional fieldsstatic SchemaSchemaUtil. addFields(Schema base, String newName, Schema.Field... additionalFields)Create a new schema augmenting the fields in the base schema with additional fieldsstatic SchemaSchemaUtil. computeOutputSchema(LocatedItem loc, Schema[] schemas, Set<SchemaUtil.CoercionOptions> options, CapturedSchemas capturedSchemas, String errorPrefix)Compute output schemastatic SchemaSchemaUtil. 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 SchemaSchemaUtil. 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 SchemaSchemaUtil. 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 SchemaSchemaUtil. createSchema(Element element, ByteOrder ord, SchemaUtil.SchemaProvider schemaProvider, List<StreamBaseException> errors)Create a schema from XMLstatic SchemaSchemaUtil. determineResultSchema(Schema res, Schema[] options)Select the correct result schema for this field mapper.static SchemaSchemaUtil. expandCaptureFields(LocatedItem loc, Schema schema, Set<SchemaUtil.CoercionOptions> options, CapturedSchemas capturedSchemas)Take a schema which might have capture field, and expand the field.SchemaSchemaMismatchException. getActualSchema()SchemaBasicFunction. getArgumentSchema()SchemaCompleteDataType.FunctionType. getArgumentSchema()SchemaCompleteDataType. getArgumentSchema()For function types, return the argument schema.SchemaFunction. getArgumentSchema()Returns Schema for the input argument types of the function.SchemaTupleCaptureTransformer. getCollapsedSchema()static SchemaSchema. getErrorSchema()SchemaTupleCaptureTransformer. getExpandedSchema()SchemaSchemaMismatchException. getExpectedSchema()SchemaSchema. getLocallyDefinedFields()SchemaSchemaUtil.SchemaProvider. getNamedSchema(String name)A request to provide a Schema for the given name.SchemaCompleteDataType. getSchema()For tuple types, return the tuple's schema.SchemaCompleteDataType.TupleType. getSchema()SchemaSchema.Field. getSchema()Return the schema for this field.static SchemaSchemaUtil. getSchema(CompleteDataType cdt)Get schema for complete data typestatic SchemaSchemaUtil. getSchema(Schema.Field f)Get schema for a schema fieldSchemaStreamProperties. getSchema()Return the stream's SchemaSchemaTuple. getSchema()Return the Schema for this TupleSchemaSchemaUtil.SchemaProvider. getSchemaByHash(byte[] hash)request a schema by hashstatic SchemaSBUtils. newSchema(String xmlString, boolean hasHeader, ByteOrder order)Deprecated.use the version without hasHeaderstatic SchemaSBUtils. newSchema(String xmlString, ByteOrder order)static SchemaSBUtils. newSchema(String name, List<Schema.Field> fields, boolean hasHeader, ByteOrder order)Deprecated.use the version without hasHeaderstatic SchemaSBUtils. newSchema(String name, List<Schema.Field> fields, ByteOrder order)static SchemaSBUtils. newSchema(Element element, boolean hasHeader, ByteOrder order)Deprecated.use the version without hasHeaderstatic SchemaSBUtils. newSchema(Element element, ByteOrder order)static SchemaSchemaUtil. removeFields(Schema base, String... fieldNames)Remove the fields by name from the schema.static SchemaSchemaUtil. 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 approbate comparator for schemasMethods in com.streambase.sb with parameters of type Schema Modifier and Type Method Description static SchemaSchemaUtil. addFields(Schema base, Schema.Field... additionalFields)Create a new schema augmenting the fields in the base schema with additional fieldsstatic SchemaSchemaUtil. addFields(Schema base, String newName, Schema.Field... additionalFields)Create a new schema augmenting the fields in the base schema with additional fieldsstatic StringAbstractFunction. buildFunctionRep(String name, Schema argSchema, String returnType, String body)static byte[]SchemaUtil. buildHash(Schema schema, boolean includeFieldNames)Build hash for schemastatic SchemaSchemaUtil. computeOutputSchema(LocatedItem loc, Schema[] schemas, Set<SchemaUtil.CoercionOptions> options, CapturedSchemas capturedSchemas, String errorPrefix)Compute output schemastatic voidSchemaUtil. copyAllDescriptionsForEquivalentFields(Schema source, Schema target)For all fields insource, when they are present intarget, descriptions are copied.static Schema.FieldSchema. createFunctionField(String fieldName, Schema argumentSchema, CompleteDataType returnType)Creates a new Field of type FUNCTION, with the given name, argument list and return type.static SchemaSchemaUtil. 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 SchemaSchemaUtil. 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 SchemaSchemaUtil. 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.FieldSchema. createTupleField(String name, Schema schema)Creates a new Field of type TUPLE, with the given name and given schemastatic ElementSchemaUtil. createXmlElement(Schema schema, SchemaUtil.SchemaProvider schemaProvider, EnumSet<SchemaUtil.CopyOptions> options)Create and return the XML for the specified schema.static ElementSchemaUtil. createXmlElement(Schema schema, Document document, SchemaUtil.SchemaProvider schemaProvider)Create and return the XML for the specified schema.static ElementSchemaUtil. createXmlElement(Schema schema, Document document, SchemaUtil.SchemaProvider schemaProvider, EnumSet<SchemaUtil.CopyOptions> options)Create and return the XML for the specified schema.static ElementSchemaUtil. 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 SchemaSchemaUtil. determineResultSchema(Schema res, Schema[] options)Select the correct result schema for this field mapper.booleanSchema. equalsNoCapture(Schema scm)Compare schemas without capture fieldsstatic SchemaSchemaUtil. 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)Find all capture fields in schemastatic CompleteDataType.FunctionTypeCompleteDataType. forFunction(Schema argumentSchema, CompleteDataType returnType)Return a function'sCompleteDataTypewith the given argument schema and return typestatic CompleteDataTypeCompleteDataType. forTuple(Schema schema)Return a tuple complete data type with the specified schema.static intSchemaUtil. 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)Get field type hashstatic List<String>SchemaUtil. getParentSchemaNames(Schema schema)Get the names of the parent schemas for the given schemastatic booleanSchemaUtil. hasCapture(Schema s)Does schema have a capture field?static booleanSchemaUtil. hasMultiCapture(Schema s)Does schema have multiple capture fields?booleanSchema. 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.booleanSchema. 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 SchemaSchemaUtil. removeFields(Schema base, String... fieldNames)Remove the fields by name from the schema.voidReadOnlyTupleRep. reset(Schema newSchema, byte[] data, int offset, ByteArrayUtils bau)reset this tuple with new data...voidSchemaUtil.SchemaTraversal. run(Schema schema, String path)Run the schema visitorbooleanSchema. sameFieldsAs(Schema other)Returns true if this schema has the same field types and names in the same order as another Schema.static booleanSchemaUtil. sameFieldsIgnoreOrder(Schema one, Schema two)Note: if you call this, and are thinking of throwing an exception when things don't match...static booleanSchemaUtil. sameFieldsIncludingDescriptions(Schema one, Schema two)Note: if you call this, and are thinking of throwing an exception when things don't match...booleanSchema. sameFieldTypes(Schema other)Returns true if this schema has the same field types in the same order as another Schemastatic SchemaSchemaUtil. sanitizeFieldNames(Schema origSchema)Sanitize field names so that they are genericvoidSchemaUtil.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 SchemaSchemaUtil. 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 SchemaSchemaUtil. 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)ConstrutorReadOnlyTupleByIndexWrapper(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)ConstructorTupleRep(Schema schema, ByteOrder byteOrder)ConstructorTupleType(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 SchemaDequeueResult. getSchema()Returns the schema for the tuples dequeued, may return nullSchemaStreamBaseClient. getSchemaByHash(byte[] hash)Return the Schema object for the given hash valueSchemaXmlRpcAdmin. getSchemaByHash(long timeoutMS, byte[] hash)SchemaStreamBaseClient. getSchemaByName(String name)Return the Schema object for the given name.SchemaXmlRpcAdmin. getSchemaByName(long timeoutMS, String schemaName)SchemaStreamBaseClient. 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 SchemaFeedSimTupleInputStream. 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 SchemaStreamBaseMonitor. STAT_SCHEMAThe stats schema.static SchemaStreamBaseMonitor. STAT_SCHEMA_V3The v3 stats schema.Methods in com.streambase.sb.monitor that return Schema Modifier and Type Method Description SchemaStreamBaseMonitor. 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 SchemaOperator. getDynamicVariablesSchema()Retrieves a Schema containing information about every dynamic variable available to the module this operator is contained in.SchemaOperator. getInputSchema(int port)Returns the schema of an input port.SchemaOperator. getNamedSchema(String name)SchemaOperator. 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.SchemaOperator. getRuntimeInputSchema(int port)Returns the schema of an input port at runtime.SchemaOperator. getRuntimeOutputSchema(int outputPort)Return the output schema that should actually use toOperator.sendOutput(int, Tuple)orOperator.sendOutputAsync(int, Tuple).SchemaTableAccessor. getSchema()The schema for rows in this table.SchemaOperator. getSchemaForCapture(String captureName, int depth)Finds the schema for the given capture name in the context that this operator is running under.SchemaOperator. getTypecheckInputSchema(int port)Returns the schema of an input port that was set at application typecheck time.SchemaOperator. getTypecheckOutputSchema(int outputPort)Return the output schema as set by typecheck.SchemaOperator. 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 TupleCaptureTransformerOperator. 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.PreparedQueryTableAccessor. prepare(String predicate, Schema args)Prepare an index-accessing query.SchemaOperator. 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 withUIHintsthat 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 withUIHintsthat 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 SchemaDequeuer. getSchema()SchemaEnqueuer. getSchema()Methods in com.streambase.sb.unittest with parameters of type Schema Modifier and Type Method Description abstract TupleAbstractTupleMaker. createTuple(Schema schema, T t)TupleCSVTupleMaker. createTuple(Schema schema, String str)TupleJSONSingleQuotesTupleMaker. createTuple(Schema schema, String str)TupleJSONTupleMaker. createTuple(Schema schema, String str)TupleObjectArrayTupleMaker. createTuple(Schema schema, Object[] objs)TupleTupleMaker. createTuple(Schema schema, T t)create aTuples 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 multipleTuples from input objectsList<Tuple>TupleMaker. createTuples(Schema schema, T... t)create multipleTuples from input objects -
Uses of Schema in com.tibco.ep.tcs.runtime.config
Methods in com.tibco.ep.tcs.runtime.config that return Schema Modifier and Type Method Description SchemaTupleSchemaFactory. createSchema(com.typesafe.config.Config sourceSchemaParent, String tupleSchemaPath, FlowValidationProblemList problems)Create a new EventFlow tuple schema given a HOCON configuration and a property name in that configuration that points to the schema.SchemaDataInputPortConfig. getTupleSchema()This port's tuple schema, null if unknown.SchemaICustomTupleSchemaProducer. getTupleSchema(com.typesafe.config.Config config, TupleSchemaFactory tupleSchemaFactory, FlowValidationProblemList problems)Produce a tuple schema, null with problems added if unknownMethods in com.tibco.ep.tcs.runtime.config with parameters of type Schema Modifier and Type Method Description DataInputPortConfigDataInputPortConfig. setTupleSchema(Schema tupleSchema)Set this port's tuple schema, null if unknown.static com.typesafe.config.ConfigTupleSchemaFactory. toJSONSchema(Schema schema)Convert an EventFlow tuple schema to JSON Schema.static StringTupleSchemaFactory. toSchemaXML(Schema schema)Convert an EventFlow tuple schema object to its XML form.
-