object HiveSchema
- Alphabetic
- By Inheritance
- HiveSchema
- 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
-
def
apply(avroSchema: Schema): Either[AvroSchemaError, String]
Returns a CREATE TABLE statement from the input Avro schema
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
avroFieldToHiveField(field: Field, level: Int): Either[AvroSchemaError, String]
Converts an Avro field definition to an equivalent column definition compatible with HiveQL
Converts an Avro field definition to an equivalent column definition compatible with HiveQL
- field
input Avro field definition
- level
the level of nested records for formatting
- returns
a HiveQL compatible column definition
-
def
avroFieldToHiveField(fields: List[Field], level: Int): Either[AvroSchemaError, String]
Gets a list of Avro field definitions and returns a single string that represents comma+new_line separated of the Hive compatible column definitions.
Gets a list of Avro field definitions and returns a single string that represents comma+new_line separated of the Hive compatible column definitions.
For example,
[{"name":"ruleName","type":"string"},{"name":"ruleVersion","type":"int"}]}returns
ruleName string, ruleVersion int
- fields
list of Avro field definitions
- level
0 for top level and more for the nested records
- returns
comma+new_line separated of Hive definitions
-
def
avroTypeToHiveType(schema: Schema, level: Int): Either[AvroSchemaError, String]
Gets an AVRO type definition of array and converts it to ARRAY in HiveQL compatible field definition.
Gets an AVRO type definition of array and converts it to ARRAY in HiveQL compatible field definition.
- schema
field schema
- returns
column type in HiveQL
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
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
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
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()
-
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()