com.endeca.portal.mdex

Class IngestUtil

java.lang.Object

com.endeca.portal.mdex.IngestUtil

public class IngestUtil
extends java.lang.Object

Utility class for data-ingest-related actions

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	INGEST_SERVICE

Constructor Summary

Constructors

Constructor and Description
IngestUtil()

Method Summary

Methods

Modifier and Type	Method and Description
static void	executeAddProject(com.oracle.endeca.pdi.mdex.ingest.IngestClient ingestClient, java.util.List<com.oracle.endeca.pdi.concepts.Kvp<?>> kvpList, RequestIds requestIds)
static void	executeDeleteProject(com.oracle.endeca.pdi.mdex.ingest.IngestClient ingestClient, com.oracle.endeca.pdi.concepts.Kvp<java.lang.Long> kvp, RequestIds requestIds)
static com.endeca.mdex.ingest.types.IngestChangesResponse	executeIngest(com.endeca.mdex.ingest.types.IngestChanges changes, RequestIds requestIds) Execute ingest
static void	executeUpdateDataset(com.oracle.endeca.pdi.mdex.ingest.IngestClient ingestClient, java.lang.String datasetId, long versionNumber, java.util.List<com.oracle.endeca.pdi.concepts.Kvp<?>> kvpList, java.lang.Iterable<java.lang.String> deleteKeys, RequestIds requestIds)
static void	executeUpdateProject(com.oracle.endeca.pdi.mdex.ingest.IngestClient ingestClient, long groupId, long versionNumber, java.util.List<com.oracle.endeca.pdi.concepts.Kvp<?>> kvpList, java.util.List<java.lang.String> deleteKeys, RequestIds requestIds)

Methods inherited from class java.lang.Object

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

Field Detail

INGEST_SERVICE

public static final java.lang.String INGEST_SERVICE

See Also:

Constant Field Values

Constructor Detail

IngestUtil

public IngestUtil()

Method Detail

executeIngest

public static com.endeca.mdex.ingest.types.IngestChangesResponse executeIngest(com.endeca.mdex.ingest.types.IngestChanges changes,
                                                               RequestIds requestIds)
                                                                        throws DataSourceException

Execute ingest

Parameters:

ingestChanges -

Throws:

DataSourceException

executeAddProject

public static void executeAddProject(com.oracle.endeca.pdi.mdex.ingest.IngestClient ingestClient,
                     java.util.List<com.oracle.endeca.pdi.concepts.Kvp<?>> kvpList,
                     RequestIds requestIds)
                              throws DataSourceException,
                                     com.oracle.endeca.pdi.mdex.ingest.OptimisticLockingException

Throws:

DataSourceException

com.oracle.endeca.pdi.mdex.ingest.OptimisticLockingException

executeUpdateProject

public static void executeUpdateProject(com.oracle.endeca.pdi.mdex.ingest.IngestClient ingestClient,
                        long groupId,
                        long versionNumber,
                        java.util.List<com.oracle.endeca.pdi.concepts.Kvp<?>> kvpList,
                        java.util.List<java.lang.String> deleteKeys,
                        RequestIds requestIds)
                                 throws DataSourceException,
                                        com.oracle.endeca.pdi.mdex.ingest.OptimisticLockingException

Throws:

DataSourceException

com.oracle.endeca.pdi.mdex.ingest.OptimisticLockingException

executeDeleteProject

public static void executeDeleteProject(com.oracle.endeca.pdi.mdex.ingest.IngestClient ingestClient,
                        com.oracle.endeca.pdi.concepts.Kvp<java.lang.Long> kvp,
                        RequestIds requestIds)
                                 throws DataSourceException,
                                        com.oracle.endeca.pdi.mdex.ingest.OptimisticLockingException

Throws:

DataSourceException

com.oracle.endeca.pdi.mdex.ingest.OptimisticLockingException

executeUpdateDataset

public static void executeUpdateDataset(com.oracle.endeca.pdi.mdex.ingest.IngestClient ingestClient,
                        java.lang.String datasetId,
                        long versionNumber,
                        java.util.List<com.oracle.endeca.pdi.concepts.Kvp<?>> kvpList,
                        java.lang.Iterable<java.lang.String> deleteKeys,
                        RequestIds requestIds)
                                 throws DataSourceException,
                                        com.oracle.endeca.pdi.mdex.ingest.OptimisticLockingException

Throws:

DataSourceException

com.oracle.endeca.pdi.mdex.ingest.OptimisticLockingException