Uses of Class
com.datasift.client.core.Stream

Packages that use Stream

Package	Description
com.datasift.client
com.datasift.client.core
com.datasift.client.preview
com.datasift.client.push
com.datasift.client.stream

Uses of Stream in com.datasift.client

Methods in com.datasift.client that return types with arguments of type Stream

Modifier and Type	Method and Description
FutureData<Stream>	DataSiftClient.compile(String csdl) Compile a CSDL string to a stream hash to which you can later subscribe and receive interactions from

Methods in com.datasift.client with parameters of type Stream

Modifier and Type	Method and Description
FutureData<Dpu>	DataSiftClient.dpu(Stream stream)

Method parameters in com.datasift.client with type arguments of type Stream

Modifier and Type	Method and Description
FutureData<Dpu>	DataSiftClient.dpu(FutureData<Stream> streamFuture)

Uses of Stream in com.datasift.client.core

Methods in com.datasift.client.core that return Stream

Modifier and Type	Method and Description
static Stream	Stream.fromString(String str) Create a stream instance containing only a hash

Methods in com.datasift.client.core with parameters of type Stream

Modifier and Type	Method and Description
boolean	Stream.isSameAs(Stream hash)

Uses of Stream in com.datasift.client.preview

Methods in com.datasift.client.preview with parameters of type Stream

Modifier and Type	Method and Description
FutureData<HistoricsPreview>	DataSiftPreview.create(org.joda.time.DateTime start, org.joda.time.DateTime end, Stream hash, String[] params)
FutureData<HistoricsPreview>	DataSiftPreview.create(org.joda.time.DateTime now, Stream stream, String[] params)
FutureData<HistoricsPreview>	DataSiftPreview.create(long start, long end, Stream stream, String[] parameters) Create a historic preview for the given stream within the given time frame, using the set of parameters provided

Uses of Stream in com.datasift.client.push

Methods in com.datasift.client.push with parameters of type Stream

Modifier and Type	Method and Description
<T extends PushConnector> FutureData<PushSubscription>	DataSiftPush.create(T con, Stream stream, String name)
<T extends PushConnector> FutureData<PushSubscription>	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, 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<PushCollection>	DataSiftPush.get(Stream hash, int page, int perPage, String orderBy, String orderDirection, boolean includeFinished) Get all push subscriptions for the given stream

Method parameters in com.datasift.client.push with type arguments of type Stream

Modifier and Type	Method and Description
<T extends PushConnector> FutureData<PushSubscription>	DataSiftPush.create(T connector, FutureData<PreparedHistoricsQuery> historics, FutureData<Stream> stream, String name)
<T extends PushConnector> FutureData<PushSubscription>	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.

Uses of Stream in com.datasift.client.stream

Fields in com.datasift.client.stream with type parameters of type Stream

Modifier and Type	Field and Description
protected Set<Stream>	DataSiftMessage.hashes
protected Map<Stream,StreamSubscription>	StreamingData.subscriptions

Methods in com.datasift.client.stream that return Stream

Modifier and Type	Method and Description
Stream	StreamSubscription.stream()

Methods in com.datasift.client.stream that return types with arguments of type Stream

Modifier and Type	Method and Description
Set<Stream>	DataSiftMessage.hashes()

Methods in com.datasift.client.stream with parameters of type Stream

Modifier and Type	Method and Description
StreamingData	StreamingData.unsubscribe(Stream stream)

Constructors in com.datasift.client.stream with parameters of type Stream

Constructor and Description
StreamSubscription(Stream stream)