Package org.apache.solr.crossdc.common

Class MirroredSolrRequestSerializer

java.lang.Object

org.apache.solr.crossdc.common.MirroredSolrRequestSerializer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.serialization.Deserializer<MirroredSolrRequest<?>>, org.apache.kafka.common.serialization.Serializer<MirroredSolrRequest<?>>

public class MirroredSolrRequestSerializer
extends Object
implements org.apache.kafka.common.serialization.Serializer<MirroredSolrRequest<?>>, org.apache.kafka.common.serialization.Deserializer<MirroredSolrRequest<?>>

Constructor Summary

Constructors

Constructor	Description
MirroredSolrRequestSerializer()

Method Summary

Modifier and Type	Method	Description
void	close()	Close this serializer.
void	configure(Map<String,?> configs, boolean isKey)	Configure this class.
MirroredSolrRequest<?>	deserialize(String topic, byte[] data)
byte[]	serialize(String topic, MirroredSolrRequest<?> request)	Convert data into a byte array.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.common.serialization.Deserializer

deserialize, deserialize

Methods inherited from interface org.apache.kafka.common.serialization.Serializer

serialize

Constructor Detail

MirroredSolrRequestSerializer

public MirroredSolrRequestSerializer()

Method Detail

configure

public void configure(Map<String,?> configs,
                      boolean isKey)

Configure this class.

Specified by:

configure in interface org.apache.kafka.common.serialization.Deserializer<MirroredSolrRequest<?>>

Specified by:

configure in interface org.apache.kafka.common.serialization.Serializer<MirroredSolrRequest<?>>

Parameters:

configs - configs in key/value pairs

isKey - whether is for key or value

deserialize

public MirroredSolrRequest<?> deserialize(String topic,
                                          byte[] data)

Specified by:

deserialize in interface org.apache.kafka.common.serialization.Deserializer<MirroredSolrRequest<?>>

serialize

public byte[] serialize(String topic,
                        MirroredSolrRequest<?> request)

Convert data into a byte array.

Specified by:

serialize in interface org.apache.kafka.common.serialization.Serializer<MirroredSolrRequest<?>>

Parameters:

topic - topic associated with data

request - MirroredSolrRequest that needs to be serialized

Returns:

serialized bytes

close

public final void close()

Close this serializer.

This method must be idempotent as it may be called multiple times.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.apache.kafka.common.serialization.Deserializer<MirroredSolrRequest<?>>

Specified by:

close in interface org.apache.kafka.common.serialization.Serializer<MirroredSolrRequest<?>>