ABLE 2.0.0 07/02/2003 10:25:01

com.ibm.able.beans.knn
Class JasKnnDistributedAgent

java.lang.Object
  |
  +--com.ibm.able.AbleObject
        |
        +--com.ibm.able.AbleDefaultAgent
              |
              +--com.ibm.able.AbleRemoteDefaultAgent
                    |
                    +--com.ibm.able.platform.AblePlatformDefaultAgent
                          |
                          +--com.ibm.able.beans.knn.JasKnnDistributedAgent
All Implemented Interfaces:
AbleAgent, AbleBean, AbleBeanContainer, AbleBeanRemoteContainer, AbleDataBufferManager, AbleEventListener, AbleEventListenerManager, AbleEventListenerRemoteManager, AbleEventQueueManager, AbleEventQueueProcessor, AbleEventQueueRemoteManager, AblePlatformAgent, AblePropertyChangeManager, AbleRemoteAgent, AbleRemoteBean, AbleRemoteEventListener, AbleSerializable, AbleUserDefinedFunctionManager, AbleUserDefinedFunctionRemoteManager, java.util.EventListener, JasKnnDistributedAgentIF, javax.agent.service.transport.MessageListener, java.beans.PropertyChangeListener, java.rmi.Remote, java.io.Serializable

public class JasKnnDistributedAgent
extends AblePlatformDefaultAgent
implements JasKnnDistributedAgentIF, java.io.Serializable

This class defines a test for the AbleJasDefaultAgent object.

See Also:
Serialized Form

Field Summary
static java.lang.String defaultName
          Value assigned to name by default.
 
Fields inherited from class com.ibm.able.platform.AblePlatformDefaultAgent
agentLastUpdate, agentMovable, agentStatus, agentSummary, agentToAutoRegister, agentToBindToRmi, agentType, agentVendor, agentVersion, myAgentInboxes, myJasAbleLocator, myJasAgentAttributes, myJasAgentDescription, myJasAgentDirectoryService, myJasAgentName, myJasAgentNamingService, myJasDefaultLocator, myJasMessageTransportService, myJasServiceRoot, myJasTransportSystem, myJasVerifiableDirectoryService, myJasVerifiableNamingService, myKeyPair, myPrincipal, myReceiveMessageMethod, myRequestKey, mySecSppt, myTrustLevel, myVerifiableAgentName
 
Fields inherited from class com.ibm.able.AbleRemoteDefaultAgent
agentAddr, agentHost, agentName, myRemoteStub
 
Fields inherited from class com.ibm.able.AbleDefaultAgent
activeDataSource, eventConnections, myBeans, numEpochs, processList, processListOK, userDefinedFunctions
 
Fields inherited from class com.ibm.able.AbleObject
changed, chgSupport, comment, dataFlowEnabled, destBufferConnections, eventQueue, fileName, inputBuffer, listeners, logger, name, outputBuffer, parent, propertyConnectionMgr, sourceBufferConnections, state, stateChgSupport, trace
 
Constructor Summary
JasKnnDistributedAgent()
          Constructor for AbleKnnClassifierAgent
JasKnnDistributedAgent(java.lang.String theName)
          Constructor for AbleKnnClassifierAgent
 
Method Summary
static java.lang.String Copyright()
          Determine the copyright of this class.
protected  void debugTrace(java.lang.String theMessage)
          Log a trace message.
 int getBufferSize()
          Get the buffer size
 com.ibm.able.beans.knn.AbleKnnDistributed getDistributedKnnBean()
          Get the distributed agent 1 bean
 int getK()
          Get the k value
 com.ibm.able.beans.knn.AbleKnnDistributed getKnnBean()
          Get the knn bean
 AbleFilter getKnnFil1()
          Get the filter 1 bean
 AbleFilter getKnnFil2()
          Get the filter 2 bean
 AbleImport getKnnImp1()
          Get the import 1 bean
 int getNumAttributes()
          Get the number of attributes
 int getNumClasses()
          Get the number of classes
 long getNumRecords()
          Get the number of records
 java.lang.String getTrainDataFileName()
          Get the name of the training data file
 void handleAbleEvent(AbleEvent theAbleEvent)
          Handle an Able event.
 void init()
          Generate a k-NN Classifier agent bean.
 void reset()
          Reset each bean created when the agent was initialized.
 void sendTo(javax.agent.Locator theDestinationLocator, javax.agent.AgentName theDestinationAgentName, java.lang.Object theMessage)
           
 void setBufferSize(int size)
          Set the buffer size
protected  void setDefaults()
          Set default values for parameters
 void setFilt1(AbleFilter fil1)
          Set the filt1 from central agent
 void setFilt2(AbleFilter fil2)
          Set the filt1 from central agent
 void setK(int kVal)
          Set the k value from agent
 void setTrainDataFileName(java.lang.String aFileName)
          Set the name of the training data file
 
Methods inherited from class com.ibm.able.platform.AblePlatformDefaultAgent
_init, _init, _quitAll, _reset, _resumeAll, _suspendAll, addAgentInbox, addJasAgentAttribute, broadcastTransportMessage, createLocatorAndBindToMethod, getAgentAutonomyLevel, getAgentInboxes, getAgentLastUpdate, getAgentStatus, getAgentSummary, getAgentType, getAgentVendor, getAgentVersion, getAndSetAgentDescription, getAndSetAgentNames, getAndSetTransportServices, getAndValidateServiceRoot, getJasAgentAttributes, getJasAgentName, getNewAgentDescription, getPrincipal, getTransportMessageContent, getTransportMessageContent2, init, initializeAgent, initializeAgent, isAgentMovable, isAgentToAutoRegister, isAgentToBindToRmi, loadAgentDescriptionWithAbleAttributes, loadAgentDescriptionWithAbleLocator, loadAgentDescriptionWithAgentName, loadAgentDescriptionWithBaseLocators, loadAgentDescriptionWithPublicKey, loadAgentDescriptionWithUserAttributes, logException, lookUpAgent, lookUpAgent, main, maybeDeregisterWithAgentDirectoryService, maybeRebindToRmi, maybeRegisterWithAgentDirectoryService, maybeUnbindFromRmi, preInit, process, quitAgent, quitAll, receiveMessage, removeAgentInbox, removeAgentInboxes, removeJasAgentAttribute, resetAgent, resumeAgent, resumeAll, sendTransportMessage, sendTransportMessage, setAgentAutonomyLevel, setAgentAutonomyLevel, setAgentMovable, setAgentSummary, setAgentToAutoRegister, setAgentToBindToRmi, setAgentType, setAgentVendor, setAgentVersion, setPrincipal, setRequestKey, suspendAgent, suspendAll, toString, updateDescriptionWithAgentDirectoryService
 
Methods inherited from class com.ibm.able.AbleRemoteDefaultAgent
getAgentAddr, getAgentHost, getAgentName, rmiRebind, rmiUnbind
 
Methods inherited from class com.ibm.able.AbleDefaultAgent
addBean, addBeans, addEventConnection, addUserDefinedFunction, buildProcessList, clsNm, containsBean, containsBean, containsUserDefinedFunction, generateUniqueName, getBean, getBeans, getDataSource, getNumEpochs, getProcessList, getUserDefinedFunction, getUserDefinedFunctions, invokeUserDefinedFunction, isActiveDataSource, process, propertyChange, quitEnabledEventProcessing, removeAllBeans, removeAllConnections, removeAllEventConnections, removeBean, removeBean, removeBeans, removeEventConnection, removeUserDefinedFunction, setActiveDataSource, setDataFlowEnabled, setProcessList, setUserDefinedFunctions
 
Methods inherited from class com.ibm.able.AbleObject
addAbleEventListener, addDestBufferConnection, addPropertyChangeListener, addPropertyConnection, addSourceBufferConnection, addStateChangeListener, dataChanged, firePropertyChange, flushAbleEventQueue, getAbleEventListeners, getAbleEventProcessingEnabled, getAbleEventQueueSize, getComment, getDestBufferConnections, getFileName, getInputBuffer, getInputBuffer, getInputBufferAsStringArray, getInputBufferContents, getLogger, getName, getOutputBuffer, getOutputBuffer, getOutputBufferAsStringArray, getOutputBufferContents, getParent, getPropertyConnectionManager, getSleepTime, getSourceBufferConnections, getState, getTraceLogger, hasInputBuffer, hasOutputBuffer, isAbleEventPostingEnabled, isAbleEventProcessingEnabled, isChanged, isConnectable, isDataFlowEnabled, isTimerEventProcessingEnabled, notifyAbleEventListeners, processAbleEvent, processBufferConnections, processNoEventProcessingEnabledSituation, processTimerEvent, removeAbleEventListener, removeAllAbleEventListeners, removeAllBufferConnections, removeAllPropertyConnections, removeDestBufferConnection, removePropertyChangeListener, removePropertyConnection, removeSourceBufferConnection, removeStateChangeListener, restartEnabledEventProcessing, restoreFromFile, restoreFromFile, restoreFromSerializedFile, restoreFromStream, resumeEnabledEventProcessing, saveToFile, saveToFile, setAbleEventProcessingEnabled, setChanged, setComment, setFileName, setInputBuffer, setInputBuffer, setLogger, setName, setOutputBuffer, setOutputBuffer, setParent, setSleepTime, setState, setTimerEventProcessingEnabled, setTraceLogger, sourceConnectionsOK, startEnabledEventProcessing, suspendEnabledEventProcessing
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface com.ibm.able.platform.AblePlatformAgent
getAgentAutonomyLevel, getAgentLastUpdate, getAgentStatus, getAgentSummary, getAgentType, getAgentVendor, getAgentVersion, getJasAgentAttributes, getJasAgentName, initializeAgent, initializeAgent, isAgentMovable, isAgentToAutoRegister, isAgentToBindToRmi, preInit, quitAgent, resetAgent, resumeAgent, setAgentAutonomyLevel, suspendAgent
 
Methods inherited from interface com.ibm.able.AbleRemoteAgent
addEventConnection, getAgentAddr, getAgentHost, getAgentName, getDataSource, isActiveDataSource, removeEventConnection, setActiveDataSource
 
Methods inherited from interface com.ibm.able.AbleRemoteBean
getName, getState, init, process, process, quitAll, resumeAll, suspendAll
 
Methods inherited from interface com.ibm.able.AbleEventListenerRemoteManager
addAbleEventListener, notifyAbleEventListeners, removeAbleEventListener
 
Methods inherited from interface com.ibm.able.AbleEventQueueRemoteManager
flushAbleEventQueue, getAbleEventProcessingEnabled, getAbleEventQueueSize, getSleepTime, isTimerEventProcessingEnabled, quitEnabledEventProcessing, restartEnabledEventProcessing, resumeEnabledEventProcessing, setAbleEventProcessingEnabled, setSleepTime, setTimerEventProcessingEnabled, startEnabledEventProcessing, suspendEnabledEventProcessing
 
Methods inherited from interface com.ibm.able.AbleBeanRemoteContainer
addBean, containsBean, containsBean, getBean, getBeans, removeAllBeans, removeBean, removeBean
 
Methods inherited from interface com.ibm.able.AbleUserDefinedFunctionRemoteManager
addUserDefinedFunction, containsUserDefinedFunction, getUserDefinedFunction, getUserDefinedFunctions, invokeUserDefinedFunction, removeUserDefinedFunction, setUserDefinedFunctions
 
Methods inherited from interface javax.agent.service.transport.MessageListener
equals, hashCode
 
Methods inherited from interface com.ibm.able.AbleBean
getComment, getLogger, getName, getParent, getState, getTraceLogger, isChanged, setChanged, setComment, setLogger, setName, setParent, setState, setTraceLogger
 
Methods inherited from interface com.ibm.able.AbleDataBufferManager
addDestBufferConnection, addSourceBufferConnection, getDestBufferConnections, getInputBuffer, getInputBuffer, getInputBufferAsStringArray, getInputBufferContents, getOutputBuffer, getOutputBuffer, getOutputBufferAsStringArray, getOutputBufferContents, getSourceBufferConnections, hasInputBuffer, hasOutputBuffer, isConnectable, isDataFlowEnabled, processBufferConnections, removeAllBufferConnections, removeDestBufferConnection, removeSourceBufferConnection, setInputBuffer, setInputBuffer, setOutputBuffer, setOutputBuffer
 
Methods inherited from interface com.ibm.able.AbleEventListenerManager
addAbleEventListener, dataChanged, getAbleEventListeners, notifyAbleEventListeners, removeAbleEventListener
 
Methods inherited from interface com.ibm.able.AbleEventQueueManager
flushAbleEventQueue, getAbleEventProcessingEnabled, getAbleEventQueueSize, getSleepTime, isAbleEventPostingEnabled, isAbleEventProcessingEnabled, isTimerEventProcessingEnabled, restartEnabledEventProcessing, resumeEnabledEventProcessing, setAbleEventProcessingEnabled, setSleepTime, setTimerEventProcessingEnabled, startEnabledEventProcessing, suspendEnabledEventProcessing
 
Methods inherited from interface com.ibm.able.AbleEventQueueProcessor
processAbleEvent, processNoEventProcessingEnabledSituation, processTimerEvent
 
Methods inherited from interface com.ibm.able.AblePropertyChangeManager
addPropertyChangeListener, addPropertyConnection, getPropertyConnectionManager, removeAllPropertyConnections, removePropertyChangeListener, removePropertyConnection
 
Methods inherited from interface com.ibm.able.AbleSerializable
getFileName, restoreFromFile, restoreFromFile, saveToFile, saveToFile, setFileName
 
Methods inherited from interface com.ibm.able.AbleBeanContainer
getName
 

Field Detail

defaultName

public static final java.lang.String defaultName
Value assigned to name by default.
Constructor Detail

JasKnnDistributedAgent

public JasKnnDistributedAgent()
                       throws java.rmi.RemoteException,
                              AbleException
Constructor for AbleKnnClassifierAgent

JasKnnDistributedAgent

public JasKnnDistributedAgent(java.lang.String theName)
                       throws java.rmi.RemoteException,
                              AbleException
Constructor for AbleKnnClassifierAgent
Method Detail

setDefaults

protected void setDefaults()
                    throws AbleException
Set default values for parameters

getDistributedKnnBean

public com.ibm.able.beans.knn.AbleKnnDistributed getDistributedKnnBean()
Get the distributed agent 1 bean

init

public void init()
          throws AbleException
Generate a k-NN Classifier agent bean. If the training data file is not set, no action is taken. If the test data file is not set, the test import and filter beans are not generated. The following attributes must be set before initialization:
  1. trainDataFileName
  2. testDataFileName
The value for 'k' may also be set before initialization.
Specified by:
init in interface AbleRemoteBean
Overrides:
init in class AblePlatformDefaultAgent
Following copied from interface: com.ibm.able.AbleRemoteBean
Throws:
java.rmi.RemoteException - If an error occurs.

reset

public void reset()
           throws AbleException
Reset each bean created when the agent was initialized. Restore processing options to default values.
Specified by:
reset in interface AbleRemoteBean
Overrides:
reset in class AblePlatformDefaultAgent
Following copied from interface: com.ibm.able.AbleRemoteBean
Throws:
java.rmi.RemoteException - If an error occurs.

handleAbleEvent

public void handleAbleEvent(AbleEvent theAbleEvent)
                     throws AbleException
Handle an Able event.

In this implementation, special processing occurs for EOF on the active data source. All other events are passed up to the superclass (AbleObject) for processing.

Specified by:
handleAbleEvent in interface AbleRemoteEventListener
Overrides:
handleAbleEvent in class AbleDefaultAgent
Parameters:
theAbleEvent - The event to handle.


setTrainDataFileName

public void setTrainDataFileName(java.lang.String aFileName)
                          throws AbleException
Set the name of the training data file

getTrainDataFileName

public java.lang.String getTrainDataFileName()
Get the name of the training data file

setBufferSize

public void setBufferSize(int size)
Set the buffer size

getBufferSize

public int getBufferSize()
Get the buffer size

getKnnBean

public com.ibm.able.beans.knn.AbleKnnDistributed getKnnBean()
Get the knn bean

getKnnImp1

public AbleImport getKnnImp1()
Get the import 1 bean

getKnnFil1

public AbleFilter getKnnFil1()
Get the filter 1 bean

getKnnFil2

public AbleFilter getKnnFil2()
Get the filter 2 bean

setK

public void setK(int kVal)
Set the k value from agent

setFilt1

public void setFilt1(AbleFilter fil1)
Set the filt1 from central agent

setFilt2

public void setFilt2(AbleFilter fil2)
Set the filt1 from central agent

getK

public int getK()
Get the k value

getNumRecords

public long getNumRecords()
Get the number of records

getNumClasses

public int getNumClasses()
Get the number of classes

getNumAttributes

public int getNumAttributes()
Get the number of attributes

sendTo

public void sendTo(javax.agent.Locator theDestinationLocator,
                   javax.agent.AgentName theDestinationAgentName,
                   java.lang.Object theMessage)
            throws AbleException
Specified by:
sendTo in interface JasKnnDistributedAgentIF

debugTrace

protected void debugTrace(java.lang.String theMessage)
Log a trace message.
Overrides:
debugTrace in class AbleDefaultAgent
Parameters:
theMessage - A String containing text to be traced.


Copyright

public static java.lang.String Copyright()
Determine the copyright of this class.
Returns:
A String containing this class's copyright statement.

ABLE 2.0.0 07/02/2003 10:25:01

(C) Copyright IBM Corporation 1999, 2003