Java KettleEnvironment类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.pentaho.di.core.KettleEnvironment类的典型用法代码示例。如果您正苦于以下问题：Java KettleEnvironment类的具体用法？Java KettleEnvironment怎么用？Java KettleEnvironment使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

KettleEnvironment类属于org.pentaho.di.core包，在下文中一共展示了KettleEnvironment类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: initEnv

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
/**
* 初始化环境变量 <br/>
* @author jingma
* @throws KettleException 
*/
public static void initEnv() throws KettleException {
    if(System.getenv("KETTLE_HOME")!=null){
        System.setProperty("DI_HOME", System.getenv("KETTLE_HOME"));
        System.setProperty("KETTLE_HOME", System.getenv("KETTLE_HOME"));
        System.setProperty("org.osjava.sj.root", System.getenv("KETTLE_HOME")+"/simple-jndi");
        log.debug("KETTLE_HOME配置[能自动加载该目录下plugins中的插件]："+System.getenv("KETTLE_HOME"));
    }
    if(System.getenv("KETTLE_JNDI_ROOT")!=null){
        System.setProperty("org.osjava.sj.root", System.getenv("KETTLE_JNDI_ROOT"));
        log.debug("Simple-jndi配置根路径："+System.getenv("KETTLE_JNDI_ROOT"));
    }
    //初始化kettle环境
    if(!KettleEnvironment.isInitialized()){
        KettleEnvironment.init();
        KettleClientEnvironment.getInstance().setClient( KettleClientEnvironment.ClientType.SPOON );
    }
}

开发者ID:majinju，项目名称:KettleUtil，代码行数:23，代码来源:KettleUtils.java

示例2: init

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
@Override
    public void init(AppView app) throws BeanFactoryException {
        this.app = app;        
//        dlSystem = (DataLogicSystem) app.getBean(DataLogicSystem.class.getName());
//        hostProp = dlSystem.getResourceAsProperties(app.getProperties() + "/properties");

        this.app.waitCursorBegin();
        try {
            KettleEnvironment.init(false);
            EnvUtil.environmentInit();
        } catch (KettleException ex) {
            MessageInf msg = new MessageInf(MessageInf.SGN_WARNING, AppLocal.getIntString("message.syncerror"), ex);
            msg.show(this);
        }
        this.app.waitCursorEnd();
    }

开发者ID:nordpos，项目名称:nordpos，代码行数:17，代码来源:JPanelTransformation.java

示例3: main

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
public static void main(String[] args) throws Exception {

    Display display = new Display();
    
    KettleEnvironment.init();
    PropsUI.init(display, PropsUI.TYPE_PROPERTIES_SPOON);
    
    Shell shell = new Shell(display);
    
    ImportRules importRules = new ImportRules();
    importRules.loadXML(XMLHandler.getSubNode(XMLHandler.loadXMLFile("bin/import-rules.xml"), ImportRules.XML_TAG));
    
    ImportRulesDialog dialog = new ImportRulesDialog(shell, importRules);
    if (dialog.open()) {
      for (ImportRuleInterface rule : importRules.getRules()) {
        System.out.println(" - "+rule.toString());
      }
    }
  }

开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:20，代码来源:ImportRulesDialog.java

示例4: test02_SelectFrom

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
public void test02_SelectFrom() throws Exception {
  KettleEnvironment.init();
  
  String sqlQuery = "SELECT Category, Country, products_sold as nr, sales_amount as sales FROM Service";
  
  SqlTransExecutor executor = new SqlTransExecutor(sqlQuery, getServices());

  final List<RowMetaAndData> rows = new ArrayList<RowMetaAndData>();
  
  // print the eventual result rows...
  //
  executor.executeQuery(new RowAdapter() { @Override
  public void rowWrittenEvent(RowMetaInterface rowMeta, Object[] row) throws KettleStepException {
    rows.add(new RowMetaAndData(rowMeta, row));
  } });
      
  // Now the generated transformation is waiting for input so we
  // can start the service transformation
  //
  executor.waitUntilFinished();
  
  assertEquals(8, rows.size());
}

开发者ID:jjeb，项目名称:kettle-trunk，代码行数:24，代码来源:SqlTransMetaTest.java

示例5: testCSVInput1

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
/**
 * Test case for Get XML Data step, very simple example.
 *
 * @throws Exception
 *           Upon any exception
 */
@Test
public void testCSVInput1() throws Exception {
  KettleEnvironment.init();

  //
  // Create a new transformation...
  //
  TransMeta transMeta = new TransMeta();
  transMeta.setName( "csvinput1" );

  PluginRegistry registry = PluginRegistry.getInstance();

  String fileName = writeInputFile();

  StepMeta injectorStep = createInjectorStep( transMeta, registry );
  StepMeta csvInputStep = createCsvInputStep( transMeta, registry, "\'", true );

  createAndTestTrans(
    registry, transMeta, injectorStep, csvInputStep, fileName, createTextFileInputFields().length );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:27，代码来源:CsvInput1NoTrailingSpaceIT.java

示例6: runTransWhenMappingsIsFollowedByCopiedStep

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
/**
 * This method runs transformations related to PDI-13545.<br/> The scenario is the following: there are two step
 * generating data, the latter of which is a Mapping step. They are followed with a Join Rows step, that has two
 * copies. The last in a row is a Dummy step, named "Last". Since both generating steps output 3 rows ([10, 20, 30]
 * and [1, 2, 3] respectively), the last step must obtain 3*3=9 rows.
 *
 * @param transPath a path to transformation file
 * @throws Exception
 */
private void runTransWhenMappingsIsFollowedByCopiedStep( String transPath ) throws Exception {
  KettleEnvironment.init();

  TransMeta transMeta = new TransMeta( transPath );
  transMeta.setTransformationType( TransMeta.TransformationType.Normal );

  Trans trans = new Trans( transMeta );
  trans.prepareExecution( null );
  trans.startThreads();
  trans.waitUntilFinished();

  assertEquals( 0, trans.getErrors() );

  List<StepInterface> list = trans.findBaseSteps( "Last" );
  assertEquals( 1, list.size() );
  assertEquals( 9, list.get( 0 ).getLinesRead() );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:27，代码来源:MappingIT.java

示例7: setUpLoadSave

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
@Before
public void setUpLoadSave() throws Exception {
  KettleEnvironment.init();
  PluginRegistry.init( true );
  List<String> attributes =
      Arrays.asList( "gPGLocation", "passphrase", "passphraseFieldName", "passphraseFieldName", "streamField", "resultFieldName" );

  Map<String, String> getterMap = new HashMap<String, String>();
  Map<String, String> setterMap = new HashMap<String, String>();

  Map<String, FieldLoadSaveValidator<?>> attrValidatorMap = new HashMap<String, FieldLoadSaveValidator<?>>();
  Map<String, FieldLoadSaveValidator<?>> typeValidatorMap = new HashMap<String, FieldLoadSaveValidator<?>>();

  loadSaveTester =
      new LoadSaveTester( testMetaClass, attributes, getterMap, setterMap, attrValidatorMap, typeValidatorMap );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:17，代码来源:PGPDecryptStreamMetaTest.java

示例8: setUp

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
  KettleEnvironment.init();

  virtualFolder = "ram://file-repo/" + UUID.randomUUID();
  KettleVFS.getFileObject( virtualFolder ).createFolder();

  KettleFileRepositoryMeta repositoryMeta =
    new KettleFileRepositoryMeta( "KettleFileRepository", "FileRep", "File repository", virtualFolder );
  repository = new KettleFileRepository();
  repository.init( repositoryMeta );

  // Test connecting... (no security needed)
  //
  repository.connect( null, null );
  assertTrue( repository.isConnected() );

  // Test loading the directory tree
  //
  tree = repository.loadRepositoryDirectoryTree();
  assertNotNull( tree );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:23，代码来源:KettleFileRepositoryTestBase.java

示例9: setUpLoadSave

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
@Before
public void setUpLoadSave() throws Exception {
  KettleEnvironment.init();
  PluginRegistry.init( true );
  List<String> attributes =
      Arrays.asList( "filename", "headerPresent", "lineWidth", "bufferSize", "lazyConversionActive", "lineFeedPresent",
          "runningInParallel", "fileType", "addResultFile", "encoding", "fieldDefinition" );

  Map<String, String> getterMap = new HashMap<String, String>();
  Map<String, String> setterMap = new HashMap<String, String>();
  Map<String, FieldLoadSaveValidator<?>> attrValidatorMap = new HashMap<String, FieldLoadSaveValidator<?>>();
  attrValidatorMap.put( "fieldDefinition",
      new ArrayLoadSaveValidator<FixedFileInputField>( new FixedFileInputFieldLoadSaveValidator(), 5 ) );
  attrValidatorMap.put( "fileType", new IntLoadSaveValidator( FixedInputMeta.fileTypeDesc.length ) );

  Map<String, FieldLoadSaveValidator<?>> typeValidatorMap = new HashMap<String, FieldLoadSaveValidator<?>>();

  loadSaveTester =
      new LoadSaveTester( testMetaClass, attributes, new ArrayList<String>(), new ArrayList<String>(),
          getterMap, setterMap, attrValidatorMap, typeValidatorMap, this );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:22，代码来源:FixedInputMetaTest.java

示例10: setUpLoadSave

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
@Before
public void setUpLoadSave() throws Exception {
  KettleEnvironment.init();
  PluginRegistry.init( true );
  List<String> attributes =
      Arrays.asList( "inputSorted", "memoryPreservationActive", "usingSortedList", "usingIntegerPair", "keystream",
          "keylookup", "value", "valueName", "valueDefault", "valueDefaultType" );

  FieldLoadSaveValidator<String[]> stringArrayLoadSaveValidator =
      new ArrayLoadSaveValidator<String>( new StringLoadSaveValidator(), 5 );

  Map<String, FieldLoadSaveValidator<?>> attrValidatorMap = new HashMap<String, FieldLoadSaveValidator<?>>();
  attrValidatorMap.put( "keystream", stringArrayLoadSaveValidator );
  attrValidatorMap.put( "keylookup", stringArrayLoadSaveValidator );
  attrValidatorMap.put( "value", stringArrayLoadSaveValidator );
  attrValidatorMap.put( "valueName", stringArrayLoadSaveValidator );
  attrValidatorMap.put( "valueDefault", stringArrayLoadSaveValidator );
  attrValidatorMap.put( "valueDefaultType", new PrimitiveIntArrayLoadSaveValidator( new IntLoadSaveValidator( 7 ), 5 ) );

  Map<String, FieldLoadSaveValidator<?>> typeValidatorMap = new HashMap<String, FieldLoadSaveValidator<?>>();

  loadSaveTester =
      new LoadSaveTester( testMetaClass, attributes, new ArrayList<String>(), new ArrayList<String>(),
          new HashMap<String, String>(), new HashMap<String, String>(), attrValidatorMap, typeValidatorMap, this );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:26，代码来源:StreamLookupMetaTest.java

示例11: setUpLoadSave

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
@Before
public void setUpLoadSave() throws Exception {
  KettleEnvironment.init();
  PluginRegistry.init( true );
  List<String> attributes =
      Arrays.asList( "fieldname", "type", "length", "precision" );

  Map<String, String> getterMap = new HashMap<String, String>();
  Map<String, String> setterMap = new HashMap<String, String>();

  Map<String, FieldLoadSaveValidator<?>> attrValidatorMap = new HashMap<String, FieldLoadSaveValidator<?>>();
  attrValidatorMap.put( "fieldname",
      new ArrayLoadSaveValidator<String>( new StringLoadSaveValidator(), 5 ) );
  attrValidatorMap.put( "type",
      new PrimitiveIntArrayLoadSaveValidator( new IntLoadSaveValidator( 7 ), 5 ) );
  attrValidatorMap.put( "length",
      new PrimitiveIntArrayLoadSaveValidator( new IntLoadSaveValidator( 100 ), 5 ) );
  attrValidatorMap.put( "precision",
      new PrimitiveIntArrayLoadSaveValidator( new IntLoadSaveValidator( 9 ), 5 ) );

  Map<String, FieldLoadSaveValidator<?>> typeValidatorMap = new HashMap<String, FieldLoadSaveValidator<?>>();

  loadSaveTester =
      new LoadSaveTester( testMetaClass, attributes, new ArrayList<String>(), new ArrayList<String>(),
          getterMap, setterMap, attrValidatorMap, typeValidatorMap, this );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:27，代码来源:InjectorMetaTest.java

示例12: setUpLoadSave

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
@Before
public void setUpLoadSave() throws Exception {
  KettleEnvironment.init();
  PluginRegistry.init( true );
  List<String> attributes =
    Arrays.asList( "filename", "fileCreated", "tablename", "tableCreated", "tableTruncated", "commitSize", "addToResultFiles", "DoNotOpenNewFileInit" );

  Map<String, String> getterMap = new HashMap<String, String>();
  Map<String, String> setterMap = new HashMap<String, String>();

  Map<String, FieldLoadSaveValidator<?>> attrValidatorMap = new HashMap<String, FieldLoadSaveValidator<?>>();
  Map<String, FieldLoadSaveValidator<?>> typeValidatorMap = new HashMap<String, FieldLoadSaveValidator<?>>();

  loadSaveTester =
    new LoadSaveTester( testMetaClass, attributes, getterMap, setterMap, attrValidatorMap, typeValidatorMap );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:17，代码来源:AccessOutputMetaTest.java

示例13: testCSVInput1

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
/**
 * Test case for Get XML Data step, very simple example.
 *
 * @throws Exception
 *           Upon any exception
 */
@Test
public void testCSVInput1() throws Exception {
  KettleEnvironment.init();

  //
  // Create a new transformation...
  //
  TransMeta transMeta = new TransMeta();
  transMeta.setName( "csvinput1" );

  PluginRegistry registry = PluginRegistry.getInstance();

  String fileName = writeInputFile();

  StepMeta injectorStep = createInjectorStep( transMeta, registry );
  StepMeta csvInputStep = createCsvInputStep( transMeta, registry, "++", true );

  createAndTestTrans(
    registry, transMeta, injectorStep, csvInputStep, fileName, createTextFileInputFields().length );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:27，代码来源:CsvInput2TrailingSpacesTwoCharEnclosuresIT.java

示例14: testCSVInput1

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
/**
 * Test case for Get XML Data step, very simple example.
 *
 * @throws Exception
 *           Upon any exception
 */
@Test
public void testCSVInput1() throws Exception {
  KettleEnvironment.init();

  //
  // Create a new transformation...
  //
  TransMeta transMeta = new TransMeta();
  transMeta.setName( "csvinput1" );

  PluginRegistry registry = PluginRegistry.getInstance();

  String fileName = writeInputFile();

  StepMeta injectorStep = createInjectorStep( transMeta, registry );
  StepMeta csvInputStep = createCsvInputStep( transMeta, registry, "\"", false );

  createAndTestTrans(
    registry, transMeta, injectorStep, csvInputStep, fileName, createTextFileInputFields().length );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:27，代码来源:CsvInput3IT.java

示例15: setUpLoadSave

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
@Before
public void setUpLoadSave() throws Exception {
  KettleEnvironment.init();
  PluginRegistry.init( true );
  List<String> attributes =
      Arrays.asList( "databaseMeta", "sQL", "rowLimit", "executeEachInputRow", "variableReplacementActive", "lazyConversionActive" );

  Map<String, String> getterMap = new HashMap<String, String>();
  Map<String, String> setterMap = new HashMap<String, String>();

  Map<String, FieldLoadSaveValidator<?>> attrValidatorMap = new HashMap<String, FieldLoadSaveValidator<?>>();

  Map<String, FieldLoadSaveValidator<?>> typeValidatorMap = new HashMap<String, FieldLoadSaveValidator<?>>();

  loadSaveTester =
      new LoadSaveTester( testMetaClass, attributes, getterMap, setterMap, attrValidatorMap, typeValidatorMap );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:18，代码来源:TableInputMetaTest.java

示例16: testTransformationDependencyList

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
public void testTransformationDependencyList() throws Exception {
  KettleEnvironment.init();
      
  TransMeta transMeta = new TransMeta("test/org/pentaho/di/resource/trans/General - Change log processing.ktr"); //$NON-NLS-1$
  List<ResourceReference> resourceReferences = transMeta.getResourceDependencies();
  // printResourceReferences(resourceReferences);    
  assertEquals(2, resourceReferences.size());
  ResourceReference genRef = null;
  for (ResourceReference look : resourceReferences) {
  	if (look.getReferenceHolder().getTypeId().equals("TextFileInput")) {
  		genRef = look;
  	}
  }
  assertNotNull(genRef);
  // System.out.println(genRef.toXml());
  
  ResourceHolderInterface refHolder = genRef.getReferenceHolder();
  assertEquals("TextFileInput", refHolder.getTypeId()); //$NON-NLS-1$
  
  List<ResourceEntry> entries = genRef.getEntries();
  assertEquals(1, entries.size());
  ResourceEntry theEntry = entries.get(0);
  assertEquals(ResourceType.FILE, theEntry.getResourcetype());
  assertTrue(theEntry.getResource().endsWith("changelog.txt")); //$NON-NLS-1$
  
}

开发者ID:jjeb，项目名称:kettle-trunk，代码行数:27，代码来源:ResourceDependencyTest.java

示例17: testLoadSaveRoundTrip

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
@Before
public void testLoadSaveRoundTrip() throws Exception {
  KettleEnvironment.init();
  PluginRegistry.init( true );
  List<String> attributes =
      Arrays.asList( "url", "urlInField", "urlField", "encoding", "httpLogin", "httpPassword", "proxyHost",
          "proxyPort", "socketTimeout", "connectionTimeout", "closeIdleConnectionsTime", "argumentField",
          "argumentParameter", "headerField", "headerParameter", "fieldName", "resultCodeFieldName",
          "responseTimeFieldName", "responseHeaderFieldName" );
  Map<String, FieldLoadSaveValidator<?>> fieldLoadSaveValidatorAttributeMap =
      new HashMap<String, FieldLoadSaveValidator<?>>();

  //Arrays need to be consistent length
  FieldLoadSaveValidator<String[]> stringArrayLoadSaveValidator =
      new ArrayLoadSaveValidator<String>( new StringLoadSaveValidator(), 25 );
  fieldLoadSaveValidatorAttributeMap.put( "argumentField", stringArrayLoadSaveValidator );
  fieldLoadSaveValidatorAttributeMap.put( "argumentParameter", stringArrayLoadSaveValidator );
  fieldLoadSaveValidatorAttributeMap.put( "headerField", stringArrayLoadSaveValidator );
  fieldLoadSaveValidatorAttributeMap.put( "headerParameter", stringArrayLoadSaveValidator );

  loadSaveTester =
      new LoadSaveTester( HTTPMeta.class, attributes, new HashMap<String, String>(),
          new HashMap<String, String>(), fieldLoadSaveValidatorAttributeMap,
          new HashMap<String, FieldLoadSaveValidator<?>>() );

}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:27，代码来源:HTTPMetaLoadSaveTest.java

示例18: createDatabase

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
@BeforeClass
public static void createDatabase() throws Exception {
  KettleEnvironment.init();

  //
  // Create a new transformation...
  //
  TransMeta transMeta = new TransMeta();
  transMeta.setName( "transname" );

  // Add the database connections
  for ( int i = 0; i < databasesXML.length; i++ ) {
    DatabaseMeta databaseMeta = new DatabaseMeta( databasesXML[i] );
    transMeta.addDatabase( databaseMeta );
  }
  DatabaseMeta dbInfo = transMeta.findDatabase( "db" );

  // Execute our setup SQLs in the database.
  database = new Database( loggingObject, dbInfo );
  database.connect();
  createTables( database );
  createData( database );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:24，代码来源:DatabaseLookupIT.java

示例19: createDatabase

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
@BeforeClass
public static void createDatabase() throws Exception
{
	KettleEnvironment.init();

    //
    // Create a new transformation...
    //
    TransMeta transMeta = new TransMeta();
    transMeta.setName("transname");

    // Add the database connections
    for (int i=0;i<databasesXML.length;i++)
    {
        DatabaseMeta databaseMeta = new DatabaseMeta(databasesXML[i]);
        transMeta.addDatabase(databaseMeta);
    }
    DatabaseMeta dbInfo = transMeta.findDatabase("db");

    // Execute our setup SQLs in the database.
    database = new Database(loggingObject, dbInfo);
    database.connect();
    createTables(database);
    createData(database);
}

开发者ID:jjeb，项目名称:kettle-trunk，代码行数:26，代码来源:ExecSQLRowTest.java

示例20: initEnv

import org.pentaho.di.core.KettleEnvironment; //导入依赖的package包/类
/**
* 初始化环境变量 <br/>
* @author jingma
* @throws KettleException 
*/
public static void initEnv() throws KettleException {
    log.debug("KETTLE_HOME配置[能自动加载该目录下plugins中的插件]："+System.getProperty("KETTLE_HOME"));
    log.debug("Simple-jndi配置根路径："+System.getProperty("org.osjava.sj.root"));
    log.debug("日志最大行数："+System.getProperty("KETTLE_MAX_LOG_SIZE_IN_LINES"));
    log.debug("最大日志管道数："+System.getProperty("KETTLE_MAX_LOGGING_REGISTRY_SIZE"));
    //初始化kettle环境
    if(!KettleEnvironment.isInitialized()){
        KettleEnvironment.init();
        KettleClientEnvironment.getInstance().setClient( KettleClientEnvironment.ClientType.SPOON );
    }
}

开发者ID:majinju，项目名称:KettleEasyExpand，代码行数:17，代码来源:KettleUtils.java

注：本文中的org.pentaho.di.core.KettleEnvironment类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。