Package org.apache.pulsar.io.solr

Class SolrGenericRecordSink

java.lang.Object

org.apache.pulsar.io.solr.SolrAbstractSink<org.apache.pulsar.client.api.schema.GenericRecord>

org.apache.pulsar.io.solr.SolrGenericRecordSink

All Implemented Interfaces:

java.lang.AutoCloseable, org.apache.pulsar.io.core.Sink<org.apache.pulsar.client.api.schema.GenericRecord>

public class SolrGenericRecordSink
extends SolrAbstractSink<org.apache.pulsar.client.api.schema.GenericRecord>

A simple Solr sink, which interprets input Record in generic record.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pulsar.io.solr.SolrAbstractSink

SolrAbstractSink.SolrMode

Constructor Summary

Constructors

Constructor	Description
SolrGenericRecordSink()

Method Summary

Modifier and Type	Method	Description
org.apache.solr.common.SolrInputDocument	convert(org.apache.pulsar.functions.api.Record<org.apache.pulsar.client.api.schema.GenericRecord> message)

Methods inherited from class org.apache.pulsar.io.solr.SolrAbstractSink

close, getClient, open, write

Methods inherited from class java.lang.Object

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

Constructor Detail

SolrGenericRecordSink

public SolrGenericRecordSink()

Method Detail

convert

public org.apache.solr.common.SolrInputDocument convert(org.apache.pulsar.functions.api.Record<org.apache.pulsar.client.api.schema.GenericRecord> message)

Specified by:

convert in class SolrAbstractSink<org.apache.pulsar.client.api.schema.GenericRecord>