| Package | Description |
|---|---|
| com.datasift.client.push |
| Modifier and Type | Method and Description |
|---|---|
static PushSubscription |
PushSubscription.fromString(String str)
Create a
PushSubscription instance containing only an id |
| Modifier and Type | Method and Description |
|---|---|
<T extends PushConnector> |
DataSiftPush.create(T connector,
FutureData<PreparedHistoricsQuery> historics,
FutureData<Stream> stream,
String name) |
<T extends PushConnector> |
DataSiftPush.create(T connector,
FutureData<PreparedHistoricsQuery> historics,
FutureData<Stream> stream,
String name,
Status initialStatus,
long start,
long end)
Creates a push subscription to either a historics query OR a live stream.
|
<T extends PushConnector> |
DataSiftPush.create(T con,
FutureData<PreparedHistoricsQuery> query,
String name) |
<T extends PushConnector> |
DataSiftPush.create(T connector,
PreparedHistoricsQuery historics,
String name,
Status initialStatus,
long start,
long end)
Create a push subscription from a prepared query
|
<T extends PushConnector> |
DataSiftPush.create(T con,
Stream stream,
String name) |
<T extends PushConnector> |
DataSiftPush.create(T connector,
Stream stream,
String name,
Status initialStatus,
long start,
long end)
Create a push subscription from a live stream
|
FutureData<PushSubscription> |
DataSiftPush.createPull(PullJsonType type,
PreparedHistoricsQuery historics,
Stream stream,
String name,
Status initialStatus,
long start,
long end) |
FutureData<PushSubscription> |
DataSiftPush.createPull(PullJsonType jsonMeta,
PreparedHistoricsQuery historics,
String name) |
FutureData<PushSubscription> |
DataSiftPush.createPull(PullJsonType jsonMeta,
PreparedHistoricsQuery historics,
String name,
Status initialStatus,
long start,
long end)
Create a push subscription to be consumed via
DataSiftPush.pull(PushSubscription, int, String) using a live stream |
FutureData<PushSubscription> |
DataSiftPush.createPull(PullJsonType jsonMeta,
Stream stream,
String name) |
FutureData<PushSubscription> |
DataSiftPush.createPull(PullJsonType jsonMeta,
Stream stream,
String name,
Status initialStatus,
long start,
long end)
Create a push subscription to be consumed via
DataSiftPush.pull(PushSubscription, int, String) using a live stream |
FutureData<PushSubscription> |
DataSiftPush.get(String id) |
List<PushSubscription> |
PushCollection.getSubscriptions() |
Iterator<PushSubscription> |
PushCollection.iterator() |
FutureData<PushSubscription> |
DataSiftPush.pause(String id)
Pause the push subscription with the given ID
|
FutureData<PushSubscription> |
DataSiftPush.resume(String id)
Set a paused subscription to run again
|
FutureData<PushSubscription> |
DataSiftPush.stop(String id)
Stop/cancel a given push subscription
|
FutureData<PushSubscription> |
DataSiftPush.update(String id,
PushConnector connector) |
FutureData<PushSubscription> |
DataSiftPush.update(String id,
PushConnector connector,
String name)
Updates the name or output parameters for a push sucription
|
| Modifier and Type | Method and Description |
|---|---|
FutureData<PulledInteractions> |
DataSiftPush.pull(PushSubscription id) |
FutureData<PulledInteractions> |
DataSiftPush.pull(PushSubscription id,
int size,
String cursor)
Retrieve one or more interactions from a Push queue
|
protected void |
DataSiftPush.sendPullRequest(FutureData<PulledInteractions> future,
PushSubscription id,
int size,
String cursor,
URI uri,
PullReader reader) |
Copyright © 2014. All Rights Reserved.