Package org.pentaho.di.core.osgi.api

Interface NamedClusterOsgi

All Superinterfaces:

VariableSpace

public interface NamedClusterOsgi
extends VariableSpace

Created by tkafalas on 7/6/2017.

Field Summary

Fields

Modifier and Type	Field	Description
static String	KNOX_GATEWAY_ROOT
static String	NAMED_CLUSTER_FS_OPTION
static String	NAMED_CLUSTER_XML_TAG
static String	NAMED_CLUSTERS_FS_OPTION

Method Summary

Modifier and Type	Method	Description
default void	addSiteFile(String fileName, String content)	Deprecated.
default void	addSiteFile(NamedClusterSiteFile namedClusterSiteFile)
String	decodePassword(String password)
String	encodePassword(String password)
String	getGatewayPassword()
String	getGatewayUrl()
String	getGatewayUsername()
String	getHdfsHost()
String	getHdfsPassword()
String	getHdfsPort()
String	getHdfsUsername()
String	getJobTrackerHost()
String	getJobTrackerPort()
String	getKafkaBootstrapServers()
long	getLastModifiedDate()
String	getName()
String	getOozieUrl()
String	getShimIdentifier()
default InputStream	getSiteFileInputStream(String siteFileName)
default List<NamedClusterSiteFile>	getSiteFiles()
String	getStorageScheme()
String	getZooKeeperHost()
String	getZooKeeperPort()
boolean	isMapr()
boolean	isUseGateway()
NamedClusterOsgi	nonOsgiFromXmlForEmbed(Node node)	This is the NamedClusterOsgi equivalent of the line commented above.
String	processURLsubstitution(String incomingURL, org.pentaho.metastore.api.IMetaStore metastore, VariableSpace variableSpace)	This method performs the root URL substitution with the URL of the specified NamedCluster
void	setGatewayPassword(String gatewayPassword)
void	setGatewayUrl(String gatewayUrl)
void	setGatewayUsername(String gatewayUsername)
void	setHdfsHost(String hdfsHost)
void	setHdfsPassword(String hdfsPassword)
void	setHdfsPort(String hdfsPort)
void	setHdfsUsername(String hdfsUsername)
void	setJobTrackerHost(String jobTrackerHost)
void	setJobTrackerPort(String jobTrackerPort)
void	setKafkaBootstrapServers(String kafkaBootstrapServers)
void	setLastModifiedDate(long lastModifiedDate)
void	setMapr(boolean mapr)
void	setName(String name)
void	setOozieUrl(String oozieUrl)
void	setShimIdentifier(String shimIdentifier)
default void	setSiteFiles(List<NamedClusterSiteFile> siteFiles)
void	setStorageScheme(String storageScheme)
void	setUseGateway(boolean selection)
void	setZooKeeperHost(String zooKeeperHost)
void	setZooKeeperPort(String zooKeeperPort)
String	toXmlForEmbed(String rootTag)

Methods inherited from interface org.pentaho.di.core.variables.VariableSpace

copyVariablesFrom, environmentSubstitute, environmentSubstitute, environmentSubstitute, fieldSubstitute, getBooleanValueOfVariable, getParentVariableSpace, getVariable, getVariable, initializeVariablesFrom, injectVariables, listVariables, setParentVariableSpace, setVariable, shareVariablesWith

Field Detail

NAMED_CLUSTERS_FS_OPTION

static final String NAMED_CLUSTERS_FS_OPTION

See Also:

Constant Field Values

NAMED_CLUSTER_FS_OPTION

static final String NAMED_CLUSTER_FS_OPTION

See Also:

Constant Field Values

NAMED_CLUSTER_XML_TAG

static final String NAMED_CLUSTER_XML_TAG

See Also:

Constant Field Values

KNOX_GATEWAY_ROOT

static final String KNOX_GATEWAY_ROOT

See Also:

Constant Field Values

Method Detail

getName

String getName()

setName

void setName(String name)

getShimIdentifier

String getShimIdentifier()

setShimIdentifier

void setShimIdentifier(String shimIdentifier)

getStorageScheme

String getStorageScheme()

setStorageScheme

void setStorageScheme(String storageScheme)

getHdfsHost

String getHdfsHost()

setHdfsHost

void setHdfsHost(String hdfsHost)

getHdfsPort

String getHdfsPort()

setHdfsPort

void setHdfsPort(String hdfsPort)

getHdfsUsername

String getHdfsUsername()

setHdfsUsername

void setHdfsUsername(String hdfsUsername)

getHdfsPassword

String getHdfsPassword()

setHdfsPassword

void setHdfsPassword(String hdfsPassword)

getJobTrackerHost

String getJobTrackerHost()

setJobTrackerHost

void setJobTrackerHost(String jobTrackerHost)

getJobTrackerPort

String getJobTrackerPort()

setJobTrackerPort

void setJobTrackerPort(String jobTrackerPort)

getZooKeeperHost

String getZooKeeperHost()

setZooKeeperHost

void setZooKeeperHost(String zooKeeperHost)

getZooKeeperPort

String getZooKeeperPort()

setZooKeeperPort

void setZooKeeperPort(String zooKeeperPort)

getOozieUrl

String getOozieUrl()

setOozieUrl

void setOozieUrl(String oozieUrl)

getLastModifiedDate

long getLastModifiedDate()

setLastModifiedDate

void setLastModifiedDate(long lastModifiedDate)

isMapr

boolean isMapr()

setMapr

void setMapr(boolean mapr)

getGatewayUrl

String getGatewayUrl()

setGatewayUrl

void setGatewayUrl(String gatewayUrl)

getGatewayUsername

String getGatewayUsername()

setGatewayUsername

void setGatewayUsername(String gatewayUsername)

getGatewayPassword

String getGatewayPassword()

setGatewayPassword

void setGatewayPassword(String gatewayPassword)

getKafkaBootstrapServers

String getKafkaBootstrapServers()

setKafkaBootstrapServers

void setKafkaBootstrapServers(String kafkaBootstrapServers)

toXmlForEmbed

String toXmlForEmbed(String rootTag)

nonOsgiFromXmlForEmbed

NamedClusterOsgi nonOsgiFromXmlForEmbed(Node node)

This is the NamedClusterOsgi equivalent of the line commented above. The NamedCluster interface is used in OSGI and should be phased out over time as this interface is adopted instead. We had to create a unique method name here for the time being since the signature is identical.

processURLsubstitution

String processURLsubstitution(String incomingURL,
                              org.pentaho.metastore.api.IMetaStore metastore,
                              VariableSpace variableSpace)

This method performs the root URL substitution with the URL of the specified NamedCluster

Parameters:

incomingURL - the URL whose root will be replaced

metastore - the metastore

variableSpace - the variable space

Returns:

the generated URL or the incoming URL if an error occurs

setUseGateway

void setUseGateway(boolean selection)

isUseGateway

boolean isUseGateway()

decodePassword

String decodePassword(String password)

encodePassword

String encodePassword(String password)

getSiteFiles

default List<NamedClusterSiteFile> getSiteFiles()

setSiteFiles

default void setSiteFiles(List<NamedClusterSiteFile> siteFiles)

addSiteFile

@Deprecated
default void addSiteFile(String fileName,
                         String content)

Deprecated.

addSiteFile

default void addSiteFile(NamedClusterSiteFile namedClusterSiteFile)

getSiteFileInputStream

default InputStream getSiteFileInputStream(String siteFileName)