@Override
    public SerializationSchema<RowData> getSerializationSchema(
            Context context,
            EncodingFormat<SerializationSchema<RowData>> format) {
        return format.createRuntimeEncoder(context, physicalFormatDataType);
    }
The base class of {@link RedisSchema}

@param <T> The type of Flink state.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/common/schema/impl/AbstractRedisSchema.java