| Modifier and Type | Method and Description |
|---|---|
FutureData<Balance> |
DataSiftClient.balance() |
FutureData<Stream> |
DataSiftClient.compile(java.lang.String csdl) |
FutureData<Dpu> |
DataSiftClient.dpu(FutureData<Stream> streamFuture) |
FutureData<Dpu> |
DataSiftClient.dpu(Stream stream) |
FutureData<Dpu> |
DataSiftClient.dpu(java.lang.String historicsId)
Retrieve the DPU usage of a historics job
|
FutureData<T> |
FutureData.onData(FutureResponse<T> response) |
FutureData<Usage> |
DataSiftClient.usage() |
FutureData<Usage> |
DataSiftClient.usage(Usage.Period timePeriod) |
FutureData<Validation> |
DataSiftClient.validate(java.lang.String csdl) |
static <A extends BaseDataSiftResult> |
FutureData.wrap(A obj) |
| Modifier and Type | Method and Description |
|---|---|
FutureData<Dpu> |
DataSiftClient.dpu(FutureData<Stream> streamFuture) |
protected <T extends DataSiftResult> |
DataSiftApiClient.failNotify(FutureData<T> response,
java.lang.Throwable cause) |
protected <T extends DataSiftResult> |
DataSiftApiClient.newRequestCallback(FutureData<T> future,
T instance,
DataSiftConfig config) |
protected <T extends DataSiftResult> |
DataSiftApiClient.performRequest(FutureData<T> response,
io.higgs.http.client.Request request) |
protected <T extends DataSiftResult,A extends DataSiftResult> |
DataSiftApiClient.unwrapFuture(FutureData<T> futureToUnwrap,
FutureData<A> futureReturnedToUser,
A expectedInstance,
FutureResponse<T> responseToExecuteOnSuccess) |
protected <T extends DataSiftResult,A extends DataSiftResult> |
DataSiftApiClient.unwrapFuture(FutureData<T> futureToUnwrap,
FutureData<A> futureReturnedToUser,
A expectedInstance,
FutureResponse<T> responseToExecuteOnSuccess) |
| Modifier and Type | Method and Description |
|---|---|
FutureData<Identity> |
DataSiftAccount.create(java.lang.String label) |
FutureData<Identity> |
DataSiftAccount.create(java.lang.String label,
boolean active) |
FutureData<Identity> |
DataSiftAccount.create(java.lang.String label,
boolean active,
boolean master) |
FutureData<Limit> |
DataSiftAccount.createLimit(java.lang.String identity,
java.lang.String service,
java.lang.Long allowance) |
FutureData<Token> |
DataSiftAccount.createToken(java.lang.String identity,
java.lang.String service,
java.lang.String token) |
FutureData<DataSiftResult> |
DataSiftAccount.delete(java.lang.String id) |
FutureData<DataSiftResult> |
DataSiftAccount.deleteLimit(java.lang.String identity,
java.lang.String service) |
FutureData<DataSiftResult> |
DataSiftAccount.deleteToken(java.lang.String identity,
java.lang.String service) |
FutureData<Identity> |
DataSiftAccount.get(java.lang.String id) |
FutureData<Limit> |
DataSiftAccount.getLimit(java.lang.String identity,
java.lang.String service) |
FutureData<Token> |
DataSiftAccount.getToken(java.lang.String identity,
java.lang.String service) |
FutureData<UsageResult> |
DataSiftAccount.getUsage(java.lang.String period,
int start,
int end) |
FutureData<IdentityList> |
DataSiftAccount.list() |
FutureData<IdentityList> |
DataSiftAccount.list(int page) |
FutureData<IdentityList> |
DataSiftAccount.list(int page,
int perPage) |
FutureData<IdentityList> |
DataSiftAccount.list(java.lang.String label) |
FutureData<IdentityList> |
DataSiftAccount.list(java.lang.String label,
int page) |
FutureData<IdentityList> |
DataSiftAccount.list(java.lang.String label,
int page,
int perPage) |
FutureData<LimitList> |
DataSiftAccount.listLimits(java.lang.String service) |
FutureData<LimitList> |
DataSiftAccount.listLimits(java.lang.String service,
int page) |
FutureData<LimitList> |
DataSiftAccount.listLimits(java.lang.String service,
int page,
int perPage) |
FutureData<TokenList> |
DataSiftAccount.listTokens(java.lang.String identity) |
FutureData<TokenList> |
DataSiftAccount.listTokens(java.lang.String identity,
int page) |
FutureData<TokenList> |
DataSiftAccount.listTokens(java.lang.String identity,
int page,
int perPage) |
FutureData<Identity> |
DataSiftAccount.update(java.lang.String id,
java.lang.String label,
java.lang.Boolean active,
java.lang.Boolean master) |
FutureData<Limit> |
DataSiftAccount.updateLimit(java.lang.String identity,
java.lang.String service,
java.lang.Long allowance) |
FutureData<Token> |
DataSiftAccount.updateToken(java.lang.String identity,
java.lang.String service,
java.lang.String token) |
| Modifier and Type | Method and Description |
|---|---|
FutureData<DataSiftResult> |
DataSiftHistorics.delete(PreparedHistoricsQuery query) |
FutureData<DataSiftResult> |
DataSiftHistorics.delete(java.lang.String id) |
FutureData<HistoricsQuery> |
DataSiftHistorics.get(java.lang.String id) |
FutureData<HistoricsQuery> |
DataSiftHistorics.get(java.lang.String id,
boolean withEstimate) |
FutureData<HistoricsQueryList> |
DataSiftHistorics.list() |
FutureData<HistoricsQueryList> |
DataSiftHistorics.list(int page) |
FutureData<HistoricsQueryList> |
DataSiftHistorics.list(int max,
int page) |
FutureData<HistoricsQueryList> |
DataSiftHistorics.list(int max,
int page,
boolean withEstimate) |
FutureData<PreparedHistoricsQuery> |
DataSiftHistorics.prepare(java.lang.String hash,
org.joda.time.DateTime start,
org.joda.time.DateTime end,
java.lang.String name,
java.lang.String... sources) |
FutureData<PreparedHistoricsQuery> |
DataSiftHistorics.prepare(java.lang.String hash,
long start,
long end,
java.lang.String name,
int sample,
java.lang.String... sources) |
FutureData<PreparedHistoricsQuery> |
DataSiftHistorics.prepare(java.lang.String hash,
long start,
long end,
java.lang.String name,
java.lang.String... sources) |
FutureData<DataSiftResult> |
DataSiftHistorics.start(FutureData<PreparedHistoricsQuery> query) |
FutureData<DataSiftResult> |
DataSiftHistorics.start(PreparedHistoricsQuery query) |
FutureData<DataSiftResult> |
DataSiftHistorics.start(java.lang.String id) |
protected FutureData<DataSiftResult> |
DataSiftHistorics.start(java.lang.String id,
FutureData<DataSiftResult> f) |
FutureData<HistoricsStatus> |
DataSiftHistorics.status(org.joda.time.DateTime start,
org.joda.time.DateTime end,
java.lang.String... sources) |
FutureData<DataSiftResult> |
DataSiftHistorics.stop(PreparedHistoricsQuery query,
java.lang.String reason) |
FutureData<DataSiftResult> |
DataSiftHistorics.stop(java.lang.String id,
java.lang.String reason) |
FutureData<DataSiftResult> |
DataSiftHistorics.update(java.lang.String id,
java.lang.String name) |
| Modifier and Type | Method and Description |
|---|---|
FutureData<DataSiftResult> |
DataSiftHistorics.start(FutureData<PreparedHistoricsQuery> query) |
protected FutureData<DataSiftResult> |
DataSiftHistorics.start(java.lang.String id,
FutureData<DataSiftResult> f) |
| Modifier and Type | Method and Description |
|---|---|
FutureData<ManagedSource> |
DataSiftManagedSource.addAuth(java.lang.String id,
boolean validate,
java.lang.String... resources) |
FutureData<ManagedSource> |
DataSiftManagedSource.addAuth(java.lang.String id,
java.lang.String... resources) |
FutureData<ManagedSource> |
DataSiftManagedSource.addResource(java.lang.String id,
boolean validate,
BaseSource.ResourceParams... resources) |
<T extends DataSource> |
DataSiftManagedSource.create(java.lang.String name,
T source) |
<T extends DataSource> |
DataSiftManagedSource.create(java.lang.String name,
T source,
boolean validate) |
FutureData<DataSiftResult> |
DataSiftManagedSource.delete(java.lang.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) |
FutureData<ManagedSource> |
DataSiftManagedSource.get(java.lang.String id) |
FutureData<ManagedSourceLog> |
DataSiftManagedSource.log(java.lang.String id) |
FutureData<ManagedSourceLog> |
DataSiftManagedSource.log(java.lang.String id,
int page) |
FutureData<ManagedSourceLog> |
DataSiftManagedSource.log(java.lang.String id,
int page,
int perPage) |
FutureData<ManagedSource> |
DataSiftManagedSource.removeAuth(java.lang.String id,
java.lang.String... resources) |
FutureData<ManagedSource> |
DataSiftManagedSource.removeResource(java.lang.String id,
java.lang.String... resources) |
FutureData<DataSiftResult> |
DataSiftManagedSource.start(FutureData<ManagedSource> source) |
FutureData<DataSiftResult> |
DataSiftManagedSource.start(ManagedSource source) |
FutureData<DataSiftResult> |
DataSiftManagedSource.start(java.lang.String id) |
FutureData<ManagedSource> |
DataSiftManagedSource.stop(java.lang.String id) |
<T extends DataSource> |
DataSiftManagedSource.update(java.lang.String name,
T source,
ManagedSource id) |
<T extends DataSource> |
DataSiftManagedSource.update(java.lang.String name,
T source,
ManagedSource id,
java.lang.Boolean validate) |
protected <T extends DataSource> |
DataSiftManagedSource.updateOrCreate(java.lang.String name,
T source,
java.lang.String id) |
protected <T extends DataSource> |
DataSiftManagedSource.updateOrCreate(java.lang.String name,
T source,
java.lang.String id,
java.lang.Boolean validate) |
| Modifier and Type | Method and Description |
|---|---|
FutureData<DataSiftResult> |
DataSiftManagedSource.start(FutureData<ManagedSource> source) |
| Modifier and Type | Method and Description |
|---|---|
FutureData<ODPBatchResponse> |
DataSiftODP.batch(java.lang.String sourceId,
java.lang.String interactions) |
| 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) |
FutureData<HistoricsPreview> |
DataSiftPreview.create(long start,
long end,
java.lang.String hash,
java.lang.String[] parameters) |
FutureData<HistoricsPreviewData> |
DataSiftPreview.get(HistoricsPreview preview) |
FutureData<HistoricsPreviewData> |
DataSiftPreview.get(java.lang.String id) |
| 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) |
<T extends PushConnector> |
DataSiftPush.create(T con,
FutureData<PreparedHistoricsQuery> query,
java.lang.String name) |
<T extends PushConnector> |
DataSiftPush.create(T connector,
PreparedHistoricsQuery historics,
java.lang.String name,
Status initialStatus,
long start,
long end) |
<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,
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<DataSiftResult> |
DataSiftPush.delete(java.lang.String id) |
FutureData<PushCollection> |
DataSiftPush.get(HistoricsQuery historics,
int page,
int perPage,
java.lang.String orderBy,
java.lang.String orderDirection,
boolean includeFinished) |
FutureData<PushCollection> |
DataSiftPush.get(int page,
int perPage,
java.lang.String orderBy,
java.lang.String orderDirection,
boolean includeFinished) |
FutureData<PushCollection> |
DataSiftPush.get(Stream hash,
int page,
int perPage,
java.lang.String orderBy,
java.lang.String orderDirection,
boolean includeFinished) |
FutureData<PushSubscription> |
DataSiftPush.get(java.lang.String id) |
FutureData<PushLogMessages> |
DataSiftPush.log(java.lang.String id,
int page) |
FutureData<PushLogMessages> |
DataSiftPush.log(java.lang.String id,
int page,
int perPage,
java.lang.String orderBy,
java.lang.String orderDirection) |
FutureData<PushSubscription> |
DataSiftPush.pause(java.lang.String id) |
FutureData<PulledInteractions> |
DataSiftPush.pull(PushSubscription id) |
FutureData<PulledInteractions> |
DataSiftPush.pull(PushSubscription id,
int size,
java.lang.String cursor) |
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) |
<T extends PushConnector> |
DataSiftPush.validate(T connector) |
| 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) |
<T extends PushConnector> |
DataSiftPush.create(T connector,
FutureData<PreparedHistoricsQuery> historics,
FutureData<Stream> stream,
java.lang.String name,
Status initialStatus,
long start,
long end) |
<T extends PushConnector> |
DataSiftPush.create(T connector,
FutureData<PreparedHistoricsQuery> historics,
FutureData<Stream> stream,
java.lang.String name,
Status initialStatus,
long start,
long end) |
<T extends PushConnector> |
DataSiftPush.create(T con,
FutureData<PreparedHistoricsQuery> query,
java.lang.String name) |
protected void |
DataSiftPush.sendPullRequest(FutureData<PulledInteractions> future,
PushSubscription id,
int size,
java.lang.String cursor,
java.net.URI uri,
PullReader reader) |
Copyright © 2018. All Rights Reserved.