com.yahoo.bullet.pubsub

Class ByteArrayPubSubMessageSerDe

java.lang.Object

com.yahoo.bullet.pubsub.PubSubMessageSerDe

com.yahoo.bullet.pubsub.IdentityPubSubMessageSerDe

com.yahoo.bullet.pubsub.ByteArrayPubSubMessageSerDe

All Implemented Interfaces:

Serializable

public class ByteArrayPubSubMessageSerDe
extends IdentityPubSubMessageSerDe

This SerDe is used to convert a provided Query into its serialized bytes in the PubSubMessage. When invoking the PubSubMessage.getContentAsByteArray() or PubSubMessage.getContentAsQuery(), the payload is lazily converted (and stored) as the appropriate type. This means that PubSubMessage.getContent() will return a byte[] or Query depending on what was called before it. This can be used to send a Query to the backend and if it is passed between multiple workers (i.e. serialized and deserialized multiple times), it will not needlessly convert the Query object multiple times. This behaves like the IdentityPubSubMessageSerDe for all other operations.

See Also:

Serialized Form

Field Summary

Fields inherited from class com.yahoo.bullet.pubsub.PubSubMessageSerDe

config

Constructor Summary

Constructors

Constructor and Description
ByteArrayPubSubMessageSerDe(BulletConfig config) Constructor.

Method Summary

Modifier and Type	Method and Description
PubSubMessage	toMessage(String id, Query query, String queryString) A helper to submit a query by converting it to a standard PubSubMessage and running it through PubSubMessageSerDe.toMessage(PubSubMessage).

Methods inherited from class com.yahoo.bullet.pubsub.IdentityPubSubMessageSerDe

fromMessage, toMessage

Methods inherited from class com.yahoo.bullet.pubsub.PubSubMessageSerDe

from

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteArrayPubSubMessageSerDe

public ByteArrayPubSubMessageSerDe(BulletConfig config)

Constructor.

Parameters:

config - The BulletConfig to configure this class.

Method Detail

toMessage

public PubSubMessage toMessage(String id,
                               Query query,
                               String queryString)

Description copied from class: PubSubMessageSerDe

A helper to submit a query by converting it to a standard PubSubMessage and running it through PubSubMessageSerDe.toMessage(PubSubMessage).

Overrides:

toMessage in class PubSubMessageSerDe

Parameters:

id - The ID for the query.

query - The Query object to create a PubSubMessage.

queryString - The BQL for the query.

Returns:

A converted PubSubMessage.