Package com.linkedin.venice.hadoop.heartbeat

Interface PushJobHeartbeatSenderFactory

All Known Implementing Classes:

DefaultPushJobHeartbeatSenderFactory, NoOpPushJobHeartbeatSenderFactory

public interface PushJobHeartbeatSenderFactory

This interface provides methods to let users create a heartbeat provider

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

Method Detail

createHeartbeatSender

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

Create a heartbeat sender

Parameters:

properties -