Package | Description |
---|---|
com.yahoo.bullet.dsl.connector | |
com.yahoo.bullet.dsl.converter | |
com.yahoo.bullet.dsl.deserializer |
Modifier and Type | Method and Description |
---|---|
void |
PulsarConnector.initialize() |
abstract void |
BulletConnector.initialize()
Initializes the BulletConnector.
|
List<Object> |
KafkaConnector.read() |
List<Object> |
PulsarConnector.read() |
abstract List<Object> |
BulletConnector.read()
Reads and deserializes messages from a data source.
|
Modifier and Type | Method and Description |
---|---|
protected BulletRecordConverter |
BulletRecordConverter.build()
Helper function used to initialize BulletRecordConverter from BulletDSLConfig.
|
protected BulletRecordConverter |
AvroBulletRecordConverter.build() |
protected BulletRecordConverter |
POJOBulletRecordConverter.build() |
com.yahoo.bullet.record.BulletRecord |
BulletRecordConverter.convert(Object object)
Converts an object to a BulletRecord using the configuration-defined implementation of BulletRecord.
|
com.yahoo.bullet.record.BulletRecord |
BulletRecordConverter.convert(Object object,
com.yahoo.bullet.record.BulletRecord record)
Converts an object to a BulletRecord using the given record.
|
com.yahoo.bullet.record.BulletRecord |
AvroBulletRecordConverter.convert(Object object,
com.yahoo.bullet.record.BulletRecord record) |
com.yahoo.bullet.record.BulletRecord |
POJOBulletRecordConverter.convert(Object object,
com.yahoo.bullet.record.BulletRecord record) |
com.yahoo.bullet.record.BulletRecord |
JSONBulletRecordConverter.convert(Object object,
com.yahoo.bullet.record.BulletRecord record) |
com.yahoo.bullet.record.BulletRecord |
MapBulletRecordConverter.convert(Object object,
com.yahoo.bullet.record.BulletRecord record) |
Constructor and Description |
---|
AvroBulletRecordConverter()
Constructs an AvroBulletRecordConverter without a schema.
|
AvroBulletRecordConverter(com.yahoo.bullet.common.BulletConfig bulletConfig)
Constructs an AvroBulletRecordConverter from a given configuration.
|
AvroBulletRecordConverter(String schema)
Constructs an AvroBulletRecordConverter from a given schema.
|
JSONBulletRecordConverter()
Constructs a JSONBulletRecordConverter without a schema.
|
JSONBulletRecordConverter(com.yahoo.bullet.common.BulletConfig bulletConfig)
Constructs a JSONBulletRecordConverter from a given configuration.
|
JSONBulletRecordConverter(String schema)
Constructs a JSONBulletRecordConverter from a given schema.
|
MapBulletRecordConverter()
Constructs a MapBulletRecordConverter without a schema.
|
MapBulletRecordConverter(com.yahoo.bullet.common.BulletConfig bulletConfig)
Constructs a MapBulletRecordConverter from a given configuration.
|
MapBulletRecordConverter(String schema)
Constructs a MapBulletRecordConverter from a given schema.
|
POJOBulletRecordConverter(com.yahoo.bullet.common.BulletConfig bulletConfig)
Constructs a POJOBulletRecordConverter from a given configuration.
|
POJOBulletRecordConverter(Class<?> type)
Constructs a POJOBulletRecordConverter without a schema that finds all valid fields regardless of access
(protected, private, etc.) though not including inherited fields.
|
POJOBulletRecordConverter(Class<?> type,
String schema)
Constructs a POJOBulletRecordConverter from a given schema.
|
Modifier and Type | Method and Description |
---|---|
Object |
AvroDeserializer.deserialize(Object object) |
abstract Object |
BulletDeserializer.deserialize(Object object)
Deserializes or transforms an object.
|
Copyright © 2021. All rights reserved.