org.apache.kafka.connect.data

Class Timestamp

java.lang.Object

org.apache.kafka.connect.data.Timestamp

public class Timestamp
extends java.lang.Object

A timestamp representing an absolute time, without timezone information. The corresponding Java type is a java.util.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 java.lang.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, java.util.Date value) Convert a value from its logical format (Date) to it's encoded format.
static java.util.Date	toLogical(Schema schema, long 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

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,
                               java.util.Date value)

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

Parameters:

value - the logical value

Returns:

the encoded value

toLogical

public static java.util.Date toLogical(Schema schema,
                                       long value)