gravitino.dto.rel.partitioning.json_serdes.partitioning_serdes.PartitioningSerdes

class gravitino.dto.rel.partitioning.json_serdes.partitioning_serdes.PartitioningSerdes

Bases: SerdesUtilsBase, JsonSerializable[Partitioning]

Custom JSON serializer/deserializer for PartitionDTO objects.

__init__()

Methods

__init__()

deserialize(data)

Deserialize the given JSON data to the corresponding Partitioning object.

serialize(data_type)

Serialize the given PartitionDTO object.

Attributes

ASSIGNMENTS_NAME

CATALOG_STRING

DATA_TYPE

DECIMAL_PATTERN

DIRECTION

EXPRESSION_TYPE

EXTERNAL

FIELDS

FIELD_NAME

FIELD_NAMES

FIXEDCHAR_PATTERN

FIXED_PATTERN

FUNCTION_ARGS

FUNCTION_NAME

IDENTITY_PARTITION_VALUES

INDEX_FIELD_NAMES

INDEX_NAME

INDEX_TYPE

LIST

LIST_ELEMENT_NULLABLE

LIST_ELEMENT_TYPE

LIST_PARTITION_LISTS

LITERAL_VALUE

MAP

MAP_KEY_TYPE

MAP_VALUE_NULLABLE

MAP_VALUE_TYPE

NON_PRIMITIVE_TYPES

NULL_ORDERING

NUMBER

NUM_BUCKETS

PARTITION_NAME

PARTITION_PROPERTIES

PARTITION_TYPE

PRIMITIVE_AND_NULL_TYPES

RANGE_PARTITION_LOWER

RANGE_PARTITION_UPPER

SORT_TERM

STRATEGY

STRUCT

STRUCT_FIELD_COMMENT

STRUCT_FIELD_NAME

STRUCT_FIELD_NULLABLE

TIMESTAMP_PATTERN

TIMESTAMP_TZ_PATTERN

TIME_PATTERN

TYPE

TYPES

UNION

UNION_TYPES

UNPARSED

UNPARSED_EXPRESSION

UNPARSED_TYPE

VARCHAR_PATTERN

WIDTH

classmethod deserialize(data: Dict[str, Any]) Partitioning

Deserialize the given JSON data to the corresponding Partitioning object.

Args:

data (Dict[str, Any]): The JSON data object to be deserialized.

Returns:

Partitioning: The deserialized result.

Raises:

IllegalArgumentException: If there’s illegal arguments in the given JSON data.

classmethod serialize(data_type: Partitioning) Dict[str, Any]

Serialize the given PartitionDTO object.

Args:

data_type (Partitioning): The PartitionDTO objects.

Returns:

Dict[str, Any]: The serialized result.

Raises:

IOError: If partitioning strategy is unknown.