public class Values extends Object
For example, a caller might expect a particular Header
to contain a 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 and Description |
---|
Values() |
Modifier and Type | Method and Description |
---|---|
static Boolean |
convertToBoolean(Schema schema,
Object value)
Convert the specified value to a
Schema.Type.BOOLEAN value. |
static Byte |
convertToByte(Schema schema,
Object value)
Convert the specified value to an
Schema.Type.INT8 byte value. |
static Date |
convertToDate(Schema schema,
Object value)
Convert the specified value to a
date value. |
static BigDecimal |
convertToDecimal(Schema schema,
Object value,
int scale)
Convert the specified value to a
decimal value. |
static Double |
convertToDouble(Schema schema,
Object value)
Convert the specified value to a
Schema.Type.FLOAT64 double value. |
static Float |
convertToFloat(Schema schema,
Object value)
Convert the specified value to a
Schema.Type.FLOAT32 float value. |
static Integer |
convertToInteger(Schema schema,
Object value)
Convert the specified value to an
Schema.Type.INT32 int value. |
static List<?> |
convertToList(Schema schema,
Object value)
Convert the specified value to an
Schema.Type.ARRAY value. |
static Long |
convertToLong(Schema schema,
Object value)
Convert the specified value to an
Schema.Type.INT64 long value. |
static Map<?,?> |
convertToMap(Schema schema,
Object value)
Convert the specified value to a
Schema.Type.MAP value. |
static Short |
convertToShort(Schema schema,
Object value)
Convert the specified value to an
Schema.Type.INT16 short value. |
static String |
convertToString(Schema schema,
Object value)
Convert the specified value to a
Schema.Type.STRING value. |
static Struct |
convertToStruct(Schema schema,
Object value)
Convert the specified value to a
Schema.Type.STRUCT value. |
static Date |
convertToTime(Schema schema,
Object value)
Convert the specified value to a
time value. |
static Date |
convertToTimestamp(Schema schema,
Object value)
Convert the specified value to a
timestamp value. |
static DateFormat |
dateFormatFor(Date value) |
static Schema |
inferSchema(Object value)
If possible infer a schema for the given value.
|
static SchemaAndValue |
parseString(String value)
Parse the specified string representation of a value into its schema and value.
|
public static Boolean convertToBoolean(Schema schema, Object value) throws DataException
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.schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value could not be converted to a booleanpublic static Byte convertToByte(Schema schema, Object value) throws DataException
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.schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value could not be converted to a bytepublic static Short convertToShort(Schema schema, Object value) throws DataException
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.schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value could not be converted to a shortpublic static Integer convertToInteger(Schema schema, Object value) throws DataException
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.schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value could not be converted to an integerpublic static Long convertToLong(Schema schema, Object value) throws DataException
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.schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value could not be converted to a longpublic static Float convertToFloat(Schema schema, Object value) throws DataException
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.schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value could not be converted to a floatpublic static Double convertToDouble(Schema schema, Object value) throws DataException
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.schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value could not be converted to a doublepublic static String convertToString(Schema schema, Object value)
Schema.Type.STRING
value.
Not supplying a schema may limit the ability to convert to the desired type.schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullpublic static List<?> convertToList(Schema schema, Object value)
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.
schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value cannot be converted to a list valuepublic static Map<?,?> convertToMap(Schema schema, Object value)
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.
schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value cannot be converted to a map valuepublic static Struct convertToStruct(Schema schema, Object value)
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.
schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value is not a structpublic static Date convertToTime(Schema schema, Object value)
time
value.
Not supplying a schema may limit the ability to convert to the desired type.schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value cannot be converted to a time valuepublic static Date convertToDate(Schema schema, Object value)
date
value.
Not supplying a schema may limit the ability to convert to the desired type.schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value cannot be converted to a date valuepublic static Date convertToTimestamp(Schema schema, Object value)
timestamp
value.
Not supplying a schema may limit the ability to convert to the desired type.schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value cannot be converted to a timestamp valuepublic static BigDecimal convertToDecimal(Schema schema, Object value, int scale)
decimal
value.
Not supplying a schema may limit the ability to convert to the desired type.schema
- the schema for the value; may be nullvalue
- the value to be converted; may be nullDataException
- if the value cannot be converted to a decimal valuepublic static Schema inferSchema(Object value)
value
- the value whose schema is to be inferred; may be nullpublic static SchemaAndValue parseString(String value)
value
- the string form of the valueconvertToString(org.apache.kafka.connect.data.Schema, java.lang.Object)
public static DateFormat dateFormatFor(Date value)