Skip to content

SerdeFeaturesFactory

sanitizeKeyFormat

KeyFormat sanitizeKeyFormat(
  KeyFormat keyFormat,
  List<SqlType> newKeyColumnSqlTypes,
  boolean allowKeyFormatChangeToSupportNewKeySchema)

sanitizeKeyFormat...FIXME


sanitizeKeyFormat is used when:

  • SchemaKGroupedStream is requested to aggregate and getKeyFormat
  • SchemaKStream is requested to selectKey and groupBy
  • SchemaKTable is requested to selectKey and groupBy

sanitizeKeyFormatForTypeCompatibility

KeyFormat sanitizeKeyFormatForTypeCompatibility(
  KeyFormat keyFormat,
  List<SqlType> sqlTypes)

sanitizeKeyFormatForTypeCompatibility requests the given KeyFormat for the FormatInfo to create a Format.

sanitizeKeyFormatForTypeCompatibility returns the KeyFormat if every SqlType (in the given sqlTypes collection) is supported as a key type by the Format.

Otherwise, sanitizeKeyFormatForTypeCompatibility convertToJsonFormat the given KeyFormat.