本文整理汇总了Java中org.pentaho.di.shared.SharedObjectInterface类的典型用法代码示例。如果您正苦于以下问题:Java SharedObjectInterface类的具体用法?Java SharedObjectInterface怎么用?Java SharedObjectInterface使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SharedObjectInterface类属于org.pentaho.di.shared包,在下文中一共展示了SharedObjectInterface类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases) throws KettleXMLException
{
try
{
String csize;
String con = XMLHandler.getTagValue(stepnode, "connection"); //$NON-NLS-1$
databaseMeta = DatabaseMeta.findDatabase(databases, con);
csize = XMLHandler.getTagValue(stepnode, "commit"); //$NON-NLS-1$
commitSize=Const.toInt(csize, 0);
sqlField = XMLHandler.getTagValue(stepnode, "sql_field"); //$NON-NLS-1$
insertField = XMLHandler.getTagValue(stepnode, "insert_field"); //$NON-NLS-1$
updateField = XMLHandler.getTagValue(stepnode, "update_field"); //$NON-NLS-1$
deleteField = XMLHandler.getTagValue(stepnode, "delete_field"); //$NON-NLS-1$
readField = XMLHandler.getTagValue(stepnode, "read_field"); //$NON-NLS-1$
}
catch(Exception e)
{
throw new KettleXMLException(Messages.getString("ExecSQLRowMeta.Exception.UnableToLoadStepInfoFromXML"), e); //$NON-NLS-1$
}
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:22,代码来源:ExecSQLRowMeta.java
示例2: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases) throws KettleXMLException
{
try
{
Node fields = XMLHandler.getSubNode(stepnode, "fields"); //$NON-NLS-1$
int count= XMLHandler.countNodes(fields, "field"); //$NON-NLS-1$
allocate(count);
for (int i=0;i<count;i++)
{
Node fnode = XMLHandler.getSubNodeByNr(fields, "field", i); //$NON-NLS-1$
fieldName[i] = XMLHandler.getTagValue(fnode, "name"); //$NON-NLS-1$
replaceByFieldValue[i] = XMLHandler.getTagValue(fnode, "replaceby"); //$NON-NLS-1$
}
}
catch(Exception e)
{
throw new KettleXMLException(Messages.getString("SetValueFieldMeta.Exception.UnableToReadStepInfoFromXML"), e); //$NON-NLS-1$
}
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:23,代码来源:SetValueFieldMeta.java
示例3: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
String con = XMLHandler.getTagValue(stepnode, "connection"); //$NON-NLS-1$
database = DatabaseMeta.findDatabase(databases, con);
tablename = XMLHandler.getTagValue(stepnode, "tablename");
schemaname = XMLHandler.getTagValue(stepnode, "schemaname");
istablenameInfield = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "istablenameInfield"));
tablenamefield = XMLHandler.getTagValue(stepnode, "tablenamefield"); //$NON-NLS-1$
columnnamefield = XMLHandler.getTagValue(stepnode, "columnnamefield"); //$NON-NLS-1$
resultfieldname = XMLHandler.getTagValue(stepnode, "resultfieldname"); // Optional, can be null //$NON-NLS-1$
}
catch (Exception e)
{
throw new KettleXMLException(Messages.getString("ColumnExistsMeta.Exception.UnableToReadStepInfo"), e); //$NON-NLS-1$
}
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:20,代码来源:ColumnExistsMeta.java
示例4: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
filenamefield = XMLHandler.getTagValue(stepnode, "filenamefield"); //$NON-NLS-1$
resultfieldname = XMLHandler.getTagValue(stepnode, "resultfieldname");
includefiletype = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "includefiletype"));
filetypefieldname = XMLHandler.getTagValue(stepnode, "filetypefieldname");
addresultfilenames = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "addresultfilenames"));
}
catch (Exception e)
{
throw new KettleXMLException(Messages.getString("FileExistsMeta.Exception.UnableToReadStepInfo"), e); //$NON-NLS-1$
}
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:17,代码来源:FileExistsMeta.java
示例5: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases) throws KettleXMLException
{
try
{
usevar = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "usevar"));
Node fields = XMLHandler.getSubNode(stepnode, "fields");
int nrfields = XMLHandler.countNodes(fields, "field");
allocate(nrfields);
for (int i = 0; i < nrfields; i++)
{
Node fnode = XMLHandler.getSubNodeByNr(fields, "field", i);
fieldName[i] = XMLHandler.getTagValue(fnode, "name");
replaceValue[i] = XMLHandler.getTagValue(fnode, "value");
replaceMask[i] = XMLHandler.getTagValue(fnode, "mask");
}
}
catch (Exception e)
{
throw new KettleXMLException("It was not possible to load the metadata for this step from XML", e);
}
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:23,代码来源:SetValueConstantMeta.java
示例6: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
sourcefilenamefield = XMLHandler.getTagValue(stepnode, "sourcefilenamefield");
targetfilenamefield = XMLHandler.getTagValue(stepnode, "targetfilenamefield");
operationType = getOperationTypeByCode(Const.NVL(XMLHandler.getTagValue(stepnode, "operation_type"), ""));
addresultfilenames = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "addresultfilenames"));
overwritetargetfile = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "overwritetargetfile"));
createparentfolder = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "createparentfolder"));
simulate = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "simulate"));
}
catch (Exception e)
{
throw new KettleXMLException(Messages.getString("ProcessFilesMeta.Exception.UnableToReadStepInfo"), e); //$NON-NLS-1$
}
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:20,代码来源:ProcessFilesMeta.java
示例7: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
databaseMeta = DatabaseMeta.findDatabase(databases, XMLHandler.getTagValue(stepnode, "connection"));
sql = XMLHandler.getTagValue(stepnode, "sql");
rowLimit = Const.toInt(XMLHandler.getTagValue(stepnode, "limit"), 0);
lookupFromStepname = XMLHandler.getTagValue(stepnode, "lookup");
executeEachInputRow = "Y".equals(XMLHandler.getTagValue(stepnode, "execute_each_row"));
variableReplacementActive = "Y".equals(XMLHandler.getTagValue(stepnode, "variables_active"));
lazyConversionActive = "Y".equals(XMLHandler.getTagValue(stepnode, "lazy_conversion_active"));
}
catch(Exception e)
{
throw new KettleXMLException("Unable to load step info from XML", e);
}
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:19,代码来源:TableInputMeta.java
示例8: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
String con = XMLHandler.getTagValue(stepnode, "connection"); //$NON-NLS-1$
database = DatabaseMeta.findDatabase(databases, con);
tablenamefield = XMLHandler.getTagValue(stepnode, "tablenamefield"); //$NON-NLS-1$
resultfieldname = XMLHandler.getTagValue(stepnode, "resultfieldname");
schemaname = XMLHandler.getTagValue(stepnode, "schemaname");
}
catch (Exception e)
{
throw new KettleXMLException(Messages.getString("TableExistsMeta.Exception.UnableToReadStepInfo"), e); //$NON-NLS-1$
}
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:18,代码来源:TableExistsMeta.java
示例9: readSharedObjects
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
public SharedObjects readSharedObjects() throws KettleException {
// Extract the shared steps, connections, etc. using the SharedObjects
// class
//
String soFile = environmentSubstitute(sharedObjectsFile);
SharedObjects sharedObjects = new SharedObjects(soFile);
Map<?, SharedObjectInterface> objectsMap = sharedObjects.getObjectsMap();
// First read the databases...
// We read databases & slaves first because there might be dependencies
// that need to be resolved.
//
for (SharedObjectInterface object : objectsMap.values()) {
if (object instanceof DatabaseMeta) {
DatabaseMeta databaseMeta = (DatabaseMeta) object;
databaseMeta.shareVariablesWith(this);
addOrReplaceDatabase(databaseMeta);
} else if (object instanceof SlaveServer) {
SlaveServer slaveServer = (SlaveServer) object;
slaveServer.shareVariablesWith(this);
addOrReplaceSlaveServer(slaveServer);
}
}
return sharedObjects;
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:27,代码来源:JobMeta.java
示例10: saveSharedObjects
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
public void saveSharedObjects() throws KettleException {
try {
// First load all the shared objects...
String soFile = environmentSubstitute(sharedObjectsFile);
SharedObjects sharedObjects = new SharedObjects(soFile);
// Now overwrite the objects in there
List<Object> shared = new ArrayList<Object>();
shared.addAll(databases);
shared.addAll(slaveServers);
// The databases connections...
for (int i = 0; i < shared.size(); i++) {
SharedObjectInterface sharedObject = (SharedObjectInterface) shared.get(i);
if (sharedObject.isShared()) {
sharedObjects.storeObject(sharedObject);
}
}
// Save the objects
sharedObjects.saveToFile();
} catch (Exception e) {
throw new KettleException("Unable to save shared ojects", e);
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:26,代码来源:JobMeta.java
示例11: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases) throws KettleXMLException
{
try
{
String csize;
String con = XMLHandler.getTagValue(stepnode, "connection"); //$NON-NLS-1$
databaseMeta = DatabaseMeta.findDatabase(databases, con);
csize = XMLHandler.getTagValue(stepnode, "commit"); //$NON-NLS-1$
commitSize=Const.toInt(csize, 0);
sqlField = XMLHandler.getTagValue(stepnode, "sql_field"); //$NON-NLS-1$
insertField = XMLHandler.getTagValue(stepnode, "insert_field"); //$NON-NLS-1$
updateField = XMLHandler.getTagValue(stepnode, "update_field"); //$NON-NLS-1$
deleteField = XMLHandler.getTagValue(stepnode, "delete_field"); //$NON-NLS-1$
readField = XMLHandler.getTagValue(stepnode, "read_field"); //$NON-NLS-1$
}
catch(Exception e)
{
throw new KettleXMLException(BaseMessages.getString(PKG, "ExecSQLRowMeta.Exception.UnableToLoadStepInfoFromXML"), e); //$NON-NLS-1$
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:22,代码来源:ExecSQLRowMeta.java
示例12: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
Node steps = XMLHandler.getSubNode(stepnode, "steps");
int nrsteps = XMLHandler.countNodes(steps, "step");
allocate(nrsteps);
for (int i = 0; i < nrsteps; i++)
{
Node fnode = XMLHandler.getSubNodeByNr(steps, "step", i);
stepName[i] = XMLHandler.getTagValue(fnode, "name");
}
}
catch (Exception e)
{
throw new KettleXMLException("Unable to load step info from XML", e);
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:22,代码来源:PrioritizeStreamsMeta.java
示例13: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
filenamefield = XMLHandler.getTagValue(stepnode, "filenamefield"); //$NON-NLS-1$
targetfilenamefield = XMLHandler.getTagValue(stepnode, "targetfilenamefield");
sourceencoding = XMLHandler.getTagValue(stepnode, "sourceencoding");
targetencoding = XMLHandler.getTagValue(stepnode, "targetencoding");
addsourceresultfilenames = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "addsourceresultfilenames"));
addtargetresultfilenames = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "addtargetresultfilenames"));
createparentfolder = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "createparentfolder"));
}
catch (Exception e)
{
throw new KettleXMLException(BaseMessages.getString(PKG, "ChangeFileEncodingMeta.Exception.UnableToReadStepInfo"), e); //$NON-NLS-1$
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:20,代码来源:ChangeFileEncodingMeta.java
示例14: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases) throws KettleXMLException
{
try
{
Node fields = XMLHandler.getSubNode(stepnode, "fields"); //$NON-NLS-1$
int count= XMLHandler.countNodes(fields, "field"); //$NON-NLS-1$
allocate(count);
for (int i=0;i<count;i++)
{
Node fnode = XMLHandler.getSubNodeByNr(fields, "field", i); //$NON-NLS-1$
fieldName[i] = XMLHandler.getTagValue(fnode, "name"); //$NON-NLS-1$
replaceByFieldValue[i] = XMLHandler.getTagValue(fnode, "replaceby"); //$NON-NLS-1$
}
}
catch(Exception e)
{
throw new KettleXMLException(BaseMessages.getString(PKG, "SetValueFieldMeta.Exception.UnableToReadStepInfoFromXML"), e); //$NON-NLS-1$
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:23,代码来源:SetValueFieldMeta.java
示例15: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
String con = XMLHandler.getTagValue(stepnode, "connection"); //$NON-NLS-1$
database = DatabaseMeta.findDatabase(databases, con);
tablename = XMLHandler.getTagValue(stepnode, "tablename");
schemaname = XMLHandler.getTagValue(stepnode, "schemaname");
istablenameInfield = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "istablenameInfield"));
tablenamefield = XMLHandler.getTagValue(stepnode, "tablenamefield"); //$NON-NLS-1$
columnnamefield = XMLHandler.getTagValue(stepnode, "columnnamefield"); //$NON-NLS-1$
resultfieldname = XMLHandler.getTagValue(stepnode, "resultfieldname"); // Optional, can be null //$NON-NLS-1$
}
catch (Exception e)
{
throw new KettleXMLException(BaseMessages.getString(PKG, "ColumnExistsMeta.Exception.UnableToReadStepInfo"), e); //$NON-NLS-1$
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:20,代码来源:ColumnExistsMeta.java
示例16: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
messagefieldname = XMLHandler.getTagValue(stepnode, "messagefieldname");
port = XMLHandler.getTagValue(stepnode, "port");
serverName = XMLHandler.getTagValue(stepnode, "servername");
facility = XMLHandler.getTagValue(stepnode, "facility");
priority = XMLHandler.getTagValue(stepnode, "priority");
datePattern = XMLHandler.getTagValue(stepnode, "datePattern");
addTimestamp = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "addTimestamp"));
addHostName = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "addHostName"));
}
catch (Exception e)
{
throw new KettleXMLException(BaseMessages.getString(PKG, "SyslogMessageMeta.Exception.UnableToReadStepInfo"), e); //$NON-NLS-1$
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:22,代码来源:SyslogMessageMeta.java
示例17: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
filenamefield = XMLHandler.getTagValue(stepnode, "filenamefield"); //$NON-NLS-1$
resultfieldname = XMLHandler.getTagValue(stepnode, "resultfieldname");
includefiletype = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "includefiletype"));
filetypefieldname = XMLHandler.getTagValue(stepnode, "filetypefieldname");
addresultfilenames = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "addresultfilenames"));
}
catch (Exception e)
{
throw new KettleXMLException(BaseMessages.getString(PKG, "FileExistsMeta.Exception.UnableToReadStepInfo"), e); //$NON-NLS-1$
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:17,代码来源:FileExistsMeta.java
示例18: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
sourcefilenamefield = XMLHandler.getTagValue(stepnode, "sourcefilenamefield");
targetfilenamefield = XMLHandler.getTagValue(stepnode, "targetfilenamefield");
operationType = getOperationTypeByCode(Const.NVL(XMLHandler.getTagValue(stepnode, "operation_type"), ""));
addresultfilenames = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "addresultfilenames"));
overwritetargetfile = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "overwritetargetfile"));
createparentfolder = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "createparentfolder"));
simulate = "Y".equalsIgnoreCase(XMLHandler.getTagValue(stepnode, "simulate"));
}
catch (Exception e)
{
throw new KettleXMLException(BaseMessages.getString(PKG, "ProcessFilesMeta.Exception.UnableToReadStepInfo"), e); //$NON-NLS-1$
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:20,代码来源:ProcessFilesMeta.java
示例19: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
olap4jUrl = XMLHandler.getTagValue(stepnode, "url");
username = XMLHandler.getTagValue(stepnode, "username");
password = XMLHandler.getTagValue(stepnode, "password");
catalog = XMLHandler.getTagValue(stepnode, "catalog");
mdx = XMLHandler.getTagValue(stepnode, "mdx");
variableReplacementActive = "Y".equals(XMLHandler.getTagValue(stepnode, "variables_active"));
}
catch(Exception e)
{
throw new KettleXMLException("Unable to load step info from XML", e);
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:19,代码来源:OlapInputMeta.java
示例20: readData
import org.pentaho.di.shared.SharedObjectInterface; //导入依赖的package包/类
private void readData(Node stepnode, List<? extends SharedObjectInterface> databases)
throws KettleXMLException
{
try
{
databaseMeta = DatabaseMeta.findDatabase(databases, XMLHandler.getTagValue(stepnode, "connection"));
sql = XMLHandler.getTagValue(stepnode, "sql");
rowLimit = XMLHandler.getTagValue(stepnode, "limit");
String lookupFromStepname = XMLHandler.getTagValue(stepnode, "lookup"); //$NON-NLS-1$
StreamInterface infoStream = getStepIOMeta().getInfoStreams().get(0);
infoStream.setSubject(lookupFromStepname);
executeEachInputRow = "Y".equals(XMLHandler.getTagValue(stepnode, "execute_each_row"));
variableReplacementActive = "Y".equals(XMLHandler.getTagValue(stepnode, "variables_active"));
lazyConversionActive = "Y".equals(XMLHandler.getTagValue(stepnode, "lazy_conversion_active"));
}
catch(Exception e)
{
throw new KettleXMLException("Unable to load step info from XML", e);
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:23,代码来源:TableInputMeta.java
注:本文中的org.pentaho.di.shared.SharedObjectInterface类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论