Uses of Class
com.datasift.client.FutureData

Packages that use FutureData

Package	Description
com.datasift.client
com.datasift.client.core
com.datasift.client.historics
com.datasift.client.managedsource
com.datasift.client.preview
com.datasift.client.push

Uses of FutureData in com.datasift.client

Methods in com.datasift.client that return FutureData

Modifier and Type	Method and Description
FutureData<T>	FutureData.onData(FutureResponse<T> response) Adds an event listener that is notified when data is received
static <A extends DataSiftResult> FutureData<A>	FutureData.wrap(A obj) Wraps any object in a FutureData instance Intended use is to enable any object obtained without a future to be passed to API methods.

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

Modifier and Type	Method and Description
protected <T extends DataSiftResult> io.higgs.core.func.Function2<String,io.higgs.http.client.Response>	DataSiftApiClient.newRequestCallback(FutureData<T> future, T instance)
protected <T extends DataSiftResult,A extends DataSiftResult> void	DataSiftApiClient.unwrapFuture(FutureData<T> futureToUnwrap, FutureData<A> futureReturnedToUser, A expectedInstance, FutureResponse<T> responseToExecuteOnSuccess) To support futures being passed as parameters, this method adds a listener to the unprocessed future that has been passed as a parameter.
protected <T extends DataSiftResult,A extends DataSiftResult> void	DataSiftApiClient.unwrapFuture(FutureData<T> futureToUnwrap, FutureData<A> futureReturnedToUser, A expectedInstance, FutureResponse<T> responseToExecuteOnSuccess) To support futures being passed as parameters, this method adds a listener to the unprocessed future that has been passed as a parameter.

Uses of FutureData in com.datasift.client.core

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

Modifier and Type	Method and Description
FutureData<Balance>	DataSiftCore.balance()
FutureData<Stream>	DataSiftCore.compile(String csdl) Compile a CSDL string to a stream hash to which you can later subscribe and receive interactions from
FutureData<Dpu>	DataSiftCore.dpu(FutureData<Stream> streamFuture)
FutureData<Dpu>	DataSiftCore.dpu(Stream stream)
FutureData<Usage>	DataSiftCore.usage()
FutureData<Usage>	DataSiftCore.usage(Usage.Period timePeriod)
FutureData<Validation>	DataSiftCore.validate(String csdl) Validate the given CSDL string against the DataSift API

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

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

Uses of FutureData in com.datasift.client.historics

Methods in com.datasift.client.historics that return FutureData

Modifier and Type	Method and Description
FutureData<DataSiftResult>	DataSiftHistorics.delete(PreparedHistoricsQuery query)
FutureData<DataSiftResult>	DataSiftHistorics.delete(String id) Delete the historic with the given ID
FutureData<HistoricsQueryList>	DataSiftHistorics.get(int max, int page, boolean withEstimate) Retrieve a list of HistoricsQuery objects
FutureData<HistoricsQuery>	DataSiftHistorics.get(String id)
FutureData<HistoricsQuery>	DataSiftHistorics.get(String id, boolean withEstimate) Get detailed information about a historics query
FutureData<PreparedHistoricsQuery>	DataSiftHistorics.prepare(String hash, org.joda.time.DateTime start, org.joda.time.DateTime end, String name)
FutureData<PreparedHistoricsQuery>	DataSiftHistorics.prepare(String hash, long start, long end, String name, int sample, String... sources)
FutureData<PreparedHistoricsQuery>	DataSiftHistorics.prepare(String hash, long start, long end, String name, String... sources)
FutureData<DataSiftResult>	DataSiftHistorics.start(FutureData<PreparedHistoricsQuery> query) Start the historics query given
FutureData<DataSiftResult>	DataSiftHistorics.start(String id) Start the historics query with the given ID
protected FutureData<DataSiftResult>	DataSiftHistorics.start(String id, FutureData<DataSiftResult> f)
FutureData<HistoricsStatus>	DataSiftHistorics.status(org.joda.time.DateTime start, org.joda.time.DateTime end)
FutureData<HistoricsStatus>	DataSiftHistorics.status(org.joda.time.DateTime start, org.joda.time.DateTime end, String... sources) Check the status of data availability in our archive for the given time period
FutureData<DataSiftResult>	DataSiftHistorics.stop(PreparedHistoricsQuery query, String reason)
FutureData<DataSiftResult>	DataSiftHistorics.stop(String id, String reason) Stop a given historics query
FutureData<DataSiftResult>	DataSiftHistorics.update(String id, String name) Update the name of a historics query

Methods in com.datasift.client.historics with parameters of type FutureData

Modifier and Type	Method and Description
FutureData<DataSiftResult>	DataSiftHistorics.start(FutureData<PreparedHistoricsQuery> query) Start the historics query given
protected FutureData<DataSiftResult>	DataSiftHistorics.start(String id, FutureData<DataSiftResult> f)

Uses of FutureData in com.datasift.client.managedsource

Methods in com.datasift.client.managedsource that return FutureData

Modifier and Type	Method and Description
<T extends DataSource> FutureData<ManagedSource>	DataSiftManagedSource.create(String name, T source) Create a new managed source
FutureData<DataSiftResult>	DataSiftManagedSource.delete(String id)
FutureData<ManagedSourceList>	DataSiftManagedSource.get()
FutureData<ManagedSourceList>	DataSiftManagedSource.get(int page)
FutureData<ManagedSourceList>	DataSiftManagedSource.get(int page, int perPage)
FutureData<ManagedSourceList>	DataSiftManagedSource.get(ManagedDataSourceType type, int page, int perPage) Get manage sources for the given type
FutureData<ManagedSource>	DataSiftManagedSource.get(String id)
FutureData<ManagedSourceLog>	DataSiftManagedSource.log(String id)
FutureData<ManagedSourceLog>	DataSiftManagedSource.log(String id, int page)
FutureData<ManagedSourceLog>	DataSiftManagedSource.log(String id, int page, int perPage)
FutureData<DataSiftResult>	DataSiftManagedSource.start(FutureData<ManagedSource> source)
FutureData<DataSiftResult>	DataSiftManagedSource.start(ManagedSource source)
FutureData<DataSiftResult>	DataSiftManagedSource.start(String id)
FutureData<ManagedSource>	DataSiftManagedSource.stop(String id)
<T extends DataSource> FutureData<ManagedSource>	DataSiftManagedSource.update(String name, T source, ManagedSource id) Update an existing managed source
protected <T extends DataSource> FutureData<ManagedSource>	DataSiftManagedSource.updateOrCreate(String name, T source, String id)

Methods in com.datasift.client.managedsource with parameters of type FutureData

Modifier and Type	Method and Description
FutureData<DataSiftResult>	DataSiftManagedSource.start(FutureData<ManagedSource> source)

Uses of FutureData in com.datasift.client.preview

Methods in com.datasift.client.preview that return FutureData

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
FutureData<HistoricsPreview>	DataSiftPreview.create(long start, long end, String hash, String[] parameters)
FutureData<HistoricsPreviewData>	DataSiftPreview.get(HistoricsPreview preview) Get the data that's available for the given preview
FutureData<HistoricsPreviewData>	DataSiftPreview.get(String id)

Uses of FutureData in com.datasift.client.push

Methods in com.datasift.client.push that return FutureData

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.
<T extends PushConnector> FutureData<PushSubscription>	DataSiftPush.create(T con, FutureData<PreparedHistoricsQuery> query, String name)
<T extends PushConnector> FutureData<PushSubscription>	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> 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<DataSiftResult>	DataSiftPush.delete(String id) Delete a push subsctiption
FutureData<PushCollection>	DataSiftPush.get(HistoricsQuery historics, int page, int perPage, String orderBy, String orderDirection, boolean includeFinished) Get all push subscriptions for the given historics
FutureData<PushCollection>	DataSiftPush.get(Stream hash, int page, int perPage, String orderBy, String orderDirection, boolean includeFinished) Get all push subscriptions for the given stream
FutureData<PushSubscription>	DataSiftPush.get(String id)
FutureData<PushLogMessages>	DataSiftPush.log(String id, int page)
FutureData<PushLogMessages>	DataSiftPush.log(String id, int page, int perPage, String orderBy, String orderDirection) Retreive log messages about subscriptions
FutureData<PushSubscription>	DataSiftPush.pause(String id) Pause the push subscription with the given ID
FutureData<PulledInteractions>	DataSiftPush.pull(String id, int size, String cursor) Retrieve one or more interactions from a Push queue
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
<T extends PushConnector> FutureData<PushValidation>	DataSiftPush.validate(T connector) Check that the subscription details are correct

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

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)
<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.
<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.
<T extends PushConnector> FutureData<PushSubscription>	DataSiftPush.create(T con, FutureData<PreparedHistoricsQuery> query, String name)