com.datasift.client

Class DataSiftClient

java.lang.Object

com.datasift.client.DataSiftApiClient

com.datasift.client.DataSiftClient

public class DataSiftClient
extends DataSiftApiClient

Field Summary

Fields

Modifier and Type	Field and Description
protected DataSiftAccount	account
java.lang.String	BALANCE
java.lang.String	COMPILE
protected DataSiftConfig	config
static java.lang.String	DATE_FORMAT
static int	DEFAULT_NUM
java.lang.String	DPU
protected DataSiftHistorics	historics
protected ConnectionManager	liveStream
static com.fasterxml.jackson.databind.ObjectMapper	MAPPER
protected DataSiftODP	odp
protected DataSiftPreview	preview
protected DataSiftPush	push
protected DataSiftPylon	pylon
protected DataSiftManagedSource	source
java.lang.String	USAGE
java.lang.String	VALIDATE

Constructor Summary

Constructors

Constructor and Description
DataSiftClient()
DataSiftClient(DataSiftConfig config)

Method Summary

Modifier and Type	Method and Description
DataSiftAccount	account()
FutureData<Balance>	balance()
FutureData<Stream>	compile(java.lang.String csdl)
DataSiftConfig	config()
protected void	configureMapper()
FutureData<Dpu>	dpu(FutureData<Stream> streamFuture)
FutureData<Dpu>	dpu(Stream stream)
FutureData<Dpu>	dpu(java.lang.String historicsId) Retrieve the DPU usage of a historics job
DataSiftHistorics	historics()
ConnectionManager	liveStream()
DataSiftManagedSource	managedSource()
DataSiftODP	odp()
DataSiftPreview	preview()
DataSiftPush	push()
DataSiftPylon	pylon()
void	shutdown()
FutureData<Usage>	usage()
FutureData<Usage>	usage(Usage.Period timePeriod)
FutureData<Validation>	validate(java.lang.String csdl)

Methods inherited from class com.datasift.client.DataSiftApiClient

failNotify, newParams, newRequestCallback, performRequest, unwrapFuture

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAPPER

public static final com.fasterxml.jackson.databind.ObjectMapper MAPPER

DATE_FORMAT

public static final java.lang.String DATE_FORMAT

See Also:

Constant Field Values

DEFAULT_NUM

public static final int DEFAULT_NUM

See Also:

Constant Field Values

config

protected DataSiftConfig config

pylon

protected DataSiftPylon pylon

odp

protected DataSiftODP odp

historics

protected DataSiftHistorics historics

source

protected DataSiftManagedSource source

preview

protected DataSiftPreview preview

push

protected DataSiftPush push

liveStream

protected ConnectionManager liveStream

account

protected DataSiftAccount account

VALIDATE

public final java.lang.String VALIDATE

See Also:

Constant Field Values

COMPILE

public final java.lang.String COMPILE

See Also:

Constant Field Values

BALANCE

public final java.lang.String BALANCE

See Also:

Constant Field Values

DPU

public final java.lang.String DPU

See Also:

Constant Field Values

USAGE

public final java.lang.String USAGE

See Also:

Constant Field Values

Constructor Detail

DataSiftClient

public DataSiftClient()

DataSiftClient

public DataSiftClient(DataSiftConfig config)

Method Detail

configureMapper

protected void configureMapper()

account

public DataSiftAccount account()

pylon

public DataSiftPylon pylon()

odp

public DataSiftODP odp()

historics

public DataSiftHistorics historics()

managedSource

public DataSiftManagedSource managedSource()

preview

public DataSiftPreview preview()

push

public DataSiftPush push()

config

public DataSiftConfig config()

liveStream

public ConnectionManager liveStream()

validate

public FutureData<Validation> validate(java.lang.String csdl)

compile

public FutureData<Stream> compile(java.lang.String csdl)

balance

public FutureData<Balance> balance()

dpu

public FutureData<Dpu> dpu(Stream stream)

dpu

public FutureData<Dpu> dpu(FutureData<Stream> streamFuture)

dpu

public FutureData<Dpu> dpu(java.lang.String historicsId)

Retrieve the DPU usage of a historics job

Parameters:

historicsId - id of the historics job to get the DPU usage of

Returns:

future containing DPU response

usage

public FutureData<Usage> usage()

usage

public FutureData<Usage> usage(Usage.Period timePeriod)

shutdown

public void shutdown()