Package org.nuxeo.ecm.core.bulk.io

Class InstantAsLongEncoding

java.lang.Object

org.apache.avro.reflect.CustomEncoding<Instant>

org.nuxeo.ecm.core.bulk.io.InstantAsLongEncoding

public class InstantAsLongEncoding
extends org.apache.avro.reflect.CustomEncoding<Instant>

This CustomEncoding encodes/decodes Instant to a long (time in milliseconds) before encoding it in Avro format.

Since:

10.3

Field Summary

Fields

Modifier and Type	Field	Description
protected static int	LONG_SCHEMA_INDEX
protected static int	NULL_SCHEMA_INDEX

Fields inherited from class org.apache.avro.reflect.CustomEncoding

schema

Constructor Summary

Constructors

Constructor	Description
InstantAsLongEncoding()

Method Summary

Modifier and Type	Method	Description
protected Instant	read(Object o, org.apache.avro.io.Decoder decoder)
protected void	write(Object o, org.apache.avro.io.Encoder encoder)

Methods inherited from class org.apache.avro.reflect.CustomEncoding

getSchema

Methods inherited from class java.lang.Object

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

Field Detail

NULL_SCHEMA_INDEX

protected static final int NULL_SCHEMA_INDEX

See Also:

Constant Field Values

LONG_SCHEMA_INDEX

protected static final int LONG_SCHEMA_INDEX

See Also:

Constant Field Values

Constructor Detail

InstantAsLongEncoding

public InstantAsLongEncoding()

Method Detail

write

protected void write(Object o,
                     org.apache.avro.io.Encoder encoder)
              throws IOException

Specified by:

write in class org.apache.avro.reflect.CustomEncoding<Instant>

Throws:

IOException

read

protected Instant read(Object o,
                       org.apache.avro.io.Decoder decoder)
                throws IOException

Specified by:

read in class org.apache.avro.reflect.CustomEncoding<Instant>

Throws:

IOException