<T extends PushConnector> FutureData<PushSubscription> |
DataSiftPush.create(T connector,
FutureData<PreparedHistoricsQuery> historics,
FutureData<Stream> stream,
java.lang.String name) |
<T extends PushConnector> FutureData<PushSubscription> |
DataSiftPush.create(T connector,
FutureData<PreparedHistoricsQuery> historics,
FutureData<Stream> stream,
java.lang.String name,
Status initialStatus,
long start,
long end) |
<T extends PushConnector> FutureData<PushSubscription> |
DataSiftPush.create(T con,
FutureData<PreparedHistoricsQuery> query,
java.lang.String name) |
<T extends PushConnector> FutureData<PushSubscription> |
DataSiftPush.create(T connector,
PreparedHistoricsQuery historics,
java.lang.String name,
Status initialStatus,
long start,
long end) |
<T extends PushConnector> FutureData<PushSubscription> |
DataSiftPush.create(T con,
Stream stream,
java.lang.String name) |
<T extends PushConnector> FutureData<PushSubscription> |
DataSiftPush.create(T connector,
Stream stream,
java.lang.String name,
Status initialStatus,
long start,
long end) |
FutureData<PushSubscription> |
DataSiftPush.createPull(PullJsonType type,
PreparedHistoricsQuery historics,
Stream stream,
java.lang.String name,
Status initialStatus,
long start,
long end) |
FutureData<PushSubscription> |
DataSiftPush.createPull(PullJsonType jsonMeta,
PreparedHistoricsQuery historics,
java.lang.String name) |
FutureData<PushSubscription> |
DataSiftPush.createPull(PullJsonType jsonMeta,
PreparedHistoricsQuery historics,
java.lang.String name,
Status initialStatus,
long start,
long end) |
FutureData<PushSubscription> |
DataSiftPush.createPull(PullJsonType jsonMeta,
Stream stream,
java.lang.String name) |
FutureData<PushSubscription> |
DataSiftPush.createPull(PullJsonType jsonMeta,
Stream stream,
java.lang.String name,
Status initialStatus,
long start,
long end) |
FutureData<PushSubscription> |
DataSiftPush.get(java.lang.String id) |
java.util.List<PushSubscription> |
PushCollection.getSubscriptions() |
java.util.Iterator<PushSubscription> |
PushCollection.iterator() |
FutureData<PushSubscription> |
DataSiftPush.pause(java.lang.String id) |
FutureData<PushSubscription> |
DataSiftPush.resume(java.lang.String id) |
FutureData<PushSubscription> |
DataSiftPush.stop(java.lang.String id) |
FutureData<PushSubscription> |
DataSiftPush.update(java.lang.String id,
PushConnector connector) |
FutureData<PushSubscription> |
DataSiftPush.update(java.lang.String id,
PushConnector connector,
java.lang.String name) |