JobEntryHadoopJobExecutor extends JobEntryBase implements Cloneable, JobEntryInterface { @VisibleForTesting URL resolveJarUrl( final String jarUrl ) throws MalformedURLException { return resolveJarUrl( jarUrl, this ); } JobEntryHadoopJobExecutor( NamedClusterService namedClusterService,
                                    RuntimeTestActionService runtimeTestActionService, RuntimeTester runtimeTester,
                                    NamedClusterServiceLocator namedClusterServiceLocator ); NamedClusterService getNamedClusterService(); RuntimeTestActionService getRuntimeTestActionService(); RuntimeTester getRuntimeTester(); NamedClusterServiceLocator getNamedClusterServiceLocator(); String getHadoopJobName(); void setHadoopJobName( String hadoopJobName ); String getJarUrl(); void setJarUrl( String jarUrl ); String getDriverClass(); void setDriverClass( String driverClass ); boolean isSimple(); void setSimple( boolean isSimple ); String getCmdLineArgs(); void setCmdLineArgs( String cmdLineArgs ); String getOutputKeyClass(); void setOutputKeyClass( String outputKeyClass ); String getOutputValueClass(); void setOutputValueClass( String outputValueClass ); String getMapperClass(); void setMapperClass( String mapperClass ); String getCombinerClass(); void setCombinerClass( String combinerClass ); String getReducerClass(); void setReducerClass( String reducerClass ); String getInputFormatClass(); void setInputFormatClass( String inputFormatClass ); String getOutputFormatClass(); void setOutputFormatClass( String outputFormatClass ); NamedCluster getNamedCluster(); void setNamedCluster( NamedCluster namedCluster ); String getInputPath(); void setInputPath( String inputPath ); String getOutputPath(); void setOutputPath( String outputPath ); boolean isBlocking(); void setBlocking( boolean blocking ); String getLoggingInterval(); void setLoggingInterval( String loggingInterval ); List<UserDefinedItem> getUserDefined(); void setUserDefined( List<UserDefinedItem> userDefined ); String getNumMapTasks(); void setNumMapTasks( String numMapTasks ); String getNumReduceTasks(); void setNumReduceTasks( String numReduceTasks ); Result execute( final Result result, int arg1 ); static URL resolveJarUrl( final String jarUrl, VariableSpace variableSpace ); void printJobStatus( MapReduceJobAdvanced runningJob ); @Override void loadXML( Node entrynode, List<DatabaseMeta> databases, List<SlaveServer> slaveServers, Repository rep,
                       IMetaStore metaStore ); @Override String getXML(); @Override void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
                       List<SlaveServer> slaveServers ); @Override void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ); boolean evaluates(); boolean isUnconditional(); String getSimpleLoggingInterval(); void setSimpleLoggingInterval( String simpleLoggingInterval ); boolean isSimpleBlocking(); void setSimpleBlocking( boolean simpleBlocking ); @Override String getDialogClassName(); static final String CLUSTER_NAME; static final String HDFS_HOSTNAME; static final String HDFS_PORT; static final String JOB_TRACKER_HOSTNAME; static final String JOB_TRACKER_PORT; static final String DIALOG_NAME; }
@Test public void testResolveJobUrl() throws MalformedURLException { String variableValue = "http: String testvar = "testvar"; jobExecutor.setVariable( testvar, variableValue ); assertEquals( new URL( variableValue ), jobExecutor.resolveJarUrl( "${" + testvar + "}" ) ); }