org.apache.kafka.connect.data

Class Decimal

java.lang.Object

org.apache.kafka.connect.data.Decimal

public class Decimal
extends java.lang.Object

An arbitrary-precision signed decimal number. The value is unscaled * 10 ^ -scale where:

• unscaled is an integer
• scale is an integer representing how many digits the decimal point should be shifted on the unscaled value

Decimal does not provide a fixed schema because it is parameterized by the scale, which is fixed on the schema rather than being part of the value.

The underlying representation of this type is bytes containing a two's complement integer

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	LOGICAL_NAME
static java.lang.String	SCALE_FIELD

Constructor Summary

Constructors

Constructor and Description
Decimal()

Method Summary

Modifier and Type	Method and Description
static SchemaBuilder	builder(int scale) Returns a SchemaBuilder for a Decimal with the given scale factor.
static byte[]	fromLogical(Schema schema, java.math.BigDecimal value) Convert a value from its logical format (BigDecimal) to it's encoded format.
static Schema	schema(int scale)
static java.math.BigDecimal	toLogical(Schema schema, byte[] value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOGICAL_NAME

public static final java.lang.String LOGICAL_NAME

See Also:

Constant Field Values

SCALE_FIELD

public static final java.lang.String SCALE_FIELD

See Also:

Constant Field Values

Constructor Detail

Decimal

public Decimal()

Method Detail

builder

public static SchemaBuilder builder(int scale)

Returns a SchemaBuilder for a Decimal with the given scale factor. By returning a SchemaBuilder you can override additional schema settings such as required/optional, default value, and documentation.

Parameters:

scale - the scale factor to apply to unscaled values

Returns:

a SchemaBuilder

schema

public static Schema schema(int scale)

fromLogical

public static byte[] fromLogical(Schema schema,
                                 java.math.BigDecimal value)

Convert a value from its logical format (BigDecimal) to it's encoded format.

Parameters:

value - the logical value

Returns:

the encoded value

toLogical

public static java.math.BigDecimal toLogical(Schema schema,
                                             byte[] value)