Package | Description |
---|---|
com.yahoo.bullet.pubsub | |
com.yahoo.bullet.querying | |
com.yahoo.bullet.querying.partitioning |
Modifier and Type | Method and Description |
---|---|
Query |
PubSubMessage.getContentAsQuery()
Returns the content stored in the message as a
Query . |
Modifier and Type | Method and Description |
---|---|
PubSubMessage |
ByteArrayPubSubMessageSerDe.toMessage(String id,
Query query,
String queryString) |
PubSubMessage |
PubSubMessageSerDe.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) . |
Modifier and Type | Method and Description |
---|---|
Query |
Querier.getQuery()
Gets the
Query instance for this Query. |
Constructor and Description |
---|
RunningQuery(String id,
Query query,
Metadata metadata)
Constructor that takes an id, query, query string, and start time.
|
Modifier and Type | Method and Description |
---|---|
Set<String> |
SimpleEqualityPartitioner.getKeys(Query query)
Returns the partitioning keys for this
Query instance. |
Set<String> |
Partitioner.getKeys(Query query)
Returns the partitioning keys for this
Query instance. |
Copyright © 2021. All rights reserved.