PySpark 扩展类型

__init__(properties={})

• properties – 数据类型的属性 (可选)。

typeName(cls)

返回 Amazon Glue 类型类的类型（即，类名，其“Type”会从末尾删除）。

• cls – 一个派生自 Amazon Glue 的 DataType 类实例。

fromJsonValue(cls, json_value)

使用 JSON 对象中的值初始化类实例。

• cls – 一个要初始化的 Amazon Glue 类型类。

• json_value – 要从其中加载键-值对的 JSON 对象。

• BinaryType – 二进制数据。

• BooleanType – 布尔值。

• ByteType – 一个字节值。

• DateType – 一个日期时间值。

• DoubleType – 一个双精度浮点值。

• IntegerType – 一个整数值。

• LongType – 一个长整数值。

• NullType – 一个空值。

• ShortType – 一个短整数值。

• StringType – 一个文本字符串。

• TimestampType – 一个时间戳值 (通常以秒为单位，从 1/1/1970 开始)。

• UnknownType – 一个未知类型的值。

__init__(precision=10, scale=2, properties={})

• precision – 十进制数中的位数 (可选；默认值为 10)。

• scale – 小数点右侧的位数 (可选；默认值为 2)。

• properties – 十进制数字的属性 (可选)。

__init__(options)

• options – 正被枚举的选项的列表。

• ArrayType(DataType)

• ChoiceType(DataType)

• MapType(DataType)

• Field(Object)

• StructType(DataType)

• EntityType(DataType)

__init__(elementType=UnknownType(), properties={})

• elementType— 数组中元素的类型（可选；默认为 UnknownType）。

• properties – 数组的属性 (可选)。

__init__(choices=[], properties={})

• choices – 可能选项的列表 (可选)。

• properties – 这些选项的属性 (可选)。

add(new_choice)

将新选项添加到可能的选项列表中。

• new_choice – 要添加到可能选项列表中的选项。

merge(new_choices)

将新选项列表与现有选项列表合并。

• new_choices – 要与现有选项列表合并的新选项列表。

__init__(valueType=UnknownType, properties={})

• valueType— 地图中值的类型（可选；默认为 UnknownType）。

• properties – 映射的属性 (可选)。

__init__(name, dataType, properties={})

• name – 要为字段分配的名称。

• dataType – 要从中创建字段的对象。

• properties – 字段的属性 (可选)。

__init__(fields=[], properties={})

• fields – 要在结构中包括的字段的列表 (类型为 Field) (可选)。

• properties – 结构的属性 (可选)。

add(field)

• field – 要添加到结构中的类型 Field 的对象。

hasField(field)

如果此结构具有同名字段，则返回 True，否则返回 False。

• field – 一个字段名称，或其名称被使用的类型 Field 的对象。

getField(field)

• field – 一个字段名称，或其名称被使用的类型 Field 的对象。如果此结构具有同名字段，则返回它。

• DataSource（对象）

• DataSink（对象）

__init__(j_source, sql_ctx, name)

• j_source – 数据源。

• sql_ctx – SQL 上下文。

• name – 数据源名称。

setFormat(format, **options)

• format – 要为数据源设置的格式。

• options- 要为数据源设置的选项的集合。

__init__(j_sink, sql_ctx)

• j_sink – 要创建的堆栈。

• sql_ctx – 数据接收器的 SQL 上下文。

setFormat(format, **options)

• format – 要为数据接收器设置的格式。

• options- 要为数据接收器设置的选项的集合。

setAccumulableSize(size)

• size – 要设置的可累积大小 (以字节为单位)。

writeFrame(dynamic_frame, info="")

• dynamic_frame – 要编写的 DynamicFrame。

• info – 有关 DynamicFrame 的信息 (可选)。

write(dynamic_frame_or_dfc, info="")

写入 DynamicFrame 或 DynamicFrameCollection。

• dynamic_frame_or_dfc – 将被写入的 DynamicFrame 对象或 DynamicFrameCollection 对象。

• info – 有关将被写入的 DynamicFrame 或 DynamicFrames 的信息 (可选)。