Package com.linkedin.venice.hadoop.heartbeat

Class DefaultPushJobHeartbeatSenderFactory

java.lang.Object

com.linkedin.venice.hadoop.heartbeat.DefaultPushJobHeartbeatSenderFactory

All Implemented Interfaces:

PushJobHeartbeatSenderFactory

public class DefaultPushJobHeartbeatSenderFactory
extends java.lang.Object
implements PushJobHeartbeatSenderFactory

Constructor Summary

Constructors

Constructor	Description
DefaultPushJobHeartbeatSenderFactory()

Method Summary

Modifier and Type	Method	Description
PushJobHeartbeatSender	createHeartbeatSender(java.lang.String kafkaUrl, VeniceProperties properties, ControllerClient controllerClient, java.util.Optional<java.util.Properties> sslProperties)	Create a heartbeat sender
protected VeniceWriter<byte[],byte[],byte[]>	getVeniceWriter(java.lang.String heartbeatKafkaTopicName, PartitionerConfig partitionerConfig, java.util.Properties veniceWriterProperties, int partitionNum)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultPushJobHeartbeatSenderFactory

public DefaultPushJobHeartbeatSenderFactory()

Method Detail

createHeartbeatSender

public PushJobHeartbeatSender createHeartbeatSender(java.lang.String kafkaUrl,
                                                    VeniceProperties properties,
                                                    @Nonnull
                                                    ControllerClient controllerClient,
                                                    java.util.Optional<java.util.Properties> sslProperties)

Description copied from interface: PushJobHeartbeatSenderFactory

Create a heartbeat sender

Specified by:

createHeartbeatSender in interface PushJobHeartbeatSenderFactory

getVeniceWriter

protected VeniceWriter<byte[],byte[],byte[]> getVeniceWriter(java.lang.String heartbeatKafkaTopicName,
                                                                         PartitionerConfig partitionerConfig,
                                                                         java.util.Properties veniceWriterProperties,
                                                                         int partitionNum)