object FlatSchema extends Serializable
- Alphabetic
- By Inheritance
- FlatSchema
- Serializable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
build(schema: Schema): FlatSchema
Build FlatSchema from a single schema.
Build FlatSchema from a single schema. Must be used only if there's only one schema
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- val empty: FlatSchema
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
extractProperties(source: SchemaList): Properties
Main function for flattening multiple schemas, preserving their lineage in their properties.
Main function for flattening multiple schemas, preserving their lineage in their properties. If user software (e.g. RDB Shredder) produces unexpected list of columns - this is the culprit
Builds subschemas which are ordered according to nullness of field, name of field and which version field is added
- source
List of ordered schemas to create ordered subschemas
- returns
list of typed pointers which are ordered according to criterias specified above
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getName(jsonPointer: SchemaPointer): String
Get normalized name
- def getRequired(cur: SchemaPointer, schema: Schema): Set[SchemaPointer]
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isLeaf(schema: Schema): Boolean
Redshift-specific
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
postProcess(subschemas: SubSchemas): List[(SchemaPointer, Schema)]
Sort and clean-up
- def save(pointer: SchemaPointer, schema: Schema): State[FlatSchema, Unit]
-
def
shouldBeIgnored(pointer: SchemaPointer, flatSchema: FlatSchema): Boolean
This property shouldn't have been added (FlatSchemaSpec.e4)
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()