A B C D F G I J K M P R S T V

A

AVRO_DESERIALIZER_CLASS_NAME - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

AvroBulletRecordConverter - Class in com.yahoo.bullet.dsl.converter

AvroBulletRecordConverter converts an Avro record into a BulletRecord.

AvroBulletRecordConverter() - Constructor for class com.yahoo.bullet.dsl.converter.AvroBulletRecordConverter

Constructs an AvroBulletRecordConverter without a schema.

AvroBulletRecordConverter(String) - Constructor for class com.yahoo.bullet.dsl.converter.AvroBulletRecordConverter

Constructs an AvroBulletRecordConverter from a given schema.

AvroBulletRecordConverter(BulletConfig) - Constructor for class com.yahoo.bullet.dsl.converter.AvroBulletRecordConverter

Constructs an AvroBulletRecordConverter from a given configuration.

AvroDeserializer - Class in com.yahoo.bullet.dsl.deserializer

A BulletDeserializer that uses Avro deserialization.

AvroDeserializer(BulletConfig) - Constructor for class com.yahoo.bullet.dsl.deserializer.AvroDeserializer

Constructs an AvroDeserializer from a given configuration.

B

build() - Method in class com.yahoo.bullet.dsl.converter.AvroBulletRecordConverter

build() - Method in class com.yahoo.bullet.dsl.converter.BulletRecordConverter

Helper function used to initialize BulletRecordConverter from BulletDSLConfig.

build() - Method in class com.yahoo.bullet.dsl.converter.POJOBulletRecordConverter

BulletConnector - Class in com.yahoo.bullet.dsl.connector

A BulletConnector is used to read objects from a data source such as Kafka or Pulsar.

BulletConnector(BulletConfig) - Constructor for class com.yahoo.bullet.dsl.connector.BulletConnector

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

BulletDeserializer - Class in com.yahoo.bullet.dsl.deserializer

A BulletDeserializer is used to deserialize or transform output from a BulletConnector into input for a BulletRecordConverter, e.g.

BulletDeserializer(BulletConfig) - Constructor for class com.yahoo.bullet.dsl.deserializer.BulletDeserializer

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

BulletDSLConfig - Class in com.yahoo.bullet.dsl

Config class for BulletDSL.

BulletDSLConfig() - Constructor for class com.yahoo.bullet.dsl.BulletDSLConfig

Constructor that loads the defaults.

BulletDSLConfig(String) - Constructor for class com.yahoo.bullet.dsl.BulletDSLConfig

Constructor that loads specific file augmented with defaults.

BulletDSLConfig(Config) - Constructor for class com.yahoo.bullet.dsl.BulletDSLConfig

Constructor that loads another configuration and augments it with defaults.

BulletDSLException - Exception in com.yahoo.bullet.dsl

Exception to be thrown if there is an error in BulletConnector or BulletRecordConverter.

BulletDSLException(String) - Constructor for exception com.yahoo.bullet.dsl.BulletDSLException

Constructor to initialize BulletDSLException with a message.

BulletDSLException(String, Throwable) - Constructor for exception com.yahoo.bullet.dsl.BulletDSLException

Constructor to initialize BulletDSLException with a message and a Throwable cause.

BulletRecordConverter - Class in com.yahoo.bullet.dsl.converter

BulletRecordConverter is used to convert objects into BulletRecords.

BulletRecordConverter(BulletConfig) - Constructor for class com.yahoo.bullet.dsl.converter.BulletRecordConverter

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

BulletRecordField - Class in com.yahoo.bullet.dsl.schema

BulletRecordField consists of a name, reference, and type.

BulletRecordField() - Constructor for class com.yahoo.bullet.dsl.schema.BulletRecordField

Default constructor recommended by Gson.

BulletRecordSchema - Class in com.yahoo.bullet.dsl.schema

A BulletRecordSchema consists of a list of BulletRecordField.

BulletRecordSchema() - Constructor for class com.yahoo.bullet.dsl.schema.BulletRecordSchema

Default constructor recommended by Gson.

C

close() - Method in class com.yahoo.bullet.dsl.connector.KafkaConnector

close() - Method in class com.yahoo.bullet.dsl.connector.PulsarConnector

com.yahoo.bullet.dsl - package com.yahoo.bullet.dsl

com.yahoo.bullet.dsl.connector - package com.yahoo.bullet.dsl.connector

com.yahoo.bullet.dsl.converter - package com.yahoo.bullet.dsl.converter

com.yahoo.bullet.dsl.deserializer - package com.yahoo.bullet.dsl.deserializer

com.yahoo.bullet.dsl.schema - package com.yahoo.bullet.dsl.schema

config - Variable in class com.yahoo.bullet.dsl.connector.BulletConnector

config - Variable in class com.yahoo.bullet.dsl.converter.BulletRecordConverter

config - Variable in class com.yahoo.bullet.dsl.deserializer.BulletDeserializer

CONNECTOR_ASYNC_COMMIT_ENABLE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_CLASS_NAME - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_KAFKA_BOOTSTRAP_SERVERS - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_KAFKA_ENABLE_AUTO_COMMIT - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_KAFKA_GROUP_ID - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_KAFKA_KEY_DESERIALIZER - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_KAFKA_NAMESPACE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_KAFKA_START_AT_END_ENABLE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_KAFKA_TOPICS - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_KAFKA_VALUE_DESERIALIZER - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_PULSAR_AUTH_ENABLE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_PULSAR_AUTH_PARAMS_STRING - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_PULSAR_AUTH_PLUGIN_CLASS_NAME - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_PULSAR_CLIENT_NAMESPACE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_PULSAR_CLIENT_SERVICE_URL - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_PULSAR_CONSUMER_NAMESPACE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_PULSAR_CONSUMER_SUBSCRIPTION_NAME - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_PULSAR_CONSUMER_SUBSCRIPTION_TYPE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_PULSAR_SCHEMA_CLASS_NAME - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_PULSAR_SCHEMA_TYPE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_PULSAR_TOPICS - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

CONNECTOR_READ_TIMEOUT_MS - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

convert(Object, BulletRecord) - Method in class com.yahoo.bullet.dsl.converter.AvroBulletRecordConverter

convert(Object) - Method in class com.yahoo.bullet.dsl.converter.BulletRecordConverter

Converts an object to a BulletRecord using the configuration-defined implementation of BulletRecord.

convert(Object, BulletRecord) - Method in class com.yahoo.bullet.dsl.converter.BulletRecordConverter

Converts an object to a BulletRecord using the given record.

convert(Object, BulletRecord) - Method in class com.yahoo.bullet.dsl.converter.JSONBulletRecordConverter

convert(Object, BulletRecord) - Method in class com.yahoo.bullet.dsl.converter.MapBulletRecordConverter

convert(Object, BulletRecord) - Method in class com.yahoo.bullet.dsl.converter.POJOBulletRecordConverter

convertGenericRecord(GenericRecord, Schema, BulletRecord) - Method in class com.yahoo.bullet.dsl.converter.AvroBulletRecordConverter

Converts a GenericRecord with a Schema into the provided BulletRecord.

D

DEFAULT_CONNECTOR_ASYNC_COMMIT_ENABLE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

DEFAULT_CONNECTOR_KAFKA_ENABLE_AUTO_COMMIT - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

DEFAULT_CONNECTOR_KAFKA_START_AT_END_ENABLE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

DEFAULT_CONNECTOR_PULSAR_AUTH_ENABLE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

DEFAULT_CONNECTOR_PULSAR_CONSUMER_SUBSCRIPTION_TYPE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

DEFAULT_CONNECTOR_PULSAR_SCHEMA_TYPE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

DEFAULT_CONNECTOR_READ_TIMEOUT_MS - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

DEFAULT_CONVERTER_AVRO_STRING_TYPE_FIX_ENABLE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

DEFAULT_CONVERTER_TYPE_CHECK_ENABLE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

DEFAULT_DSL_CONFIGURATION - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

deserialize(Object) - Method in class com.yahoo.bullet.dsl.deserializer.AvroDeserializer

deserialize(Object) - Method in class com.yahoo.bullet.dsl.deserializer.BulletDeserializer

Deserializes or transforms an object.

deserialize(Object) - Method in class com.yahoo.bullet.dsl.deserializer.IdentityDeserializer

deserialize(Object) - Method in class com.yahoo.bullet.dsl.deserializer.JavaDeserializer

DESERIALIZER_AVRO_CLASS_NAME - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

DESERIALIZER_AVRO_SCHEMA_FILE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

DESERIALIZER_CLASS_NAME - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

F

FILE_PREFIX - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

flattenMap(Map<String, Serializable>, BulletRecord) - Method in class com.yahoo.bullet.dsl.converter.BulletRecordConverter

Takes the fields of a map and inserts them into a BulletRecord.

from(BulletDSLConfig) - Static method in class com.yahoo.bullet.dsl.connector.BulletConnector

Creates a BulletConnector instance using the specified class.

from(BulletDSLConfig) - Static method in class com.yahoo.bullet.dsl.converter.BulletRecordConverter

Creates a BulletRecordConverter instance using the specified class.

from(BulletDSLConfig) - Static method in class com.yahoo.bullet.dsl.deserializer.BulletDeserializer

Creates a BulletDeserializer instance using the specified class.

G

get(Object, String) - Method in class com.yahoo.bullet.dsl.converter.AvroBulletRecordConverter

get(Object, String) - Method in class com.yahoo.bullet.dsl.converter.BulletRecordConverter

Gets the specified top-level field from the object.

get(Object, String) - Method in class com.yahoo.bullet.dsl.converter.MapBulletRecordConverter

get(Object, String) - Method in class com.yahoo.bullet.dsl.converter.POJOBulletRecordConverter

getField(Object, String) - Method in class com.yahoo.bullet.dsl.converter.AvroBulletRecordConverter

getField(Object, String) - Method in class com.yahoo.bullet.dsl.converter.BulletRecordConverter

Gets the specified inner field from the object.

getToken() - Method in class com.yahoo.bullet.dsl.schema.BulletRecordField

Gets the reference delimited as an array of tokens.

getTypedObject(String, Type, Serializable) - Method in class com.yahoo.bullet.dsl.converter.BulletRecordConverter

Converts the field value with the given name and expected type into a TypedObject.

getTypedObject(String, Type, Serializable) - Method in class com.yahoo.bullet.dsl.converter.JSONBulletRecordConverter

I

IdentityDeserializer - Class in com.yahoo.bullet.dsl.deserializer

A BulletDeserializer that does nothing.

IdentityDeserializer(BulletConfig) - Constructor for class com.yahoo.bullet.dsl.deserializer.IdentityDeserializer

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

initialize() - Method in class com.yahoo.bullet.dsl.connector.BulletConnector

Initializes the BulletConnector.

initialize() - Method in class com.yahoo.bullet.dsl.connector.KafkaConnector

initialize() - Method in class com.yahoo.bullet.dsl.connector.PulsarConnector

initialize() - Method in class com.yahoo.bullet.dsl.schema.BulletRecordField

initialize() - Method in class com.yahoo.bullet.dsl.schema.BulletRecordSchema

J

JavaDeserializer - Class in com.yahoo.bullet.dsl.deserializer

A BulletDeserializer that uses Java deserialization.

JavaDeserializer(BulletConfig) - Constructor for class com.yahoo.bullet.dsl.deserializer.JavaDeserializer

Constructs a JavaDeserializer from a given (but unused) configuration.

JSONBulletRecordConverter - Class in com.yahoo.bullet.dsl.converter

JSONBulletRecordConverter is used to convert String JSON to BulletRecord instances.

JSONBulletRecordConverter() - Constructor for class com.yahoo.bullet.dsl.converter.JSONBulletRecordConverter

Constructs a JSONBulletRecordConverter without a schema.

JSONBulletRecordConverter(String) - Constructor for class com.yahoo.bullet.dsl.converter.JSONBulletRecordConverter

Constructs a JSONBulletRecordConverter from a given schema.

JSONBulletRecordConverter(BulletConfig) - Constructor for class com.yahoo.bullet.dsl.converter.JSONBulletRecordConverter

Constructs a JSONBulletRecordConverter from a given configuration.

K

KAFKA_CONNECTOR_CLASS_NAME - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

KafkaConnector - Class in com.yahoo.bullet.dsl.connector

A BulletConnector that reads and deserializes messages from Kafka.

KafkaConnector(BulletConfig) - Constructor for class com.yahoo.bullet.dsl.connector.KafkaConnector

Constructs a KafkaConnector from a given configuration.

M

MapBulletRecordConverter - Class in com.yahoo.bullet.dsl.converter

MapBulletRecordConverter is used to convert Map<String, Object> to BulletRecord.

MapBulletRecordConverter() - Constructor for class com.yahoo.bullet.dsl.converter.MapBulletRecordConverter

Constructs a MapBulletRecordConverter without a schema.

MapBulletRecordConverter(String) - Constructor for class com.yahoo.bullet.dsl.converter.MapBulletRecordConverter

Constructs a MapBulletRecordConverter from a given schema.

MapBulletRecordConverter(BulletConfig) - Constructor for class com.yahoo.bullet.dsl.converter.MapBulletRecordConverter

Constructs a MapBulletRecordConverter from a given configuration.

P

POJO_CONVERTER_CLASS_NAME - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

POJOBulletRecordConverter - Class in com.yahoo.bullet.dsl.converter

POJOBulletRecordConverter is used to convert POJOs to BulletRecord.

POJOBulletRecordConverter(Class<?>) - Constructor for class com.yahoo.bullet.dsl.converter.POJOBulletRecordConverter

Constructs a POJOBulletRecordConverter without a schema that finds all valid fields regardless of access (protected, private, etc.) though not including inherited fields.

POJOBulletRecordConverter(Class<?>, String) - Constructor for class com.yahoo.bullet.dsl.converter.POJOBulletRecordConverter

Constructs a POJOBulletRecordConverter from a given schema.

POJOBulletRecordConverter(BulletConfig) - Constructor for class com.yahoo.bullet.dsl.converter.POJOBulletRecordConverter

Constructs a POJOBulletRecordConverter from a given configuration.

PULSAR_CONNECTOR_CLASS_NAME - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

PULSAR_SCHEMA_AVRO - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

PULSAR_SCHEMA_BYTES - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

PULSAR_SCHEMA_CLASS_REQUIRED_TYPES - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

PULSAR_SCHEMA_CUSTOM - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

PULSAR_SCHEMA_JSON - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

PULSAR_SCHEMA_PROTOBUF - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

PULSAR_SCHEMA_STRING - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

PULSAR_SCHEMA_TYPES - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

PulsarConnector - Class in com.yahoo.bullet.dsl.connector

A BulletConnector that reads and deserializes messages from Pulsar.

PulsarConnector(BulletConfig) - Constructor for class com.yahoo.bullet.dsl.connector.PulsarConnector

Constructs a PulsarConnector from a given configuration.

R

read() - Method in class com.yahoo.bullet.dsl.connector.BulletConnector

Reads and deserializes messages from a data source.

read() - Method in class com.yahoo.bullet.dsl.connector.KafkaConnector

read() - Method in class com.yahoo.bullet.dsl.connector.PulsarConnector

RECORD_CONVERTER_AVRO_STRING_TYPE_FIX_ENABLE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

RECORD_CONVERTER_CLASS_NAME - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

RECORD_CONVERTER_POJO_CLASS_NAME - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

RECORD_CONVERTER_SCHEMA_FILE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

RECORD_CONVERTER_SCHEMA_TYPE_CHECK_ENABLE - Static variable in class com.yahoo.bullet.dsl.BulletDSLConfig

runStringFixer - Variable in class com.yahoo.bullet.dsl.converter.AvroBulletRecordConverter

S

schema - Variable in class com.yahoo.bullet.dsl.converter.BulletRecordConverter

SCHEMA_REQUIRES_FIELDS - Static variable in class com.yahoo.bullet.dsl.schema.BulletRecordSchema

SCHEMA_REQUIRES_UNIQUE_FIELD_NAMES - Static variable in class com.yahoo.bullet.dsl.schema.BulletRecordSchema

setField(BulletRecordField, Object, BulletRecord) - Method in class com.yahoo.bullet.dsl.converter.AvroBulletRecordConverter

setField(BulletRecordField, Object, BulletRecord) - Method in class com.yahoo.bullet.dsl.converter.BulletRecordConverter

Sets the field in a BulletRecord.

shouldTypeCheck - Variable in class com.yahoo.bullet.dsl.converter.BulletRecordConverter

T

toString() - Method in class com.yahoo.bullet.dsl.schema.BulletRecordField

V

validate() - Method in class com.yahoo.bullet.dsl.BulletDSLConfig

A B C D F G I J K M P R S T V