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.