@Test public void getAdvancedArgumentsList() { AbstractModelList<ArgumentWrapper> args = config.getAdvancedArgumentsList(); assertEquals( 60, args.size() ); PropertyChangeListener l = mock( PropertyChangeListener.class ); config.addPropertyChangeListener( l ); String value = String.valueOf( System.currentTimeMillis() ); for ( ArgumentWrapper arg : args ) { arg.setValue( value ); assertEquals( value, arg.getValue() ); } verify( l, times( 60 ) ).propertyChange( (PropertyChangeEvent) any() ); }
public AbstractModelList<ArgumentWrapper> getAdvancedArgumentsList() { final AbstractModelList<ArgumentWrapper> items = new AbstractModelList<ArgumentWrapper>(); items.addAll( SqoopUtils.findAllArguments( this ) ); try { items.add( new ArgumentWrapper( NAMENODE_HOST, BaseMessages.getString( getClass(), "NamenodeHost.Label" ), false, "", 0, this, getClass().getMethod( "getNamenodeHost" ), getClass().getMethod( "setNamenodeHost", String.class ) ) ); items.add( new ArgumentWrapper( NAMENODE_PORT, BaseMessages.getString( getClass(), "NamenodePort.Label" ), false, "", 0, this, getClass().getMethod( "getNamenodePort" ), getClass().getMethod( "setNamenodePort", String.class ) ) ); items.add( new ArgumentWrapper( SHIM_IDENTIFIER, BaseMessages.getString( getClass(), "ShimIdentifier.Label" ), false, "", 0, this, getClass().getMethod( "getShimIdentifier" ), getClass().getMethod( "setShimIdentifier", String.class ) ) ); items.add( new ArgumentWrapper( JOBTRACKER_HOST, BaseMessages.getString( getClass(), "JobtrackerHost.Label" ), false, "", 0, this, getClass().getMethod( "getJobtrackerHost" ), getClass().getMethod( "setJobtrackerHost", String.class ) ) ); items.add( new ArgumentWrapper( JOBTRACKER_PORT, BaseMessages.getString( getClass(), "JobtrackerPort.Label" ), false, "", 0, this, getClass().getMethod( "getJobtrackerPort" ), getClass().getMethod( "setJobtrackerPort", String.class ) ) ); items.add( new ArgumentWrapper( BLOCKING_EXECUTION, BaseMessages .getString( getClass(), "BlockingExecution.Label" ), false, "", 0, this, getClass().getMethod( "getBlockingExecution" ), getClass().getMethod( "setBlockingExecution", String.class ) ) ); items.add( new ArgumentWrapper( BLOCKING_POLLING_INTERVAL, BaseMessages.getString( getClass(), "BlockingPollingInterval.Label" ), false, "", 0, this, getClass().getMethod( "getBlockingPollingInterval" ), getClass().getMethod( "setBlockingPollingInterval", String.class ) ) ); } catch ( NoSuchMethodException ex ) { throw new RuntimeException( ex ); } return items; }
SqoopConfig extends BlockableJobConfig implements XulEventSource, Cloneable { public AbstractModelList<ArgumentWrapper> getAdvancedArgumentsList() { final AbstractModelList<ArgumentWrapper> items = new AbstractModelList<ArgumentWrapper>(); items.addAll( SqoopUtils.findAllArguments( this ) ); try { items.add( new ArgumentWrapper( NAMENODE_HOST, BaseMessages.getString( getClass(), "NamenodeHost.Label" ), false, "", 0, this, getClass().getMethod( "getNamenodeHost" ), getClass().getMethod( "setNamenodeHost", String.class ) ) ); items.add( new ArgumentWrapper( NAMENODE_PORT, BaseMessages.getString( getClass(), "NamenodePort.Label" ), false, "", 0, this, getClass().getMethod( "getNamenodePort" ), getClass().getMethod( "setNamenodePort", String.class ) ) ); items.add( new ArgumentWrapper( SHIM_IDENTIFIER, BaseMessages.getString( getClass(), "ShimIdentifier.Label" ), false, "", 0, this, getClass().getMethod( "getShimIdentifier" ), getClass().getMethod( "setShimIdentifier", String.class ) ) ); items.add( new ArgumentWrapper( JOBTRACKER_HOST, BaseMessages.getString( getClass(), "JobtrackerHost.Label" ), false, "", 0, this, getClass().getMethod( "getJobtrackerHost" ), getClass().getMethod( "setJobtrackerHost", String.class ) ) ); items.add( new ArgumentWrapper( JOBTRACKER_PORT, BaseMessages.getString( getClass(), "JobtrackerPort.Label" ), false, "", 0, this, getClass().getMethod( "getJobtrackerPort" ), getClass().getMethod( "setJobtrackerPort", String.class ) ) ); items.add( new ArgumentWrapper( BLOCKING_EXECUTION, BaseMessages .getString( getClass(), "BlockingExecution.Label" ), false, "", 0, this, getClass().getMethod( "getBlockingExecution" ), getClass().getMethod( "setBlockingExecution", String.class ) ) ); items.add( new ArgumentWrapper( BLOCKING_POLLING_INTERVAL, BaseMessages.getString( getClass(), "BlockingPollingInterval.Label" ), false, "", 0, this, getClass().getMethod( "getBlockingPollingInterval" ), getClass().getMethod( "setBlockingPollingInterval", String.class ) ) ); } catch ( NoSuchMethodException ex ) { throw new RuntimeException( ex ); } return items; } }
SqoopConfig extends BlockableJobConfig implements XulEventSource, Cloneable { public AbstractModelList<ArgumentWrapper> getAdvancedArgumentsList() { final AbstractModelList<ArgumentWrapper> items = new AbstractModelList<ArgumentWrapper>(); items.addAll( SqoopUtils.findAllArguments( this ) ); try { items.add( new ArgumentWrapper( NAMENODE_HOST, BaseMessages.getString( getClass(), "NamenodeHost.Label" ), false, "", 0, this, getClass().getMethod( "getNamenodeHost" ), getClass().getMethod( "setNamenodeHost", String.class ) ) ); items.add( new ArgumentWrapper( NAMENODE_PORT, BaseMessages.getString( getClass(), "NamenodePort.Label" ), false, "", 0, this, getClass().getMethod( "getNamenodePort" ), getClass().getMethod( "setNamenodePort", String.class ) ) ); items.add( new ArgumentWrapper( SHIM_IDENTIFIER, BaseMessages.getString( getClass(), "ShimIdentifier.Label" ), false, "", 0, this, getClass().getMethod( "getShimIdentifier" ), getClass().getMethod( "setShimIdentifier", String.class ) ) ); items.add( new ArgumentWrapper( JOBTRACKER_HOST, BaseMessages.getString( getClass(), "JobtrackerHost.Label" ), false, "", 0, this, getClass().getMethod( "getJobtrackerHost" ), getClass().getMethod( "setJobtrackerHost", String.class ) ) ); items.add( new ArgumentWrapper( JOBTRACKER_PORT, BaseMessages.getString( getClass(), "JobtrackerPort.Label" ), false, "", 0, this, getClass().getMethod( "getJobtrackerPort" ), getClass().getMethod( "setJobtrackerPort", String.class ) ) ); items.add( new ArgumentWrapper( BLOCKING_EXECUTION, BaseMessages .getString( getClass(), "BlockingExecution.Label" ), false, "", 0, this, getClass().getMethod( "getBlockingExecution" ), getClass().getMethod( "setBlockingExecution", String.class ) ) ); items.add( new ArgumentWrapper( BLOCKING_POLLING_INTERVAL, BaseMessages.getString( getClass(), "BlockingPollingInterval.Label" ), false, "", 0, this, getClass().getMethod( "getBlockingPollingInterval" ), getClass().getMethod( "setBlockingPollingInterval", String.class ) ) ); } catch ( NoSuchMethodException ex ) { throw new RuntimeException( ex ); } return items; }  }
SqoopConfig extends BlockableJobConfig implements XulEventSource, Cloneable { public AbstractModelList<ArgumentWrapper> getAdvancedArgumentsList() { final AbstractModelList<ArgumentWrapper> items = new AbstractModelList<ArgumentWrapper>(); items.addAll( SqoopUtils.findAllArguments( this ) ); try { items.add( new ArgumentWrapper( NAMENODE_HOST, BaseMessages.getString( getClass(), "NamenodeHost.Label" ), false, "", 0, this, getClass().getMethod( "getNamenodeHost" ), getClass().getMethod( "setNamenodeHost", String.class ) ) ); items.add( new ArgumentWrapper( NAMENODE_PORT, BaseMessages.getString( getClass(), "NamenodePort.Label" ), false, "", 0, this, getClass().getMethod( "getNamenodePort" ), getClass().getMethod( "setNamenodePort", String.class ) ) ); items.add( new ArgumentWrapper( SHIM_IDENTIFIER, BaseMessages.getString( getClass(), "ShimIdentifier.Label" ), false, "", 0, this, getClass().getMethod( "getShimIdentifier" ), getClass().getMethod( "setShimIdentifier", String.class ) ) ); items.add( new ArgumentWrapper( JOBTRACKER_HOST, BaseMessages.getString( getClass(), "JobtrackerHost.Label" ), false, "", 0, this, getClass().getMethod( "getJobtrackerHost" ), getClass().getMethod( "setJobtrackerHost", String.class ) ) ); items.add( new ArgumentWrapper( JOBTRACKER_PORT, BaseMessages.getString( getClass(), "JobtrackerPort.Label" ), false, "", 0, this, getClass().getMethod( "getJobtrackerPort" ), getClass().getMethod( "setJobtrackerPort", String.class ) ) ); items.add( new ArgumentWrapper( BLOCKING_EXECUTION, BaseMessages .getString( getClass(), "BlockingExecution.Label" ), false, "", 0, this, getClass().getMethod( "getBlockingExecution" ), getClass().getMethod( "setBlockingExecution", String.class ) ) ); items.add( new ArgumentWrapper( BLOCKING_POLLING_INTERVAL, BaseMessages.getString( getClass(), "BlockingPollingInterval.Label" ), false, "", 0, this, getClass().getMethod( "getBlockingPollingInterval" ), getClass().getMethod( "setBlockingPollingInterval", String.class ) ) ); } catch ( NoSuchMethodException ex ) { throw new RuntimeException( ex ); } return items; }  AbstractModelList<ArgumentWrapper> getAdvancedArgumentsList(); NamedCluster getNamedCluster(); void setNamedCluster( NamedCluster namedCluster ); @Override SqoopConfig clone(); void setConnectionInfo( String database, String connect, String username, String password ); void copyConnectionInfoFromAdvanced(); void copyConnectionInfoToAdvanced(); String getDatabase(); void setDatabase( String database ); String getSchema(); void setSchema( String schema ); String getConnect(); void setConnect( String connect ); String getUsername(); void setUsername( String username ); String getPassword(); void setPassword( String password ); String getConnectFromAdvanced(); void setConnectFromAdvanced( String connectFromAdvanced ); String getUsernameFromAdvanced(); void setUsernameFromAdvanced( String usernameFromAdvanced ); String getPasswordFromAdvanced(); void setPasswordFromAdvanced( String passwordFromAdvanced ); String getConnectionManager(); void setConnectionManager( String connectionManager ); String getDriver(); void setDriver( String driver ); String getVerbose(); void setVerbose( String verbose ); String getConnectionParamFile(); void setConnectionParamFile( String connectionParamFile ); String getHadoopHome(); void setHadoopHome( String hadoopHome ); String getEnclosedBy(); void setEnclosedBy( String enclosedBy ); String getEscapedBy(); void setEscapedBy( String escapedBy ); String getFieldsTerminatedBy(); void setFieldsTerminatedBy( String fieldsTerminatedBy ); String getLinesTerminatedBy(); void setLinesTerminatedBy( String linesTerminatedBy ); String getOptionallyEnclosedBy(); void setOptionallyEnclosedBy( String optionallyEnclosedBy ); String getMysqlDelimiters(); void setMysqlDelimiters( String mysqlDelimiters ); String getInputEnclosedBy(); void setInputEnclosedBy( String inputEnclosedBy ); String getInputEscapedBy(); void setInputEscapedBy( String inputEscapedBy ); String getInputFieldsTerminatedBy(); void setInputFieldsTerminatedBy( String inputFieldsTerminatedBy ); String getInputLinesTerminatedBy(); void setInputLinesTerminatedBy( String inputLinesTerminatedBy ); String getInputOptionallyEnclosedBy(); void setInputOptionallyEnclosedBy( String inputOptionallyEnclosedBy ); String getBinDir(); void setBinDir( String binDir ); String getClassName(); void setClassName( String className ); String getJarFile(); void setJarFile( String jarFile ); String getOutdir(); void setOutdir( String outdir ); String getPackageName(); void setPackageName( String packageName ); String getMapColumnJava(); void setMapColumnJava( String mapColumnJava ); String getTable(); void setTable( String table ); String getNumMappers(); void setNumMappers( String numMappers ); String getCommandLine(); void setCommandLine( String commandLine ); String getMode(); JobEntryMode getModeAsEnum(); void setMode( JobEntryMode mode ); void setMode( String mode ); String getClusterName(); void setClusterName( String clusterName ); String getNamenodeHost(); void setNamenodeHost( String namenodeHost ); String getShimIdentifier(); void setShimIdentifier( String shimIdentifier ); String getNamenodePort(); void setNamenodePort( String namenodePort ); String getJobtrackerHost(); void setJobtrackerHost( String jobtrackerHost ); String getJobtrackerPort(); void setJobtrackerPort( String jobtrackerPort ); String getHadoopMapredHome(); void setHadoopMapredHome( String hadoopMapredHome ); String getPasswordAlias(); void setPasswordAlias( String passwordAlias ); String getPasswordFile(); void setPasswordFile( String passwordFile ); String getRelaxedIsolation(); void setRelaxedIsolation( String relaxedIsolation ); String getSkipDistCache(); void setSkipDistCache( String skipDistCache ); String getMapreduceJobName(); void setMapreduceJobName( String mapreduceJobName ); String getValidate(); void setValidate( String validate ); String getValidationFailureHandler(); void setValidationFailureHandler( String validationFailureHandler ); String getValidationThreshold(); void setValidationThreshold( String validationThreshold ); String getValidator(); void setValidator( String validator ); String getHcatalogDatabase(); void setHcatalogDatabase( String hcatalogDatabase ); String getHcatalogHome(); void setHcatalogHome( String hcatalogHome ); String getHcatalogPartitionKeys(); void setHcatalogPartitionKeys( String hcatalogPartitionKeys ); String getHcatalogPartitionValues(); void setHcatalogPartitionValues( String hcatalogPartitionValues ); String getHcatalogTable(); void setHcatalogTable( String hcatalogTable ); String getHiveHome(); void setHiveHome( String hiveHome ); String getHivePartitionKey(); void setHivePartitionKey( String hivePartitionKey ); String getHivePartitionValue(); void setHivePartitionValue( String hivePartitionValue ); String getMapColumnHive(); void setMapColumnHive( String mapColumnHive ); String getInputNullString(); void setInputNullString( String inputNullString ); String getInputNullNonString(); void setInputNullNonString( String inputNullNonString ); String getNullString(); void setNullString( String nullString ); String getNullNonString(); void setNullNonString( String nullNonString ); String getFiles(); void setFiles( String files ); String getLibjars(); void setLibjars( String libjars ); String getArchives(); void setArchives( String archives ); AbstractModelList<PropertyEntry> getCustomArguments(); void setCustomArguments( AbstractModelList<PropertyEntry> customArguments ); void loadClusterConfig( Repository rep, ObjectId id ); void loadClusterConfig( Node entrynode ); String getClusterXML(); void saveClusterConfig( Repository rep, ObjectId id_job, JobEntryInterface jobEntry ); boolean isAdvancedClusterConfigSet(); }
SqoopConfig extends BlockableJobConfig implements XulEventSource, Cloneable { public AbstractModelList<ArgumentWrapper> getAdvancedArgumentsList() { final AbstractModelList<ArgumentWrapper> items = new AbstractModelList<ArgumentWrapper>(); items.addAll( SqoopUtils.findAllArguments( this ) ); try { items.add( new ArgumentWrapper( NAMENODE_HOST, BaseMessages.getString( getClass(), "NamenodeHost.Label" ), false, "", 0, this, getClass().getMethod( "getNamenodeHost" ), getClass().getMethod( "setNamenodeHost", String.class ) ) ); items.add( new ArgumentWrapper( NAMENODE_PORT, BaseMessages.getString( getClass(), "NamenodePort.Label" ), false, "", 0, this, getClass().getMethod( "getNamenodePort" ), getClass().getMethod( "setNamenodePort", String.class ) ) ); items.add( new ArgumentWrapper( SHIM_IDENTIFIER, BaseMessages.getString( getClass(), "ShimIdentifier.Label" ), false, "", 0, this, getClass().getMethod( "getShimIdentifier" ), getClass().getMethod( "setShimIdentifier", String.class ) ) ); items.add( new ArgumentWrapper( JOBTRACKER_HOST, BaseMessages.getString( getClass(), "JobtrackerHost.Label" ), false, "", 0, this, getClass().getMethod( "getJobtrackerHost" ), getClass().getMethod( "setJobtrackerHost", String.class ) ) ); items.add( new ArgumentWrapper( JOBTRACKER_PORT, BaseMessages.getString( getClass(), "JobtrackerPort.Label" ), false, "", 0, this, getClass().getMethod( "getJobtrackerPort" ), getClass().getMethod( "setJobtrackerPort", String.class ) ) ); items.add( new ArgumentWrapper( BLOCKING_EXECUTION, BaseMessages .getString( getClass(), "BlockingExecution.Label" ), false, "", 0, this, getClass().getMethod( "getBlockingExecution" ), getClass().getMethod( "setBlockingExecution", String.class ) ) ); items.add( new ArgumentWrapper( BLOCKING_POLLING_INTERVAL, BaseMessages.getString( getClass(), "BlockingPollingInterval.Label" ), false, "", 0, this, getClass().getMethod( "getBlockingPollingInterval" ), getClass().getMethod( "setBlockingPollingInterval", String.class ) ) ); } catch ( NoSuchMethodException ex ) { throw new RuntimeException( ex ); } return items; }  AbstractModelList<ArgumentWrapper> getAdvancedArgumentsList(); NamedCluster getNamedCluster(); void setNamedCluster( NamedCluster namedCluster ); @Override SqoopConfig clone(); void setConnectionInfo( String database, String connect, String username, String password ); void copyConnectionInfoFromAdvanced(); void copyConnectionInfoToAdvanced(); String getDatabase(); void setDatabase( String database ); String getSchema(); void setSchema( String schema ); String getConnect(); void setConnect( String connect ); String getUsername(); void setUsername( String username ); String getPassword(); void setPassword( String password ); String getConnectFromAdvanced(); void setConnectFromAdvanced( String connectFromAdvanced ); String getUsernameFromAdvanced(); void setUsernameFromAdvanced( String usernameFromAdvanced ); String getPasswordFromAdvanced(); void setPasswordFromAdvanced( String passwordFromAdvanced ); String getConnectionManager(); void setConnectionManager( String connectionManager ); String getDriver(); void setDriver( String driver ); String getVerbose(); void setVerbose( String verbose ); String getConnectionParamFile(); void setConnectionParamFile( String connectionParamFile ); String getHadoopHome(); void setHadoopHome( String hadoopHome ); String getEnclosedBy(); void setEnclosedBy( String enclosedBy ); String getEscapedBy(); void setEscapedBy( String escapedBy ); String getFieldsTerminatedBy(); void setFieldsTerminatedBy( String fieldsTerminatedBy ); String getLinesTerminatedBy(); void setLinesTerminatedBy( String linesTerminatedBy ); String getOptionallyEnclosedBy(); void setOptionallyEnclosedBy( String optionallyEnclosedBy ); String getMysqlDelimiters(); void setMysqlDelimiters( String mysqlDelimiters ); String getInputEnclosedBy(); void setInputEnclosedBy( String inputEnclosedBy ); String getInputEscapedBy(); void setInputEscapedBy( String inputEscapedBy ); String getInputFieldsTerminatedBy(); void setInputFieldsTerminatedBy( String inputFieldsTerminatedBy ); String getInputLinesTerminatedBy(); void setInputLinesTerminatedBy( String inputLinesTerminatedBy ); String getInputOptionallyEnclosedBy(); void setInputOptionallyEnclosedBy( String inputOptionallyEnclosedBy ); String getBinDir(); void setBinDir( String binDir ); String getClassName(); void setClassName( String className ); String getJarFile(); void setJarFile( String jarFile ); String getOutdir(); void setOutdir( String outdir ); String getPackageName(); void setPackageName( String packageName ); String getMapColumnJava(); void setMapColumnJava( String mapColumnJava ); String getTable(); void setTable( String table ); String getNumMappers(); void setNumMappers( String numMappers ); String getCommandLine(); void setCommandLine( String commandLine ); String getMode(); JobEntryMode getModeAsEnum(); void setMode( JobEntryMode mode ); void setMode( String mode ); String getClusterName(); void setClusterName( String clusterName ); String getNamenodeHost(); void setNamenodeHost( String namenodeHost ); String getShimIdentifier(); void setShimIdentifier( String shimIdentifier ); String getNamenodePort(); void setNamenodePort( String namenodePort ); String getJobtrackerHost(); void setJobtrackerHost( String jobtrackerHost ); String getJobtrackerPort(); void setJobtrackerPort( String jobtrackerPort ); String getHadoopMapredHome(); void setHadoopMapredHome( String hadoopMapredHome ); String getPasswordAlias(); void setPasswordAlias( String passwordAlias ); String getPasswordFile(); void setPasswordFile( String passwordFile ); String getRelaxedIsolation(); void setRelaxedIsolation( String relaxedIsolation ); String getSkipDistCache(); void setSkipDistCache( String skipDistCache ); String getMapreduceJobName(); void setMapreduceJobName( String mapreduceJobName ); String getValidate(); void setValidate( String validate ); String getValidationFailureHandler(); void setValidationFailureHandler( String validationFailureHandler ); String getValidationThreshold(); void setValidationThreshold( String validationThreshold ); String getValidator(); void setValidator( String validator ); String getHcatalogDatabase(); void setHcatalogDatabase( String hcatalogDatabase ); String getHcatalogHome(); void setHcatalogHome( String hcatalogHome ); String getHcatalogPartitionKeys(); void setHcatalogPartitionKeys( String hcatalogPartitionKeys ); String getHcatalogPartitionValues(); void setHcatalogPartitionValues( String hcatalogPartitionValues ); String getHcatalogTable(); void setHcatalogTable( String hcatalogTable ); String getHiveHome(); void setHiveHome( String hiveHome ); String getHivePartitionKey(); void setHivePartitionKey( String hivePartitionKey ); String getHivePartitionValue(); void setHivePartitionValue( String hivePartitionValue ); String getMapColumnHive(); void setMapColumnHive( String mapColumnHive ); String getInputNullString(); void setInputNullString( String inputNullString ); String getInputNullNonString(); void setInputNullNonString( String inputNullNonString ); String getNullString(); void setNullString( String nullString ); String getNullNonString(); void setNullNonString( String nullNonString ); String getFiles(); void setFiles( String files ); String getLibjars(); void setLibjars( String libjars ); String getArchives(); void setArchives( String archives ); AbstractModelList<PropertyEntry> getCustomArguments(); void setCustomArguments( AbstractModelList<PropertyEntry> customArguments ); void loadClusterConfig( Repository rep, ObjectId id ); void loadClusterConfig( Node entrynode ); String getClusterXML(); void saveClusterConfig( Repository rep, ObjectId id_job, JobEntryInterface jobEntry ); boolean isAdvancedClusterConfigSet(); static final String NAMENODE_HOST; static final String NAMENODE_PORT; static final String SHIM_IDENTIFIER; static final String JOBTRACKER_HOST; static final String JOBTRACKER_PORT; static final String DATABASE; static final String SCHEMA; static final String CONNECT; static final String USERNAME; static final String PASSWORD; static final String VERBOSE; static final String CONNECTION_MANAGER; static final String DRIVER; static final String CONNECTION_PARAM_FILE; static final String HADOOP_HOME; static final String ENCLOSED_BY; static final String ESCAPED_BY; static final String FIELDS_TERMINATED_BY; static final String LINES_TERMINATED_BY; static final String OPTIONALLY_ENCLOSED_BY; static final String MYSQL_DELIMITERS; static final String INPUT_ENCLOSED_BY; static final String INPUT_ESCAPED_BY; static final String INPUT_FIELDS_TERMINATED_BY; static final String INPUT_LINES_TERMINATED_BY; static final String INPUT_OPTIONALLY_ENCLOSED_BY; static final String BIN_DIR; static final String CLASS_NAME; static final String JAR_FILE; static final String OUTDIR; static final String PACKAGE_NAME; static final String MAP_COLUMN_JAVA; static final String TABLE; static final String NUM_MAPPERS; static final String COMMAND_LINE; static final String MODE; static final String HADOOP_MAPRED_HOME; static final String PASSWORD_ALIAS; static final String PASSWORD_FILE; static final String RELAXED_ISOLATION; static final String SKIP_DIST_CACHE; static final String MAPREDUCE_JOB_NAME; static final String VALIDATE; static final String VALIDATION_FAILURE_HANDLER; static final String VALIDATION_THRESHOLD; static final String VALIDATOR; static final String HCATALOG_DATABASE; static final String HCATALOG_HOME; static final String HCATALOG_PARTITION_KEYS; static final String HCATALOG_PARTITION_VALUES; static final String HCATALOG_TABLE; static final String HIVE_HOME; static final String HIVE_PARTITION_KEY; static final String HIVE_PARTITION_VALUE; static final String MAP_COLUMN_HIVE; static final String INPUT_NULL_STRING; static final String INPUT_NULL_NON_STRING; static final String NULL_STRING; static final String NULL_NON_STRING; static final String FILES; static final String LIBJARS; static final String ARCHIVES; }