com.ibm.di.server
Class DeltaTaskComponent

java.lang.Object
  com.ibm.di.server.AssemblyLineComponent
      com.ibm.di.server.DeltaTaskComponent

public class DeltaTaskComponent
extends AssemblyLineComponent

Field Summary

Fields inherited from class com.ibm.di.server.AssemblyLineComponent

addmap, CHECKPOINT_GETS, config, connConfig, connector, connPool, handler, imap, INITIALIZE, log, modmap, name, parent, pooledConnector, restartCycle, reusingConnector, SELECT, stats

Constructor Summary

DeltaTaskComponent(AssemblyLine parent, String name, ConnectorConfig config, ConnectorInterface conn)

DeltaTaskComponent(AssemblyLine parent, String name, ConnectorConfig config, ConnectorInterface conn, boolean forceRuntime)

Method Summary

static boolean	deltaEnabled(ConnectorConfig config)
Entry	getnext() The method returns the next entry from the connector.
Entry	getnext(Entry work) The method returns the next entry from the connector.
Entry	nextDeletedEntry(Entry work) Return the next deleted entry

Methods inherited from class com.ibm.di.server.AssemblyLineComponent

add, callreply, checkInitialize, checkTerminate, close, debug, delete, deleteEntry, delta, doConnectorInitialize, doConnectorTerminate, dumpEntry, dumpObjects, expandParameters, getBaseConfiguration, getConfig, getConfiguration, getConnector, getConnectorParam, getCriteria, getCurrent, getDebug, getDuplicateEntryCount, getFirstDuplicateEntry, getHandler, getLastEntry, getLastReadEntry, getLog, getName, getnextClient, getNextDuplicateEntry, getRestartInfoEntry, getStats, getType, handleException, handleSuccess, initialize, isCheckpointRestartEnabled, isDeltaMode, isEnabled, isExceptionFatal, logmsg, lookup, lookup, mapEntry, modify, pushback, reconnect, reply, setConnectorParam, setCriteria, setCriteria, setCurrent, setDebug, setDuplicateEntryCount, setErrorObject, setName, setRestartInfoEntry, trigger, trigger, trigger, update, verifySchema, wasConfigurationModified, willExecute

Methods inherited from class java.lang.Object

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

Constructor Detail

DeltaTaskComponent

public DeltaTaskComponent(AssemblyLine parent,
                          String name,
                          ConnectorConfig config,
                          ConnectorInterface conn)
                   throws Exception

Throws:

Exception

DeltaTaskComponent

public DeltaTaskComponent(AssemblyLine parent,
                          String name,
                          ConnectorConfig config,
                          ConnectorInterface conn,
                          boolean forceRuntime)
                   throws Exception

Throws:

Exception

Method Detail

deltaEnabled

public static boolean deltaEnabled(ConnectorConfig config)

getnext

public Entry getnext()
              throws Exception

Description copied from class: AssemblyLineComponent

The method returns the next entry from the connector.

Overrides:

getnext in class AssemblyLineComponent

Returns:

The next input entry or null if there are no more entries

Throws:

Exception - Errors that may occur

getnext

public Entry getnext(Entry work)
              throws Exception

Description copied from class: AssemblyLineComponent

The method returns the next entry from the connector. It is called by the AssemblyLine if we are working in Iterator mode.

Overrides:

getnext in class AssemblyLineComponent

Parameters:

work - The work entry to fill in

Returns:

The work entry filled with the next input entry, or null if there are no more entries

Throws:

Exception - Errors that may occur

nextDeletedEntry

public Entry nextDeletedEntry(Entry work)
                       throws Exception

Return the next deleted entry

Throws:

Exception