| Package | Description |
|---|---|
| com.datasift.client | |
| com.datasift.client.core | |
| com.datasift.client.preview | |
| com.datasift.client.push | |
| com.datasift.client.stream |
| Modifier and Type | Method and Description |
|---|---|
FutureData<Stream> |
DataSiftClient.compile(java.lang.String csdl) |
| Modifier and Type | Method and Description |
|---|---|
FutureData<Dpu> |
DataSiftClient.dpu(Stream stream) |
| Modifier and Type | Method and Description |
|---|---|
FutureData<Dpu> |
DataSiftClient.dpu(FutureData<Stream> streamFuture) |
| Modifier and Type | Method and Description |
|---|---|
static Stream |
Stream.fromString(java.lang.String str) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
Stream.isSameAs(Stream hash) |
| Modifier and Type | Method and Description |
|---|---|
FutureData<HistoricsPreview> |
DataSiftPreview.create(org.joda.time.DateTime start,
org.joda.time.DateTime end,
Stream hash,
java.lang.String[] params) |
FutureData<HistoricsPreview> |
DataSiftPreview.create(org.joda.time.DateTime now,
Stream stream,
java.lang.String[] params) |
FutureData<HistoricsPreview> |
DataSiftPreview.create(long start,
long end,
Stream stream,
java.lang.String[] parameters) |
| Modifier and Type | Method and Description |
|---|---|
<T extends PushConnector> |
DataSiftPush.create(T con,
Stream stream,
java.lang.String name) |
<T extends PushConnector> |
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,
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<PushCollection> |
DataSiftPush.get(Stream hash,
int page,
int perPage,
java.lang.String orderBy,
java.lang.String orderDirection,
boolean includeFinished) |
| Modifier and Type | Method and Description |
|---|---|
<T extends PushConnector> |
DataSiftPush.create(T connector,
FutureData<PreparedHistoricsQuery> historics,
FutureData<Stream> stream,
java.lang.String name) |
<T extends PushConnector> |
DataSiftPush.create(T connector,
FutureData<PreparedHistoricsQuery> historics,
FutureData<Stream> stream,
java.lang.String name,
Status initialStatus,
long start,
long end) |
| Modifier and Type | Field and Description |
|---|---|
protected java.util.Set<Stream> |
DataSiftMessage.hashes |
| Modifier and Type | Method and Description |
|---|---|
Stream |
StreamSubscription.stream() |
| Modifier and Type | Method and Description |
|---|---|
java.util.Set<Stream> |
DataSiftMessage.hashes() |
| Modifier and Type | Method and Description |
|---|---|
protected com.datasift.client.stream.DataSiftConnection |
ConnectionManager.obtainConnectionFor(Stream stream) |
ConnectionManager |
ConnectionManager.unsubscribe(Stream stream) |
| Constructor and Description |
|---|
StreamSubscription(Stream stream) |
Copyright © 2018. All Rights Reserved.