Uses of Class
com.streambase.sb.CompleteDataType
Package
Description
Provides classes and interfaces fundamental to the Streaming Java API.
Provides classes and interfaces used to author Streaming Unit tests.
-
Uses of CompleteDataType in com.streambase.sb
Modifier and TypeClassDescriptionstatic class
Capture typestatic class
Function typestatic class
List typestatic class
Tuple typeModifier and TypeMethodDescriptionstatic CompleteDataType
Build a random complete data typestatic CompleteDataType
SchemaUtil.createType
(Element element) Create a complete type from XMLstatic CompleteDataType
CompleteDataType.findSuperType
(CompleteDataType t1, CompleteDataType t2) Find a type that t1 and t2 can both promote to safelystatic CompleteDataType
CompleteDataType.forBlob()
Return the complete type for a blob.static CompleteDataType
CompleteDataType.forBlobList()
static CompleteDataType
CompleteDataType.forBool()
Deprecated.static CompleteDataType
CompleteDataType.forBoolean()
Return the complete type for a bool.static CompleteDataType
CompleteDataType.forBoolList()
static CompleteDataType
CompleteDataType.forCapture
(String typeName) Return a capture complete data type with the specified type parameter name.static CompleteDataType
CompleteDataType.forDouble()
Return the complete type for a double.static CompleteDataType
CompleteDataType.forDoubleList()
static CompleteDataType
CompleteDataType.forInt()
Return the complete type for an int.static CompleteDataType
CompleteDataType.forIntList()
static CompleteDataType
CompleteDataType.forList
(CompleteDataType elementType) Return a list complete data type with the specified element typestatic CompleteDataType
CompleteDataType.forLong()
Return the complete type for a long.static CompleteDataType
CompleteDataType.forLongList()
static CompleteDataType
CompleteDataType.forString()
Return the complete type for a string.static CompleteDataType
CompleteDataType.forStringList()
static CompleteDataType
CompleteDataType.forTimestamp()
Return the complete type for a timestamp.static CompleteDataType
CompleteDataType.forTimestampList()
static CompleteDataType
Return a tuple complete data type with the specified schema.Schema.Field.getCompleteDataType()
Return the CompleteDataType of the FieldCompleteDataType.getElementType()
For list collection types, return the complete type of the list's elements.CompleteDataType.ListType.getElementType()
Schema.Field.getElementType()
Return the element type for this field.abstract CompleteDataType
AbstractFunction.getInnerType()
Returns the inner function type if this is a coerced function.BasicFunction.getInnerType()
static CompleteDataType
SchemaUtil.getInnerType
(CompleteDataType cdt) Get element type for complete data typestatic CompleteDataType
SchemaUtil.getInnerType
(Schema.Field f) Get element type for fieldBasicFunction.getReturnType()
CompleteDataType.FunctionType.getReturnType()
CompleteDataType.getReturnType()
For function types, return the return type of the function.Function.getReturnType()
Returns the CompleteDataType for the function's return type.Modifier and TypeMethodDescriptionfinal boolean
CompleteDataType.canAssignFrom
(CompleteDataType other) Check if a value of this type can be assigned a value of the other type.protected boolean
CompleteDataType.canAssignFromImpl
(CompleteDataType other) Method for subclasses to override if they have a broader concept of type.protected boolean
CompleteDataType.FunctionType.canAssignFromImpl
(CompleteDataType other) Method for subclasses to override if they have a broader concept of type.void
Schema.Field.checkType
(CompleteDataType dataType) Check to make sure that the given type is the same as the type of this Fieldprotected static List<?>
DataTypeCopier.copyList
(com.streambase.sb.DataTypeCopier fieldCopier, CompleteDataType destType, List<?> sourceList) a common method to do the list coping(package private) static com.streambase.sb.DataTypeCopier
DataTypeCopier.createCopier
(CompleteDataType sourceType, CompleteDataType destType, EnumSet<TupleCopier.Options> options) Create a DataTypeCopierstatic 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.Field
Schema.createListField
(String name, CompleteDataType elementType) Creates a new Field of type LIST, with the given name and given element typeprotected boolean
CompleteDataType.equalBaseTypes
(CompleteDataType other) Compare wrapped typesboolean
CompleteDataType.CaptureType.equalTypes
(CompleteDataType completeType) boolean
CompleteDataType.FunctionType.equalTypes
(CompleteDataType completeType) boolean
CompleteDataType.ListType.equalTypes
(CompleteDataType completeType) boolean
CompleteDataType.TupleType.equalTypes
(CompleteDataType completeType) static CompleteDataType
CompleteDataType.findSuperType
(CompleteDataType t1, CompleteDataType t2) Find a type that t1 and t2 can both promote to safelyCompleteDataType.forFunction
(Schema argumentSchema, CompleteDataType returnType) Return a function'sCompleteDataType
with the given argument schema and return typestatic CompleteDataType
CompleteDataType.forList
(CompleteDataType elementType) Return a list complete data type with the specified element typeTuple.DefaultTupleFormatter.formatList
(CompleteDataType elementType, List<?> l) Tuple.TupleFormatter.formatList
(CompleteDataType elementType, List<?> l) Return a string representation of the given StreamBase liststatic Object
TupleUtil.generateRandomValue
(Random random, CompleteDataType type, int maxCount, int flags) Build a random value appropriate to the complete data typeT
DataType.Registry.get
(CompleteDataType type) Return the factory for the specified CompleteDataType.static CompleteDataType
SchemaUtil.getInnerType
(CompleteDataType cdt) Get element type for complete data type(package private) static int
TupleUtil.getListLength
(CompleteDataType elementType, List<?> list) Calculate (exact) length of the specified list's serialization in bytesstatic String
SchemaUtil.getNullValueExpr
(CompleteDataType type) Transforms the type to its null value expressionstatic Schema
SchemaUtil.getSchema
(CompleteDataType cdt) Get schema for complete data type(package private) int
TupleUtil.RepMethods.getValueLength
(CompleteDataType completeType, Object value) Get value lengthstatic boolean
SchemaUtil.hasCapture
(CompleteDataType typ) Does complete data type have a capture field?static boolean
SchemaUtil.hasMultiCapture
(CompleteDataType cdt) Does complete data type have multiple capture fieldslong
CompleteDataType.FunctionType.rateCoercion
(CompleteDataType to) long
CompleteDataType.ListType.rateCoercion
(CompleteDataType to) long
CompleteDataType.rateCoercion
(CompleteDataType type) calculate the coercion score to get coerce this → type - by default returns SCORE_PASS or SCORE_FAIL based on equalsstatic long
CompleteDataType.rateCoercion
(CompleteDataType from, CompleteDataType to) Rate coercionlong
CompleteDataType.TupleType.rateCoercion
(CompleteDataType to) long
CompleteDataType.TupleType.rateCoercion
(CompleteDataType to, boolean capture) Rate coercionvoid
SchemaUtil.SchemaTraversal.run
(CompleteDataType cdt, String path) Run traversal(package private) static Schema.Field
Schema.Field.sanitizedField
(int index, CompleteDataType type) Create a sanitized field from the parameters, using cached string name if possible and bypassing identifier validation.(package private) abstract void
TupleUtil.RepMethods.serializeValue
(CompleteDataType valueType, Object value, com.streambase.sb.util.ByteOrderedDataOutput out) Serialize valuestatic List<?>
TupleUtil.setListElement
(String name, CompleteDataType elementType, List<?> list, int index, Object value) Return a new list that's a copy of the supplied list except with the element at the specified index replaced with the specified value, potentially applying the conversions as specified inTuple.setField(Field, Object, com.streambase.sb.util.CSV.FormatInfo)
to the value.static String
TupleJSONUtil.typeObjectToJsonString
(CompleteDataType cdt, Object value, EnumSet<TupleJSONUtil.Options> options) static String
TupleJSONUtil.typeObjectToJsonString
(CompleteDataType cdt, Object value, EnumSet<TupleJSONUtil.Options> options, String timestampFormat) static Object
ReadOnlyTupleByIndexWrapper.wrapObject
(CompleteDataType cdt, Object o) Wrap objectvoid
TupleCSVCharWriter.write
(List<?> list, CompleteDataType elementType, com.streambase.sb.TupleCSVOutputWriter.StringQuoteStyle stringQuoteStyle) Write a list of valuesvoid
TupleCSVOutputWriter.write
(List<?> list, CompleteDataType elementType) Write list of valuesvoid
TupleCSVOutputWriter.write
(List<?> list, CompleteDataType elementType, com.streambase.sb.TupleCSVOutputWriter.StringQuoteStyle stringQuoteStyle) Write list of valuesModifierConstructorDescriptionField
(String name, CompleteDataType completeType, com.streambase.sb.util.Location loc) ConstructorFunctionType
(Schema arguments, CompleteDataType returnType) Constructor(package private)
ListCopier
(CompleteDataType sourceType, CompleteDataType destType, EnumSet<TupleCopier.Options> options) ConstructorListType
(CompleteDataType elementType) Constructor -
Uses of CompleteDataType in com.streambase.sb.unittest
Modifier and TypeMethodDescriptionboolean
FieldBasedTupleComparator.CompareFunctor.compare
(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) abstract boolean
FieldBasedTupleComparator.CompareFunctor.compareImpl
(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) Compare two values expected and actual, usingcomparator
for recursion as necessary.boolean
FieldBasedTupleComparator.DoubleCompareFunctor.compareImpl
(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) boolean
FieldBasedTupleComparator.IgnoreTimestampCompareFunctor.compareImpl
(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) boolean
FieldBasedTupleComparator.ListCompareFunctor.compareImpl
(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) boolean
FieldBasedTupleComparator.NaiveObjectCompareFunctor.compareImpl
(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) boolean
FieldBasedTupleComparator.RegexCompareFunctor.compareImpl
(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) boolean
FieldBasedTupleComparator.TupleCompareFunctor.compareImpl
(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) boolean
FieldBasedTupleComparator.compareValues
(CompleteDataType cdt, Object expected, Object actual) boolean
TupleComparator.compareValues
(CompleteDataType cdt, Object expected, Object actual) Compare two values withCompleteDataType
cdt.
forBoolean()