Java Doc for Condor.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
         org.griphyn.cPlanner.transfer.implementation.Condor

Condor
public class Condor extends AbstractMultipleFTPerXFERJob (Code)
A prototype implementation that leverages the Condor file transfer mechanism to do the transfer to the remote directory . Currently, this will only work for staging in data to a remote site from the submit host.

Additionally, this will only work with local replica selector that prefers file urls from the submit host for staging.

In order to use the transfer implementation implemented by this class,

 - property pegasus.transfer.stagein.impl must be set to
 value Condor.
 - property pegasus.selector.replica must be set to value
 Local
 

author:
   Karan Vahi
version:
   $Revision: 387 $


Field Summary
final public static  StringDERIVATION_NAME
     The name of the underlying derivation.
final public static  StringDERIVATION_NAMESPACE
     The derivation namespace for for the transfer job.
final public static  StringDERIVATION_VERSION
     The derivation version number for the transfer job.
final public static  StringDESCRIPTION
     A short description of the transfer implementation.
final public static  StringTRANSFORMATION_NAME
     The name of the underlying transformation that is queried for in the Transformation Catalog.
final public static  StringTRANSFORMATION_NAMESPACE
     The transformation namespace for the transfer job.
final public static  StringTRANSFORMATION_VERSION
     The version number for the transfer job.

Constructor Summary
public  Condor(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 condor file transfer job that handles multiple transfers. The job itself is a /bin/true job that currently only manages to transfer input files from the local host.
Parameters:
  job - the SubInfo object for the job, in relation to whichthe transfer node is being added.
public  booleandoesPreserveXBit()
     Returns a boolean indicating whether the transfer protocol being used by the implementation preserves the X Bit or not while staging.
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.
protected  StringgetCompleteTCName()
     Returns the complete name for the transformation.
protected  StringgetDerivationName()
     Returns the logical name of the derivation that this implementation refers to.
protected  StringgetDerivationNamespace()
     Returns the namespace of the derivation that this implementation refers to.
protected  StringgetDerivationVersion()
     Returns the version of the derivation that this implementation refers to.
public  StringgetDescription()
     Returns a textual description of the transfer implementation.
protected  ListgetEnvironmentVariables(String site)
     Returns the environment profiles that are required for the default entry to sensibly work.
public  TransformationCatalogEntrygetTransformationCatalogEntry(String siteHandle)
     Retrieves the transformation catalog entry for the executable that is being used to transfer the files in the implementation.
Parameters:
  siteHandle - the handle of the site where the transformation isto be searched.
public  booleanuseThirdPartyTransferAlways()
     Return a boolean indicating whether the transfers to be done always in a third party transfer mode.
protected  voidwriteJumboStdIn(FileWriter stdIn, Collection files)
    

Field Detail
DERIVATION_NAME
final public static String DERIVATION_NAME(Code)
The name of the underlying derivation.



DERIVATION_NAMESPACE
final public static String DERIVATION_NAMESPACE(Code)
The derivation namespace for for the transfer job.



DERIVATION_VERSION
final public static String DERIVATION_VERSION(Code)
The derivation version number for the transfer job.



DESCRIPTION
final public static String DESCRIPTION(Code)
A short description of the transfer implementation.



TRANSFORMATION_NAME
final public static String TRANSFORMATION_NAME(Code)
The name of the underlying transformation that is queried for in the Transformation Catalog.



TRANSFORMATION_NAMESPACE
final public static String TRANSFORMATION_NAMESPACE(Code)
The transformation namespace for the transfer job.



TRANSFORMATION_VERSION
final public static String TRANSFORMATION_VERSION(Code)
The version number for the transfer job.




Constructor Detail
Condor
public Condor(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 condor file transfer job that handles multiple transfers. The job itself is a /bin/true job that currently only manages to transfer input files from the local host.
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.



doesPreserveXBit
public boolean doesPreserveXBit()(Code)
Returns a boolean indicating whether the transfer protocol being used by the implementation preserves the X Bit or not while staging. false



generateArgumentString
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
protected String getCompleteTCName()(Code)
Returns the complete name for the transformation. the complete name.



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



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



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



getDescription
public String getDescription()(Code)
Returns a textual description of the transfer implementation. a short textual description



getEnvironmentVariables
protected List getEnvironmentVariables(String site)(Code)
Returns the environment profiles that are required for the default entry to sensibly work. There are no variables to be returned for this case.
Parameters:
  site - the site where the job is going to run. an empty list



getTransformationCatalogEntry
public TransformationCatalogEntry getTransformationCatalogEntry(String siteHandle)(Code)
Retrieves the transformation catalog entry for the executable that is being used to transfer the files in the implementation.
Parameters:
  siteHandle - the handle of the site where the transformation isto be searched. the transformation catalog entry if found, else null.



useThirdPartyTransferAlways
public boolean useThirdPartyTransferAlways()(Code)
Return a boolean indicating whether the transfers to be done always in a third party transfer mode. Fix me. should say NEVER. boolean indicating whether to always use third partytransfers or not.



writeJumboStdIn
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 objectscontaining the information about sourceam fin and destURL's.
throws:
  Exception -



Methods inherited from org.griphyn.cPlanner.transfer.implementation.AbstractMultipleFTPerXFERJob
public TransferJob createTransferJob(SubInfo job, Collection files, Collection execFiles, String txJobName, int jobClass)(Code)(Java Doc)
protected TransformationCatalogEntry defaultTCEntry(String namespace, String name, String version, String site)(Code)(Java Doc)
abstract protected String generateArgumentString(TransferJob job)(Code)(Java Doc)
abstract protected String getCompleteTCName()(Code)(Java Doc)
abstract protected String getDerivationName()(Code)(Java Doc)
abstract protected String getDerivationNamespace()(Code)(Java Doc)
abstract protected String getDerivationVersion()(Code)(Java Doc)
abstract protected List getEnvironmentVariables(String site)(Code)(Java Doc)
public void postProcess(TransferJob job)(Code)(Java Doc)
protected String prepareSTDIN(String name, Collection files) throws Exception(Code)(Java Doc)
abstract protected void writeJumboStdIn(FileWriter stdIn, Collection files) throws Exception(Code)(Java Doc)

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.