Package org.apache.kafka.connect.data

Class Values

  • public class Values
extends Object
    Utility for converting from one Connect value to a different form. This is useful when the caller expects a value of a particular type but is uncertain whether the actual value is one that isn't directly that type but can be converted into that type.

    For example, a caller might expects a particular Header to contain an Schema.Type.INT64 value, when in fact that header contains a string representation of a 32-bit integer. Here, the caller can use the methods in this class to convert the value to the desired type: 

         Header header = ...
     long value = Values.convertToLong(header.schema(), header.value());

    This class is able to convert any value to a string representation as well as parse those string representations back into most of the types. The only exception is Struct values that require a schema and thus cannot be parsed from a simple string.

    • Constructor Detail

      • Values

        public Values()

    • Method Detail

      • convertToBoolean

        public static Boolean convertToBoolean​(Schema schema,
                                       Object value)
                                throws DataException
        Convert the specified value to an Schema.Type.BOOLEAN value. The supplied schema is required if the value is a logical type when the schema contains critical information that might be necessary for converting to a boolean.
        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a boolean, or null if the supplied value was null
        Throws:
        DataException - if the value could not be converted to a boolean

      • convertToByte

        public static Byte convertToByte​(Schema schema,
                                 Object value)
                          throws DataException
        Convert the specified value to an Schema.Type.INT8 byte value. The supplied schema is required if the value is a logical type when the schema contains critical information that might be necessary for converting to a byte.
        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a byte, or null if the supplied value was null
        Throws:
        DataException - if the value could not be converted to a byte

      • convertToShort

        public static Short convertToShort​(Schema schema,
                                   Object value)
                            throws DataException
        Convert the specified value to an Schema.Type.INT16 short value. The supplied schema is required if the value is a logical type when the schema contains critical information that might be necessary for converting to a short.
        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a short, or null if the supplied value was null
        Throws:
        DataException - if the value could not be converted to a short

      • convertToInteger

        public static Integer convertToInteger​(Schema schema,
                                       Object value)
                                throws DataException
        Convert the specified value to an Schema.Type.INT32 int value. The supplied schema is required if the value is a logical type when the schema contains critical information that might be necessary for converting to an integer.
        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as an integer, or null if the supplied value was null
        Throws:
        DataException - if the value could not be converted to an integer

      • convertToLong

        public static Long convertToLong​(Schema schema,
                                 Object value)
                          throws DataException
        Convert the specified value to an Schema.Type.INT64 long value. The supplied schema is required if the value is a logical type when the schema contains critical information that might be necessary for converting to a long.
        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a long, or null if the supplied value was null
        Throws:
        DataException - if the value could not be converted to a long

      • convertToFloat

        public static Float convertToFloat​(Schema schema,
                                   Object value)
                            throws DataException
        Convert the specified value to an Schema.Type.FLOAT32 float value. The supplied schema is required if the value is a logical type when the schema contains critical information that might be necessary for converting to a floating point number.
        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a float, or null if the supplied value was null
        Throws:
        DataException - if the value could not be converted to a float

      • convertToDouble

        public static Double convertToDouble​(Schema schema,
                                     Object value)
                              throws DataException
        Convert the specified value to an Schema.Type.FLOAT64 double value. The supplied schema is required if the value is a logical type when the schema contains critical information that might be necessary for converting to a floating point number.
        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a double, or null if the supplied value was null
        Throws:
        DataException - if the value could not be converted to a double

      • convertToString

        public static String convertToString​(Schema schema,
                                     Object value)
        Convert the specified value to an Schema.Type.STRING value. Not supplying a schema may limit the ability to convert to the desired type.
        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a string, or null if the supplied value was null

      • convertToList

        public static List<?> convertToList​(Schema schema,
                                    Object value)
        Convert the specified value to an Schema.Type.ARRAY value. If the value is a string representation of an array, this method will parse the string and its elements to infer the schemas for those elements. Thus, this method supports arrays of other primitives and structured types. If the value is already an array (or list), this method simply casts and returns it.

        This method currently does not use the schema, though it may be used in the future.

        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a list, or null if the supplied value was null
        Throws:
        DataException - if the value cannot be converted to a list value

      • convertToMap

        public static Map<?,​?> convertToMap​(Schema schema,
                                          Object value)
        Convert the specified value to an Schema.Type.MAP value. If the value is a string representation of a map, this method will parse the string and its entries to infer the schemas for those entries. Thus, this method supports maps with primitives and structured keys and values. If the value is already a map, this method simply casts and returns it.

        This method currently does not use the schema, though it may be used in the future.

        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a map, or null if the supplied value was null
        Throws:
        DataException - if the value cannot be converted to a map value

      • convertToStruct

        public static Struct convertToStruct​(Schema schema,
                                     Object value)
        Convert the specified value to an Schema.Type.STRUCT value. Structs cannot be converted from other types, so this method returns a struct only if the supplied value is a struct. If not a struct, this method throws an exception.

        This method currently does not use the schema, though it may be used in the future.

        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a struct, or null if the supplied value was null
        Throws:
        DataException - if the value is not a struct

      • convertToTime

        public static Date convertToTime​(Schema schema,
                                 Object value)
        Convert the specified value to an time value. Not supplying a schema may limit the ability to convert to the desired type.
        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a time, or null if the supplied value was null
        Throws:
        DataException - if the value cannot be converted to a time value

      • convertToDate

        public static Date convertToDate​(Schema schema,
                                 Object value)
        Convert the specified value to an date value. Not supplying a schema may limit the ability to convert to the desired type.
        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a date, or null if the supplied value was null
        Throws:
        DataException - if the value cannot be converted to a date value

      • convertToTimestamp

        public static Date convertToTimestamp​(Schema schema,
                                      Object value)
        Convert the specified value to an timestamp value. Not supplying a schema may limit the ability to convert to the desired type.
        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a timestamp, or null if the supplied value was null
        Throws:
        DataException - if the value cannot be converted to a timestamp value

      • convertToDecimal

        public static BigDecimal convertToDecimal​(Schema schema,
                                          Object value,
                                          int scale)
        Convert the specified value to an decimal value. Not supplying a schema may limit the ability to convert to the desired type.
        Parameters:
        schema - the schema for the value; may be null
        value - the value to be converted; may be null
        Returns:
        the representation as a decimal, or null if the supplied value was null
        Throws:
        DataException - if the value cannot be converted to a decimal value

      • inferSchema

        public static Schema inferSchema​(Object value)
        If possible infer a schema for the given value.
        Parameters:
        value - the value whose schema is to be inferred; may be null
        Returns:
        the inferred schema, or null if the value is null or no schema could be inferred

      • convertTo

        protected static Object convertTo​(Schema toSchema,
                                  Schema fromSchema,
                                  Object value)
                           throws DataException
        Convert the value to the desired type.
        Parameters:
        toSchema - the schema for the desired type; may not be null
        fromSchema - the schema for the supplied value; may be null if not known
        Returns:
        the converted value; never null
        Throws:
        DataException - if the value could not be converted to the desired type

      • asLong

        protected static long asLong​(Object value,
                             Schema fromSchema,
                             Throwable error)
        Convert the specified value to the desired scalar value type.
        Parameters:
        value - the value to be converted; may not be null
        fromSchema - the schema for the current value type; may not be null
        error - any previous error that should be included in an exception message; may be null
        Returns:
        the long value after conversion; never null
        Throws:
        DataException - if the value could not be converted to a long

      • asDouble

        protected static double asDouble​(Object value,
                                 Schema schema,
                                 Throwable error)
        Convert the specified value with the desired floating point type.
        Parameters:
        value - the value to be converted; may not be null
        schema - the schema for the current value type; may not be null
        error - any previous error that should be included in an exception message; may be null
        Returns:
        the double value after conversion; never null
        Throws:
        DataException - if the value could not be converted to a double

      • append

        protected static void append​(StringBuilder sb,
                             Object value,
                             boolean embedded)

      • dateFormatFor

        public static DateFormat dateFormatFor​(Date value)

      • canParseSingleTokenLiteral

        protected static boolean canParseSingleTokenLiteral​(Values.Parser parser,
                                                    boolean embedded,
                                                    String tokenLiteral)