Java ElasticSearchBulkMeta类的典型用法和代码示例

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

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

示例1: ElasticSearchBulkDialog

import org.pentaho.di.trans.steps.elasticsearchbulk.ElasticSearchBulkMeta; //导入依赖的package包/类
public ElasticSearchBulkDialog(Shell parent, Object in, TransMeta transMeta, String sname)
{
  super(parent, (BaseStepMeta) in, transMeta, sname);
  model = (ElasticSearchBulkMeta) in;
}

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

示例2: getData

import org.pentaho.di.trans.steps.elasticsearchbulk.ElasticSearchBulkMeta; //导入依赖的package包/类
/**
 * Read the data from the ElasticSearchBulkMeta object and show it in this
 * dialog.
 *
 * @param in The ElasticSearchBulkMeta object to obtain the data from.
 */
public void getData(ElasticSearchBulkMeta in)
{
  wStepname.selectAll();
  
  wIndex.setText(Const.NVL(in.getIndex(),""));
  wType.setText(Const.NVL(in.getType(),""));
  
  wBatchSize.setText(Const.NVL(in.getBatchSize(), "" + ElasticSearchBulkMeta.DEFAULT_BATCH_SIZE));
  
  wStopOnError.setSelection(in.isStopOnError());
  
  wTimeOut.setText(Const.NVL(in.getTimeOut(), ""));
  wTimeOut.setTimeUnit(in.getTimeoutUnit());
  
  wIdInField.setText(Const.NVL(in.getIdInField(), ""));
  
  wIsOverwrite.setSelection( in.isOverWriteIfSameId() );
  
  wIsJson.setSelection(in.isJsonInsert());
  
  wJsonField.setText( Const.NVL(in.getJsonField(), "")); 
  wJsonField.setEnabled(wIsJson.getSelection());//listener not working here
  
  wUseOutput.setSelection(in.isUseOutput());
  
  wIdOutField.setText( Const.NVL(in.getIdOutField(), "") ); 
  wIdOutField.setEnabled(wUseOutput.getSelection());//listener not working here
  
  //Fields
  mapToTableView(model.getFields(), wFields);
  
  //Servers
  for(InetSocketTransportAddress server : model.getServers()){
    String addr = server.address().getAddress().getHostAddress();
    int port = server.address().getPort(); 
    wServers.add(addr, "" + port);
  }
  wServers.removeEmptyRows();
  wServers.setRowNums();
  
  //Settings
  mapToTableView(model.getSettings(), wSettings);
}

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

示例3: ElasticSearchBulkDialog

import org.pentaho.di.trans.steps.elasticsearchbulk.ElasticSearchBulkMeta; //导入依赖的package包/类
public ElasticSearchBulkDialog( Shell parent, Object in, TransMeta transMeta, String sname ) {
  super( parent, (BaseStepMeta) in, transMeta, sname );
  model = (ElasticSearchBulkMeta) in;
}

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

示例4: getData

import org.pentaho.di.trans.steps.elasticsearchbulk.ElasticSearchBulkMeta; //导入依赖的package包/类
/**
 * Read the data from the ElasticSearchBulkMeta object and show it in this dialog.
 *
 * @param in The ElasticSearchBulkMeta object to obtain the data from.
 */
public void getData( ElasticSearchBulkMeta in ) {
  wIndex.setText( Const.NVL( in.getIndex(), "" ) );
  wType.setText( Const.NVL( in.getType(), "" ) );

  wBatchSize.setText( Const.NVL( in.getBatchSize(), "" + ElasticSearchBulkMeta.DEFAULT_BATCH_SIZE ) );

  wStopOnError.setSelection( in.isStopOnError() );

  wTimeOut.setText( Const.NVL( in.getTimeOut(), "" ) );
  wTimeOut.setTimeUnit( in.getTimeoutUnit() );

  wIdInField.setText( Const.NVL( in.getIdInField(), "" ) );

  wIsOverwrite.setSelection( in.isOverWriteIfSameId() );

  wIsJson.setSelection( in.isJsonInsert() );

  wJsonField.setText( Const.NVL( in.getJsonField(), "" ) );
  wJsonField.setEnabled( wIsJson.getSelection() ); // listener not working here

  wUseOutput.setSelection( in.isUseOutput() );

  wIdOutField.setText( Const.NVL( in.getIdOutField(), "" ) );
  wIdOutField.setEnabled( wUseOutput.getSelection() ); // listener not working here

  // Fields
  mapToTableView( model.getFieldsMap(), wFields );

  // Servers
  for ( ElasticSearchBulkMeta.Server server : model.getServers() ) {
    wServers.add( server.address, "" + server.port );
  }
  wServers.removeEmptyRows();
  wServers.setRowNums();

  // Settings
  mapToTableView( model.getSettingsMap(), wSettings );

  wStepname.selectAll();
  wStepname.setFocus();
}

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