• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java InfobrightNamedPipeLoader类代码示例

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

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



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

示例1: loadXML

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
@Override
public void loadXML(Node stepnode, List<DatabaseMeta> databases, Map<String, Counter> counters)
    throws KettleXMLException {
  super.loadXML(stepnode, databases, counters);
  try {
    dataFormat = Enum.valueOf(DataFormat.class, XMLHandler.getTagValue(stepnode, TAG_DATA_FORMAT));
    agentPort = Integer.parseInt(Const.NVL(XMLHandler.getTagValue(stepnode, TAG_AGENT_PORT),
        Integer.toString(InfobrightNamedPipeLoader.AGENT_DEFAULT_PORT)));
    String charsetName = XMLHandler.getTagValue(stepnode, TAG_CHARSET);
    charset = (charsetName == null ? InfobrightNamedPipeLoader.DEFAULT_CHARSET :
      Charset.forName(charsetName));
    debugFile = XMLHandler.getTagValue(stepnode, TAG_DEBUG_FILE);
  } catch(Exception e) {
    throw new KettleXMLException("Unable to load step info from XML", e);
  }
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:17,代码来源:InfobrightLoaderMeta.java


示例2: readRep

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
@Override
public void readRep(Repository rep, ObjectId id_step, List<DatabaseMeta> databases, Map<String, Counter> counters) throws KettleException {
  super.readRep(rep, id_step, databases, counters);
  try {
    dataFormat = Enum.valueOf(DataFormat.class, rep.getStepAttributeString(id_step, TAG_DATA_FORMAT));
    String agentPortStr = rep.getStepAttributeString(id_step, TAG_AGENT_PORT);
    if (agentPortStr == null) {
      agentPort = InfobrightNamedPipeLoader.AGENT_DEFAULT_PORT;
    } else {
      agentPort = Integer.parseInt(agentPortStr);
    }
    String charsetName = rep.getStepAttributeString(id_step, TAG_CHARSET);
    charset = (charsetName == null ? InfobrightNamedPipeLoader.DEFAULT_CHARSET :
      Charset.forName(charsetName));
    debugFile    = rep.getStepAttributeString(id_step, TAG_DEBUG_FILE);
  } catch (Exception e) {
    throw new KettleException("Unexpected error reading step information from the repository", e);
  }
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:20,代码来源:InfobrightLoaderMeta.java


示例3: ok

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
protected void ok() {
  try {
    stepname = wStepname.getText(); // return value
    meta.setDatabaseMeta( transMeta.findDatabase(serverConnection.getText()) );
    meta.setSchemaName(targetSchemaText.getText());
    meta.setTablename(targetTableText.getText());
    meta.setDataFormat(DataFormat.valueForDisplayName(dataFormatSelect.getText()));
    String charsetName = charsetSelect.getText();
    Charset charset2 = ("".equals(charsetName) ?
        InfobrightNamedPipeLoader.DEFAULT_CHARSET :
        Charset.forName(charsetName));
    meta.setCharset(charset2);
    String agentPortStr = agentPortText.getText().trim();
    if ("".equals(agentPortStr)) {
      meta.setAgentPort(InfobrightNamedPipeLoader.AGENT_DEFAULT_PORT);
    } else {
      meta.setAgentPort(Integer.parseInt(agentPortStr));
    }
    meta.setDebugFile(debugFileText.getText());
    dispose();
  } catch(Exception e) {
      new ErrorDialog(shell, BaseMessages.getString(PKG,
          "InfobrightLoaderDialog.Illegal.Dialog.Settings.Title"),
        BaseMessages.getString(PKG, "InfobrightLoaderDialog.Illegal.Dialog.Settings.Message"), e);
  }
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:27,代码来源:InfobrightLoaderDialog.java


示例4: ok

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
protected void ok() {
  try {
    stepname = wStepname.getText(); // return value
    meta.setDatabaseMeta( transMeta.findDatabase(serverConnection.getText()) );
    meta.setSchemaName(targetSchemaText.getText());
    meta.setTableName(targetTableText.getText());
    meta.setDataFormat(DataFormat.valueForDisplayName(dataFormatSelect.getText()));
    String charsetName = charsetSelect.getText();
    Charset charset2 = ("".equals(charsetName) ?
        InfobrightNamedPipeLoader.DEFAULT_CHARSET :
        Charset.forName(charsetName));
    meta.setCharset(charset2);
    String agentPortStr = agentPortText.getText().trim();
    if ("".equals(agentPortStr)) {
      meta.setAgentPort(InfobrightNamedPipeLoader.AGENT_DEFAULT_PORT);
    } else {
      meta.setAgentPort(Integer.parseInt(agentPortStr));
    }
    meta.setDebugFile(debugFileText.getText());
    dispose();
  } catch(Exception e) {
      new ErrorDialog(shell, BaseMessages.getString(PKG,
          "InfobrightLoaderDialog.Illegal.Dialog.Settings.Title"),
        BaseMessages.getString(PKG, "InfobrightLoaderDialog.Illegal.Dialog.Settings.Message"), e);
  }
}
 
开发者ID:bsspirit,项目名称:kettle-4.4.0-stable,代码行数:27,代码来源:InfobrightLoaderDialog.java


示例5: loadXML

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
@Override
public void loadXML( Node stepnode, List<DatabaseMeta> databases, IMetaStore metaStore ) throws KettleXMLException {
  super.loadXML( stepnode, databases, metaStore );
  try {
    dataFormat = Enum.valueOf( DataFormat.class, XMLHandler.getTagValue( stepnode, TAG_DATA_FORMAT ) );
    agentPort =
      Integer.parseInt( Const.NVL( XMLHandler.getTagValue( stepnode, TAG_AGENT_PORT ), Integer
        .toString( InfobrightNamedPipeLoader.AGENT_DEFAULT_PORT ) ) );
    String charsetName = XMLHandler.getTagValue( stepnode, TAG_CHARSET );
    charset =
      ( charsetName == null ? InfobrightNamedPipeLoader.DEFAULT_CHARSET : Charset.forName( charsetName ) );
    debugFile = XMLHandler.getTagValue( stepnode, TAG_DEBUG_FILE );
  } catch ( Exception e ) {
    throw new KettleXMLException( "Unable to load step info from XML", e );
  }
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:17,代码来源:InfobrightLoaderMeta.java


示例6: readRep

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
@Override
public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
  super.readRep( rep, metaStore, id_step, databases );
  try {
    dataFormat = Enum.valueOf( DataFormat.class, rep.getStepAttributeString( id_step, TAG_DATA_FORMAT ) );
    String agentPortStr = rep.getStepAttributeString( id_step, TAG_AGENT_PORT );
    if ( agentPortStr == null ) {
      agentPort = InfobrightNamedPipeLoader.AGENT_DEFAULT_PORT;
    } else {
      agentPort = Integer.parseInt( agentPortStr );
    }
    String charsetName = rep.getStepAttributeString( id_step, TAG_CHARSET );
    charset =
      ( charsetName == null ? InfobrightNamedPipeLoader.DEFAULT_CHARSET : Charset.forName( charsetName ) );
    debugFile = rep.getStepAttributeString( id_step, TAG_DEBUG_FILE );
  } catch ( Exception e ) {
    throw new KettleException( "Unexpected error reading step information from the repository", e );
  }
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:20,代码来源:InfobrightLoaderMeta.java


示例7: ok

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
protected void ok() {
  try {
    stepname = wStepname.getText(); // return value
    meta.setDatabaseMeta( transMeta.findDatabase( serverConnection.getText() ) );
    meta.setSchemaName( targetSchemaText.getText() );
    meta.setTableName( targetTableText.getText() );
    meta.setDataFormat( DataFormat.valueForDisplayName( dataFormatSelect.getText() ) );
    String charsetName = charsetSelect.getText();
    Charset charset2 =
      ( "".equals( charsetName ) ? InfobrightNamedPipeLoader.DEFAULT_CHARSET : Charset.forName( charsetName ) );
    meta.setCharset( charset2 );
    String agentPortStr = agentPortText.getText().trim();
    if ( "".equals( agentPortStr ) ) {
      meta.setAgentPort( InfobrightNamedPipeLoader.AGENT_DEFAULT_PORT );
    } else {
      meta.setAgentPort( Integer.parseInt( agentPortStr ) );
    }
    meta.setDebugFile( debugFileText.getText() );
    dispose();
  } catch ( Exception e ) {
    new ErrorDialog(
      shell, BaseMessages.getString( PKG, "InfobrightLoaderDialog.Illegal.Dialog.Settings.Title" ),
      BaseMessages.getString( PKG, "InfobrightLoaderDialog.Illegal.Dialog.Settings.Message" ), e );
  }
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:26,代码来源:InfobrightLoaderDialog.java


示例8: parsePort

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
/**
 * 
 * @param args
 * @return
 * @throws UsageException
 * @throws NumberFormatException
 */
private int parsePort(String[] args) throws UsageException {
  int port2 = InfobrightNamedPipeLoader.AGENT_DEFAULT_PORT;
  for (int i = 0; i < args.length; i++) {
    if (PORT_FLAG.equals(args[i])) {
      if (i < args.length - 1) {
        port2 = Integer.parseInt(args[i + 1]);
        break;
      } else {
        throw new UsageException();
      }
    }
  }
  return port2;
}
 
开发者ID:EidosMedia,项目名称:infobright-core,代码行数:22,代码来源:CLArgs.java


示例9: setDefault

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
@Override
public void setDefault() {
  this.dataFormat = DataFormat.TXT_VARIABLE; // default for ICE
  // this.dataFormat = DataFormat.BINARY; // default for IEE
  this.agentPort = InfobrightNamedPipeLoader.AGENT_DEFAULT_PORT;
  this.charset = InfobrightNamedPipeLoader.DEFAULT_CHARSET;
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:8,代码来源:InfobrightLoaderMeta.java


示例10: databaseSetup

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
void databaseSetup(InfobrightLoaderMeta meta, InfobrightLoader step) throws KettleException {
  
  db = new Database(meta.getDatabaseMeta());
  db.connect();

  // FIXME: This will fail if the first row of the table contains a value that
  // cannot be read by Java. For example, a DATE field that contains the value
  // '0000-00-00'. In this case, the Kettle error message will misleadingly say
  // that the table doesn't exist. There doesn't seem to be any workaround.
  // See Pentaho JIRA: PDI-2117.
  //
  requiredRowMeta = meta.getRequiredFields(step); 
  requiredFields = requiredRowMeta.getFieldNames();
  
  try {
    // once the loader is built, this db connection cannot be used by this thread anymore.
    // the loader is using it and any other uses of the connection will block.
    if (meta.getInfobrightProductType() == null) {
      meta.setDataFormat(DataFormat.TXT_VARIABLE); // default for ICE
    }
    DataFormat dataFormat = DataFormat.valueForDisplayName(meta.getInfobrightProductType());

    Connection conn = db.getConnection();
    String tableName = meta.getDatabaseMeta().getQuotedSchemaTableCombination(step.environmentSubstitute(meta.getSchemaName()), step.environmentSubstitute(meta.getTablename()));
    EtlLogger logger = new KettleEtlLogger(step);
    loader = new InfobrightNamedPipeLoader(tableName, conn, logger, dataFormat);
    record = loader.createRecord(false); // TODO set to true to support error path
    loader.start();
    
  } catch (Exception e) {
    db.disconnect();
    db = null;
    if (loader != null) {
      try {
        loader.killQuery();
      } catch (SQLException e1) {
        throw new KettleDatabaseException(e1);
      }
    }
    throw new KettleDatabaseException(e);
  }
}
 
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:43,代码来源:InfobrightLoaderData.java


示例11: databaseSetup

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
void databaseSetup(InfobrightLoaderMeta meta, InfobrightLoader step) throws KettleException {
  
  db = new Database(step, meta.getDatabaseMeta());
  db.connect();

  // FIXME: This will fail if the first row of the table contains a value that
  // cannot be read by Java. For example, a DATE field that contains the value
  // '0000-00-00'. In this case, the Kettle error message will misleadingly say
  // that the table doesn't exist. There doesn't seem to be any workaround.
  // See Pentaho JIRA: PDI-2117.
  //
  requiredRowMeta = meta.getRequiredFields(step); 
  requiredFields = requiredRowMeta.getFieldNames();
  
  try {
    // once the loader is built, this db connection cannot be used by this thread anymore.
    // the loader is using it and any other uses of the connection will block.
    if (meta.getInfobrightProductType() == null) {
      meta.setDataFormat(DataFormat.TXT_VARIABLE); // default for ICE
    }
    DataFormat dataFormat = DataFormat.valueForDisplayName(meta.getInfobrightProductType());
    int agentPort = meta.getAgentPort();
    Charset charset = meta.getCharset();
    Connection conn = db.getConnection();
    String tableName = meta.getDatabaseMeta().getQuotedSchemaTableCombination(step.environmentSubstitute(meta.getSchemaName()), step.environmentSubstitute(meta.getTablename()));
    EtlLogger logger = new KettleEtlLogger(step);
    loader = new InfobrightNamedPipeLoader(tableName, conn, logger, dataFormat, charset, agentPort);
    loader.setTimeout(30);
    String debugFile = meta.getDebugFile();
    if (debugFile != null) {
      OutputStream debugOutputStream = new FileOutputStream(debugFile);
      loader.setDebugOutputStream(debugOutputStream);
    }
    record = loader.createRecord(false); // TODO set to true to support error path
    loader.start();
    
  } catch (Exception e) {
    db.disconnect();
    db = null;
    if (loader != null) {
      try {
        loader.killQuery();
      } catch (SQLException e1) {
        throw new KettleDatabaseException(e1);
      }
    }
    throw new KettleDatabaseException(e);
  }
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:50,代码来源:InfobrightLoaderData.java


示例12: setDefault

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
public void setDefault() {
  this.dataFormat = DataFormat.TXT_VARIABLE; // default for ICE
  // this.dataFormat = DataFormat.BINARY; // default for IEE
  this.agentPort = InfobrightNamedPipeLoader.AGENT_DEFAULT_PORT;
  this.charset = InfobrightNamedPipeLoader.DEFAULT_CHARSET;
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:7,代码来源:InfobrightLoaderMeta.java


示例13: databaseSetup

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
void databaseSetup(InfobrightLoaderMeta meta, InfobrightLoader step) throws KettleException {
  
  db = new Database(step, meta.getDatabaseMeta());
  db.connect();

  // FIXME: This will fail if the first row of the table contains a value that
  // cannot be read by Java. For example, a DATE field that contains the value
  // '0000-00-00'. In this case, the Kettle error message will misleadingly say
  // that the table doesn't exist. There doesn't seem to be any workaround.
  // See Pentaho JIRA: PDI-2117.
  //
  requiredRowMeta = meta.getRequiredFields(step); 
  requiredFields = requiredRowMeta.getFieldNames();
  
  try {
    // once the loader is built, this db connection cannot be used by this thread anymore.
    // the loader is using it and any other uses of the connection will block.
    if (meta.getInfobrightProductType() == null) {
      meta.setDataFormat(DataFormat.TXT_VARIABLE); // default for ICE
    }
    DataFormat dataFormat = DataFormat.valueForDisplayName(meta.getInfobrightProductType());
    int agentPort = meta.getAgentPort();
    Charset charset = meta.getCharset();
    Connection conn = db.getConnection();
    String tableName = meta.getDatabaseMeta().getQuotedSchemaTableCombination(step.environmentSubstitute(meta.getSchemaName()), step.environmentSubstitute(meta.getTableName()));
    EtlLogger logger = new KettleEtlLogger(step);
    loader = new InfobrightNamedPipeLoader(tableName, conn, logger, dataFormat, charset, agentPort);
    loader.setTimeout(30);
    String debugFile = meta.getDebugFile();
    if (debugFile != null) {
      OutputStream debugOutputStream = new FileOutputStream(debugFile);
      loader.setDebugOutputStream(debugOutputStream);
    }
    record = loader.createRecord(false); // TODO set to true to support error path
    loader.start();
    
  } catch (Exception e) {
    db.disconnect();
    db = null;
    if (loader != null) {
      try {
        loader.killQuery();
      } catch (SQLException e1) {
        throw new KettleDatabaseException(e1);
      }
    }
    throw new KettleDatabaseException(e);
  }
}
 
开发者ID:bsspirit,项目名称:kettle-4.4.0-stable,代码行数:50,代码来源:InfobrightLoaderData.java


示例14: databaseSetup

import com.infobright.io.InfobrightNamedPipeLoader; //导入依赖的package包/类
void databaseSetup( InfobrightLoaderMeta meta, InfobrightLoader step ) throws KettleException {

    db = new Database( step, meta.getDatabaseMeta() );
    db.connect();

    // FIXME: This will fail if the first row of the table contains a value that
    // cannot be read by Java. For example, a DATE field that contains the value
    // '0000-00-00'. In this case, the Kettle error message will misleadingly say
    // that the table doesn't exist. There doesn't seem to be any workaround.
    // See Pentaho JIRA: PDI-2117.
    //
    requiredRowMeta = meta.getRequiredFields( step );
    requiredFields = requiredRowMeta.getFieldNames();

    try {
      // once the loader is built, this db connection cannot be used by this thread anymore.
      // the loader is using it and any other uses of the connection will block.
      if ( meta.getInfobrightProductType() == null ) {
        meta.setDataFormat( DataFormat.TXT_VARIABLE ); // default for ICE
      }
      DataFormat dataFormat = DataFormat.valueForDisplayName( meta.getInfobrightProductType() );
      int agentPort = meta.getAgentPort();
      Charset charset = meta.getCharset();
      Connection conn = db.getConnection();
      String tableName =
        meta
          .getDatabaseMeta().getQuotedSchemaTableCombination(
            step.environmentSubstitute( meta.getSchemaName() ),
            step.environmentSubstitute( meta.getTableName() ) );
      EtlLogger logger = new KettleEtlLogger( step );
      loader = new InfobrightNamedPipeLoader( tableName, conn, logger, dataFormat, charset, agentPort );
      loader.setTimeout( 30 );
      String debugFile = meta.getDebugFile();
      if ( debugFile != null ) {
        OutputStream debugOutputStream = new FileOutputStream( debugFile );
        loader.setDebugOutputStream( debugOutputStream );
      }
      record = loader.createRecord( false ); // TODO set to true to support error path
      loader.start();

    } catch ( Exception e ) {
      db.disconnect();
      db = null;
      if ( loader != null ) {
        try {
          loader.killQuery();
        } catch ( SQLException e1 ) {
          throw new KettleDatabaseException( e1 );
        }
      }
      throw new KettleDatabaseException( e );
    }
  }
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:54,代码来源:InfobrightLoaderData.java



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


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java ProjectLevelVcsManagerImpl类代码示例发布时间:2022-05-22
下一篇:
Java Header类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap