OnlineVeniceProducer (venice API)

java.lang.Object

com.linkedin.venice.producer.AbstractVeniceProducer<K,V>

com.linkedin.venice.producer.online.OnlineVeniceProducer<K,V>

All Implemented Interfaces:: VeniceProducer<K,V>, Closeable, AutoCloseable

public class OnlineVeniceProducer<K,V> extends AbstractVeniceProducer<K,V>

An implementation of a VeniceProducer suitable for online applications. This producer only supports producing data to a store's RT topic.

See Also:

Method Summary

Modifier and Type

Method

Description

void

close()

protected VersionCreationResponse

requestTopic()

This function should return a VersionCreationResponse to determine the PubSub topic and the characteristics that the producer should follow.

Methods inherited from class com.linkedin.venice.producer.AbstractVeniceProducer
asyncDelete, asyncDelete, asyncPut, asyncPut, asyncUpdate, asyncUpdate, configure, constructVeniceWriter, getSerializer, isClosed

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- requestTopic
  
  protected VersionCreationResponse requestTopic()
  
  Description copied from class: AbstractVeniceProducer
  
  This function should return a VersionCreationResponse to determine the PubSub topic and the characteristics that the producer should follow.
  
  Specified by:
  
  requestTopic in class AbstractVeniceProducer<K,V>
- close
  
  public void close() throws IOException
  
  Specified by:
  
  close in interface AutoCloseable
  
  Specified by:
  
  close in interface Closeable
  
  Overrides:
  
  close in class AbstractVeniceProducer<K,V>
  
  Throws:
  
  IOException