Class SlaveServerConfig


  • public class SlaveServerConfig
    extends Object
    • Constructor Detail

      • SlaveServerConfig

        public SlaveServerConfig()
      • SlaveServerConfig

        public SlaveServerConfig​(SlaveServer slaveServer)
      • SlaveServerConfig

        public SlaveServerConfig​(List<SlaveServer> masters,
                                 boolean reportingToMasters,
                                 SlaveServer slaveServer)
      • SlaveServerConfig

        public SlaveServerConfig​(org.pentaho.di.core.logging.LogChannelInterface log,
                                 Node node)
                          throws org.pentaho.di.core.exception.KettleXMLException
        Throws:
        org.pentaho.di.core.exception.KettleXMLException
      • SlaveServerConfig

        public SlaveServerConfig​(String hostname,
                                 int port,
                                 boolean joining)
    • Method Detail

      • getXML

        public String getXML()
      • setUpJettyOptions

        protected void setUpJettyOptions​(Node node)
        Set up jetty options to the system properties
        Parameters:
        node -
      • parseJettyOptions

        protected Map<String,​String> parseJettyOptions​(Node node)
        Read and parse jetty options
        Parameters:
        node - that contains jetty options nodes
        Returns:
        map of not empty jetty options
      • readAutoSequences

        public void readAutoSequences()
                               throws org.pentaho.di.core.exception.KettleException
        Throws:
        org.pentaho.di.core.exception.KettleException
      • getMasters

        public List<SlaveServer> getMasters()
        Returns:
        the list of masters to report back to if the report to masters flag is enabled.
      • setMasters

        public void setMasters​(List<SlaveServer> masters)
        Parameters:
        masters - the list of masters to set. It is the list of masters to report back to if the report to masters flag is enabled.
      • getSlaveServer

        public SlaveServer getSlaveServer()
        Returns:
        the slave server.
        The user name and password defined in here are used to contact this slave by the masters.
      • setSlaveServer

        public void setSlaveServer​(SlaveServer slaveServer)
        Parameters:
        slaveServer - the slave server details to set.
        The user name and password defined in here are used to contact this slave by the masters.
      • isReportingToMasters

        public boolean isReportingToMasters()
        Returns:
        true if this slave reports to the masters
      • setReportingToMasters

        public void setReportingToMasters​(boolean reportingToMaster)
        Parameters:
        reportingToMaster - set to true if this slave should report to the masters
      • isJoining

        public boolean isJoining()
        Returns:
        true if the webserver needs to join with the webserver threads (wait/block until finished)
      • setJoining

        public void setJoining​(boolean joining)
        Parameters:
        joining - Set to true if the webserver needs to join with the webserver threads (wait/block until finished)
      • getMaxLogLines

        public int getMaxLogLines()
        Returns:
        the maxLogLines
      • setMaxLogLines

        public void setMaxLogLines​(int maxLogLines)
        Parameters:
        maxLogLines - the maxLogLines to set
      • getMaxLogTimeoutMinutes

        public int getMaxLogTimeoutMinutes()
        Returns:
        the maxLogTimeoutMinutes
      • setMaxLogTimeoutMinutes

        public void setMaxLogTimeoutMinutes​(int maxLogTimeoutMinutes)
        Parameters:
        maxLogTimeoutMinutes - the maxLogTimeoutMinutes to set
      • getObjectTimeoutMinutes

        public int getObjectTimeoutMinutes()
        Returns:
        the objectTimeoutMinutes
      • setObjectTimeoutMinutes

        public void setObjectTimeoutMinutes​(int objectTimeoutMinutes)
        Parameters:
        objectTimeoutMinutes - the objectTimeoutMinutes to set
      • getFilename

        public String getFilename()
        Returns:
        the filename
      • setFilename

        public void setFilename​(String filename)
        Parameters:
        filename - the filename to set
      • getDatabases

        public List<org.pentaho.di.core.database.DatabaseMeta> getDatabases()
        Returns:
        the databases
      • setDatabases

        public void setDatabases​(List<org.pentaho.di.core.database.DatabaseMeta> databases)
        Parameters:
        databases - the databases to set
      • getSlaveSequences

        public List<SlaveSequence> getSlaveSequences()
        Returns:
        the slaveSequences
      • setSlaveSequences

        public void setSlaveSequences​(List<SlaveSequence> slaveSequences)
        Parameters:
        slaveSequences - the slaveSequences to set
      • getAutoSequence

        public SlaveSequence getAutoSequence()
        Returns:
        the autoSequence
      • setAutoSequence

        public void setAutoSequence​(SlaveSequence autoSequence)
        Parameters:
        autoSequence - the autoSequence to set
      • isAutomaticCreationAllowed

        public boolean isAutomaticCreationAllowed()
        Returns:
        the automaticCreationAllowed
      • setAutomaticCreationAllowed

        public void setAutomaticCreationAllowed​(boolean automaticCreationAllowed)
        Parameters:
        automaticCreationAllowed - the automaticCreationAllowed to set
      • getRepository

        public Repository getRepository()
                                 throws org.pentaho.di.core.exception.KettleException
        Returns:
        the repository, loaded lazily
        Throws:
        org.pentaho.di.core.exception.KettleException
      • setRepository

        public void setRepository​(Repository repository)
        Parameters:
        repository - the repository to set
      • getRepositoryUsername

        public String getRepositoryUsername()
        Returns:
        the repositoryUsername
      • setRepositoryUsername

        public void setRepositoryUsername​(String repositoryUsername)
        Parameters:
        repositoryUsername - the repositoryUsername to set
      • getRepositoryPassword

        public String getRepositoryPassword()
        Returns:
        the repositoryPassword
      • setRepositoryPassword

        public void setRepositoryPassword​(String repositoryPassword)
        Parameters:
        repositoryPassword - the repositoryPassword to set
      • getMetaStore

        public org.pentaho.metastore.stores.delegate.DelegatingMetaStore getMetaStore()
      • setMetaStore

        public void setMetaStore​(org.pentaho.metastore.stores.delegate.DelegatingMetaStore metaStore)
      • getPasswordFile

        public String getPasswordFile()
      • setPasswordFile

        public void setPasswordFile​(String passwordFile)
      • getRepositoryId

        public String getRepositoryId()
      • setRepositoryId

        public void setRepositoryId​(String repositoryId)