com.endeca.portal.data

Class DGraphAgentUtil

java.lang.Object

com.endeca.portal.data.DGraphAgentUtil

public class DGraphAgentUtil
extends java.lang.Object

This class provides IngestStatus, ActiveIngests, CancelIngest and StartIngest operations to the Dgraph HDFS Agent. For BDT1.0, only IngestStatus method will be used in upload wizard.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	INGEST_STATUS_FAILED
static java.lang.String	INGEST_STATUS_IN_PROGRESS
static java.lang.String	INGEST_STATUS_SUCCESSFUL

Constructor Summary

Constructors

Constructor and Description
DGraphAgentUtil()

Method Summary

Methods

Modifier and Type	Method and Description
static boolean	cancelIngest(javax.portlet.PortletRequest request, java.util.List<java.lang.String> dataSetNames) Cancel all ingesting data sets
static java.lang.String	getActiveIngests(javax.portlet.PortletRequest request) get all active ingests name
static long	getIngestStatus(javax.portlet.PortletRequest request, java.lang.String dataSetName) Get the ingest status of data set
static long	getIngestStatus(RequestIds requestIds, java.lang.String dataSetName) Get the ingest status of data set
static boolean	startIngest(javax.portlet.PortletRequest request, java.lang.String dataSetName, java.lang.String userName, java.lang.String location) Start ingest a data set

Methods inherited from class java.lang.Object

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

Field Detail

INGEST_STATUS_IN_PROGRESS

public static final java.lang.String INGEST_STATUS_IN_PROGRESS

See Also:

Constant Field Values

INGEST_STATUS_FAILED

public static final java.lang.String INGEST_STATUS_FAILED

See Also:

Constant Field Values

INGEST_STATUS_SUCCESSFUL

public static final java.lang.String INGEST_STATUS_SUCCESSFUL

See Also:

Constant Field Values

Constructor Detail

DGraphAgentUtil

public DGraphAgentUtil()

Method Detail

getIngestStatus

public static long getIngestStatus(javax.portlet.PortletRequest request,
                   java.lang.String dataSetName)
                            throws org.apache.commons.httpclient.HttpException,
                                   java.io.IOException

Get the ingest status of data set

Parameters:

request - the UI request associated with this method call

dataSetName -

Returns:

-lL if no import currently in progress or return the number of created records if in progress.

Throws:

org.apache.commons.httpclient.HttpException

java.io.IOException

getIngestStatus

public static long getIngestStatus(RequestIds requestIds,
                   java.lang.String dataSetName)
                            throws org.apache.commons.httpclient.HttpException,
                                   java.io.IOException

Get the ingest status of data set

Parameters:

requestIds - contains the gesture/page/session context of the UI gesture associated with this method call

dataSetName -

Returns:

-lL if no import currently in progress or return the number of created records if in progress.

Throws:

org.apache.commons.httpclient.HttpException

java.io.IOException

getActiveIngests

public static java.lang.String getActiveIngests(javax.portlet.PortletRequest request)
                                         throws org.apache.commons.httpclient.HttpException,
                                                java.io.IOException

get all active ingests name

Parameters:

request - PortletRequest

Returns:

all data set names

Throws:

org.apache.commons.httpclient.HttpException

java.io.IOException

startIngest

public static boolean startIngest(javax.portlet.PortletRequest request,
                  java.lang.String dataSetName,
                  java.lang.String userName,
                  java.lang.String location)
                           throws org.apache.commons.httpclient.HttpException,
                                  java.io.IOException

Start ingest a data set

Parameters:

request - PortletRequest

dataSetName - Collection name

userName - HDFS file owner

location - HDFS directory containing the files

Returns:

boolean true if the response is successful, false if the response is failed.

Throws:

org.apache.commons.httpclient.HttpException

java.io.IOException

cancelIngest

public static boolean cancelIngest(javax.portlet.PortletRequest request,
                   java.util.List<java.lang.String> dataSetNames)
                            throws org.apache.commons.httpclient.HttpException,
                                   java.io.IOException

Cancel all ingesting data sets

Parameters:

request - PortletRequest

dataSetNames - the ingest of these data set will be canceled.

Returns:

boolean true if the response is successful, false if the response is failed.

Throws:

org.apache.commons.httpclient.HttpException

java.io.IOException