org.apache.kafka.connect.data

Class Timestamp

java.lang.Object

org.apache.kafka.connect.data.Timestamp

public class Timestamp
extends Object

A timestamp representing an absolute time, without timezone information. The corresponding Java type is a Date. The underlying representation is a long representing the number of milliseconds since Unix epoch.

Field Summary

Fields

Modifier and Type	Field and Description
static String	LOGICAL_NAME
static Schema	SCHEMA

Constructor Summary

Constructors

Constructor and Description
Timestamp()

Method Summary

Modifier and Type	Method and Description
static SchemaBuilder	builder() Returns a SchemaBuilder for a Timestamp.
static long	fromLogical(Schema schema, Date value) Convert a value from its logical format (Date) to its encoded format (long).
static Date	toLogical(Schema schema, long value) Convert a value from its encoded format (long) to its logical format (Date).

Methods inherited from class java.lang.Object

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

Field Detail

LOGICAL_NAME

public static final String LOGICAL_NAME

See Also:

Constant Field Values

SCHEMA

public static final Schema SCHEMA

Constructor Detail

Timestamp

public Timestamp()

Method Detail

builder

public static SchemaBuilder builder()

Returns a SchemaBuilder for a Timestamp. By returning a SchemaBuilder you can override additional schema settings such as required/optional, default value, and documentation.

Returns:

a SchemaBuilder

fromLogical

public static long fromLogical(Schema schema,
                               Date value)

Convert a value from its logical format (Date) to its encoded format (long).

Parameters:

value - the logical value

Returns:

the encoded value

toLogical

public static Date toLogical(Schema schema,
                             long value)

Convert a value from its encoded format (long) to its logical format (Date).

Parameters:

value - the encoded value

Returns:

the logical value