com.yahoo.bullet.dsl.connector

Class BulletConnector

java.lang.Object

com.yahoo.bullet.dsl.connector.BulletConnector

All Implemented Interfaces:

Serializable, AutoCloseable

Direct Known Subclasses:

KafkaConnector, PulsarConnector

public abstract class BulletConnector
extends Object
implements AutoCloseable, Serializable

A BulletConnector is used to read objects from a data source such as Kafka or Pulsar. Connectors should extend this class and expect configuration though BulletDSLConfig.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected BulletDSLConfig	config

Constructor Summary

Constructors

Constructor and Description
BulletConnector(com.yahoo.bullet.common.BulletConfig bulletConfig) Constructor that takes a configuration containing the settings relevant for this connector.

Method Summary

Modifier and Type	Method and Description
static BulletConnector	from(BulletDSLConfig config) Creates a BulletConnector instance using the specified class.
abstract void	initialize() Initializes the BulletConnector.
abstract List<Object>	read() Reads and deserializes messages from a data source.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.AutoCloseable

close

Field Detail

config

protected BulletDSLConfig config

Constructor Detail

BulletConnector

public BulletConnector(com.yahoo.bullet.common.BulletConfig bulletConfig)

Constructor that takes a configuration containing the settings relevant for this connector.

Parameters:

bulletConfig - The BulletConfig to use.

Method Detail

initialize

public abstract void initialize()
                         throws BulletDSLException

Initializes the BulletConnector. Must be called before read().

Throws:

BulletDSLException - if there is an initialization error.

read

public abstract List<Object> read()
                           throws BulletDSLException

Reads and deserializes messages from a data source. A timeout duration can be set in the configuration.

Returns:

A list of deserialized objects.

Throws:

BulletDSLException - if there is a connection or reading error.

from

public static BulletConnector from(BulletDSLConfig config)

Creates a BulletConnector instance using the specified class.

Parameters:

config - The configuration containing the BulletConnector class name and other relevant settings.

Returns:

A new instance of the specified BulletConnector class.