Java Doc for AbstractMultipleFTPerXFERJob.java in  » Workflow-Engines » pegasus-2.1.0 » org » griphyn » cPlanner » transfer » implementation » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation
1. 6.0 JDK Core
2. 6.0 JDK Modules
3. 6.0 JDK Modules com.sun
4. 6.0 JDK Modules com.sun.java
5. 6.0 JDK Modules sun
6. 6.0 JDK Platform
7. Ajax
8. Apache Harmony Java SE
9. Aspect oriented
10. Authentication Authorization
11. Blogger System
12. Build
13. Byte Code
14. Cache
15. Chart
16. Chat
17. Code Analyzer
18. Collaboration
19. Content Management System
20. Database Client
21. Database DBMS
22. Database JDBC Connection Pool
23. Database ORM
24. Development
25. EJB Server geronimo
26. EJB Server GlassFish
27. EJB Server JBoss 4.2.1
28. EJB Server resin 3.1.5
29. ERP CRM Financial
30. ESB
31. Forum
32. GIS
33. Graphic Library
34. Groupware
35. HTML Parser
36. IDE
37. IDE Eclipse
38. IDE Netbeans
39. Installer
40. Internationalization Localization
41. Inversion of Control
42. Issue Tracking
43. J2EE
44. JBoss
45. JMS
46. JMX
47. Library
48. Mail Clients
49. Net
50. Parser
51. PDF
52. Portal
53. Profiler
54. Project Management
55. Report
56. RSS RDF
57. Rule Engine
58. Science
59. Scripting
60. Search Engine
61. Security
62. Sevlet Container
63. Source Control
64. Swing Library
65. Template Engine
66. Test Coverage
67. Testing
68. UML
69. Web Crawler
70. Web Framework
71. Web Mail
72. Web Server
73. Web Services
74. Web Services apache cxf 2.0.1
75. Web Services AXIS2
76. Wiki Engine
77. Workflow Engines
78. XML
79. XML UI
Java
Java Tutorial
Java Open Source
Jar File Download
Java Articles
Java Products
Java by API
Photoshop Tutorials
Maya Tutorials
Flash Tutorials
3ds-Max Tutorials
Illustrator Tutorials
GIMP Tutorials
C# / C Sharp
C# / CSharp Tutorial
C# / CSharp Open Source
ASP.Net
ASP.NET Tutorial
JavaScript DHTML
JavaScript Tutorial
JavaScript Reference
HTML / CSS
HTML CSS Reference
C / ANSI-C
C Tutorial
C++
C++ Tutorial
Ruby
PHP
Python
Python Tutorial
Python Open Source
SQL Server / T-SQL
SQL Server / T-SQL Tutorial
Oracle PL / SQL
Oracle PL/SQL Tutorial
PostgreSQL
SQL / MySQL
MySQL Tutorial
VB.Net
VB.Net Tutorial
Flash / Flex / ActionScript
VBA / Excel / Access / Word
XML
XML Tutorial
Microsoft Office PowerPoint 2007 Tutorial
Microsoft Office Excel 2007 Tutorial
Microsoft Office Word 2007 Tutorial
Java Source Code / Java Documentation » Workflow Engines » pegasus 2.1.0 » org.griphyn.cPlanner.transfer.implementation 
Source Cross Reference  Class Diagram Java Document (Java Doc) 


java.lang.Object
   org.griphyn.cPlanner.transfer.implementation.Abstract
      org.griphyn.cPlanner.transfer.implementation.AbstractMultipleFTPerXFERJob

All known Subclasses:   org.griphyn.cPlanner.transfer.implementation.SRM,  org.griphyn.cPlanner.transfer.implementation.Transfer,  org.griphyn.cPlanner.transfer.implementation.Condor,  org.griphyn.cPlanner.transfer.implementation.CRFT,  org.griphyn.cPlanner.transfer.implementation.T2,  org.griphyn.cPlanner.transfer.implementation.RFT,
AbstractMultipleFTPerXFERJob
abstract public class AbstractMultipleFTPerXFERJob extends Abstract implements MultipleFTPerXFERJob(Code)
An abstract implementation for implementations that can handle multiple file transfers in a single file transfer job.
author:
   Karan Vahi
version:
   $Revision: 145 $



Constructor Summary
public  AbstractMultipleFTPerXFERJob(PegasusProperties properties, PlannerOptions options)
     The overloaded constructor, that is called by the Factory to load the class.

Method Summary
public  TransferJobcreateTransferJob(SubInfo job, Collection files, Collection execFiles, String txJobName, int jobClass)
     Constructs a general transfer job that handles multiple transfers per transfer job.
protected  TransformationCatalogEntrydefaultTCEntry(String namespace, String name, String version, String site)
     Returns a default TC entry to be used in case entry is not found in the transformation catalog.
Parameters:
  namespace - the namespace of the transfer transformation
Parameters:
  name - the logical name of the transfer transformation
Parameters:
  version - the version of the transfer transformation
Parameters:
  site - the site for which the default entry is required.
abstract protected  StringgenerateArgumentString(TransferJob job)
     It constructs the arguments to the transfer executable that need to be passed to the executable referred to in this transfer mode.
Parameters:
  job - the object containing the transfer node.
abstract protected  StringgetCompleteTCName()
     Returns the complete name for the transformation that the implementation is using..
abstract protected  StringgetDerivationName()
     Returns the logical name of the derivation that this implementation refers to.
abstract protected  StringgetDerivationNamespace()
     Returns the namespace of the derivation that this implementation refers to.
abstract protected  StringgetDerivationVersion()
     Returns the version of the derivation that this implementation refers to.
abstract protected  ListgetEnvironmentVariables(String site)
     Returns the environment profiles that are required for the default entry to sensibly work.
Parameters:
  site - the site where the job is going to run.
public  voidpostProcess(TransferJob job)
     An optional method that allows the derived classes to do their own post processing on the the transfer job before it is returned to the calling module.
protected  StringprepareSTDIN(String name, Collection files)
     Prepares the stdin for the transfer job.
abstract protected  voidwriteJumboStdIn(FileWriter stdIn, Collection files)
    


Constructor Detail
AbstractMultipleFTPerXFERJob
public AbstractMultipleFTPerXFERJob(PegasusProperties properties, PlannerOptions options)(Code)
The overloaded constructor, that is called by the Factory to load the class.
Parameters:
  properties - the properties object.
Parameters:
  options - the options passed to the Planner.




Method Detail
createTransferJob
public TransferJob createTransferJob(SubInfo job, Collection files, Collection execFiles, String txJobName, int jobClass)(Code)
Constructs a general transfer job that handles multiple transfers per transfer job. There are appropriate callouts to generate the implementation specific details.
Parameters:
  job - the SubInfo object for the job, in relation to whichthe transfer node is being added. Either the transfernode can be transferring this jobs input files tothe execution pool, or transferring this job's outputfiles to the output pool.
Parameters:
  files - collection of FileTransfer objectsrepresenting the data files and staged executables to betransferred.
Parameters:
  execFiles - subset collection of the files parameter, that identifiesthe executable files that are being transferred.
Parameters:
  txJobName - the name of transfer node.
Parameters:
  jobClass - the job Class for the newly added job. Can be one of thefollowing:stage-instage-outinter-pool transfer the created TransferJob.



defaultTCEntry
protected TransformationCatalogEntry defaultTCEntry(String namespace, String name, String version, String site)(Code)
Returns a default TC entry to be used in case entry is not found in the transformation catalog.
Parameters:
  namespace - the namespace of the transfer transformation
Parameters:
  name - the logical name of the transfer transformation
Parameters:
  version - the version of the transfer transformation
Parameters:
  site - the site for which the default entry is required. the default entry.



generateArgumentString
abstract protected String generateArgumentString(TransferJob job)(Code)
It constructs the arguments to the transfer executable that need to be passed to the executable referred to in this transfer mode.
Parameters:
  job - the object containing the transfer node. the argument string



getCompleteTCName
abstract protected String getCompleteTCName()(Code)
Returns the complete name for the transformation that the implementation is using.. the complete name.



getDerivationName
abstract protected String getDerivationName()(Code)
Returns the logical name of the derivation that this implementation refers to. the name of the derivation.



getDerivationNamespace
abstract protected String getDerivationNamespace()(Code)
Returns the namespace of the derivation that this implementation refers to. the namespace of the derivation.



getDerivationVersion
abstract protected String getDerivationVersion()(Code)
Returns the version of the derivation that this implementation refers to. the version of the derivation.



getEnvironmentVariables
abstract protected List getEnvironmentVariables(String site)(Code)
Returns the environment profiles that are required for the default entry to sensibly work.
Parameters:
  site - the site where the job is going to run. List of environment variables, else null in case where therequired environment variables could not be found.



postProcess
public void postProcess(TransferJob job)(Code)
An optional method that allows the derived classes to do their own post processing on the the transfer job before it is returned to the calling module.
Parameters:
  job - the TransferJob that has been created.



prepareSTDIN
protected String prepareSTDIN(String name, Collection files) throws Exception(Code)
Prepares the stdin for the transfer job. Usually involves writing out a text file that Condor transfers to the remote end.
Parameters:
  name - the name of the transfer job.
Parameters:
  files - Collection of FileTransfer objects containingthe information about sourceam fin and destURL's. the path to the prepared stdin file.
throws:
  Exception - in case of error.



writeJumboStdIn
abstract protected void writeJumboStdIn(FileWriter stdIn, Collection files) throws Exception(Code)
Writes to a FileWriter stream the stdin which goes into the magic script via standard input
Parameters:
  stdIn - the writer to the stdin file.
Parameters:
  files - Collection of FileTransfer objects containingthe information about sourceam fin and destURL's.
throws:
  Exception -



Fields inherited from org.griphyn.cPlanner.transfer.implementation.Abstract
final public static String CHANGE_XBIT_TRANSFORMATION(Code)(Java Doc)
final public static String NOOP_PREFIX(Code)(Java Doc)
final public static String SET_XBIT_PREFIX(Code)(Java Doc)
final public static String XBIT_DERIVATION_NS(Code)(Java Doc)
final public static String XBIT_DERIVATION_VERSION(Code)(Java Doc)
final public static String XBIT_TRANSFORMATION_NS(Code)(Java Doc)
final public static String XBIT_TRANSFORMATION_VERSION(Code)(Java Doc)
protected Set mDisabledChmodSites(Code)(Java Doc)
protected String mLocalUserProxy(Code)(Java Doc)
protected String mLocalUserProxyBasename(Code)(Java Doc)
protected LogManager mLogger(Code)(Java Doc)
protected PlannerOptions mPOptions(Code)(Java Doc)
protected PegasusProperties mProps(Code)(Java Doc)
protected Refiner mRefiner(Code)(Java Doc)
protected PoolInfoProvider mSCHandle(Code)(Java Doc)
protected TransformationCatalog mTCHandle(Code)(Java Doc)

Methods inherited from org.griphyn.cPlanner.transfer.implementation.Abstract
protected boolean addSetXBitJobs(SubInfo computeJob, SubInfo txJob, Collection execFiles)(Code)(Java Doc)
public boolean addSetXBitJobs(SubInfo computeJob, String txJobName, Collection execFiles, int transferClass)(Code)(Java Doc)
public boolean addSetXBitJobs(SubInfo computeJob, String txJobName, Collection execFiles, int transferClass, int xbitIndex)(Code)(Java Doc)
public void applyPriority(TransferJob job)(Code)(Java Doc)
public boolean checkAndTransferProxy(TransferJob job)(Code)(Java Doc)
protected void construct(SubInfo job, String key, String value)(Code)(Java Doc)
public SubInfo createNoOPJob(String name)(Code)(Java Doc)
protected SubInfo createSetXBitJob(FileTransfer file, String name)(Code)(Java Doc)
protected Set determineDisabledChmodSites(String sites)(Code)(Java Doc)
protected boolean disableChmodJobCreation(String site)(Code)(Java Doc)
public String getNOOPJobName(String name, int counter)(Code)(Java Doc)
protected String getPathToUserProxy()(Code)(Java Doc)
protected String getPriority(TransferJob job)(Code)(Java Doc)
public String getSetXBitJobName(String name, int counter)(Code)(Java Doc)
public void setRefiner(Refiner refiner)(Code)(Java Doc)

Methods inherited from java.lang.Object
native protected Object clone() throws CloneNotSupportedException(Code)(Java Doc)
public boolean equals(Object obj)(Code)(Java Doc)
protected void finalize() throws Throwable(Code)(Java Doc)
final native public Class getClass()(Code)(Java Doc)
native public int hashCode()(Code)(Java Doc)
final native public void notify()(Code)(Java Doc)
final native public void notifyAll()(Code)(Java Doc)
public String toString()(Code)(Java Doc)
final native public void wait(long timeout) throws InterruptedException(Code)(Java Doc)
final public void wait(long timeout, int nanos) throws InterruptedException(Code)(Java Doc)
final public void wait() throws InterruptedException(Code)(Java Doc)

www.java2java.com | Contact Us
Copyright 2009 - 12 Demo Source and Support. All rights reserved.
All other trademarks are property of their respective owners.