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_NAMECATALOG_STRINGDATA_TYPEDECIMAL_PATTERNDIRECTIONEXPRESSION_TYPEEXTERNALFIELDSFIELD_NAMEFIELD_NAMESFIXEDCHAR_PATTERNFIXED_PATTERNFUNCTION_ARGSFUNCTION_NAMEIDENTITY_PARTITION_VALUESINDEX_FIELD_NAMESINDEX_NAMEINDEX_TYPELISTLIST_ELEMENT_NULLABLELIST_ELEMENT_TYPELIST_PARTITION_LISTSLITERAL_VALUEMAPMAP_KEY_TYPEMAP_VALUE_NULLABLEMAP_VALUE_TYPENON_PRIMITIVE_TYPESNULL_ORDERINGNUMBERNUM_BUCKETSPARTITION_NAMEPARTITION_PROPERTIESPARTITION_TYPEPRIMITIVE_AND_NULL_TYPESRANGE_PARTITION_LOWERRANGE_PARTITION_UPPERSORT_TERMSTRATEGYSTRUCTSTRUCT_FIELD_COMMENTSTRUCT_FIELD_NAMESTRUCT_FIELD_NULLABLETIMESTAMP_PATTERNTIMESTAMP_TZ_PATTERNTIME_PATTERNTYPETYPESUNIONUNION_TYPESUNPARSEDUNPARSED_EXPRESSIONUNPARSED_TYPEVARCHAR_PATTERNWIDTH- 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.