Java TextFileInputField类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: getTextInputFiles

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
/**
 * @param measuresInCSVFile
 * @throws DataLoadingException
 */
public static TextFileInputField[] getTextInputFiles(String header, StringBuilder builder,
    StringBuilder measuresInCSVFile, String delimiter) throws DataLoadingException {

  String[] columnNames = header.split(delimiter);
  TextFileInputField[] textFileInputFields = new TextFileInputField[columnNames.length];

  int i = 0;
  String tmpCol;
  for (String columnName : columnNames) {
    tmpCol = columnName.replaceAll("\"", "");
    builder.append(tmpCol);
    builder.append(";");
    textFileInputFields[i] = new TextFileInputField();
    textFileInputFields[i].setName(tmpCol.trim());
    textFileInputFields[i].setType(2);
    measuresInCSVFile.append(tmpCol);
    measuresInCSVFile.append(";");
    i++;
  }

  return textFileInputFields;

}

开发者ID:carbondata，项目名称:carbondata，代码行数:28，代码来源:GraphExecutionUtil.java

示例2: saveRep

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
@Override
public void saveRep(Repository rep, IMetaStore metaStore, ObjectId id_transformation, ObjectId id_step) throws KettleException {
    try {
        rep.saveStepAttribute(id_transformation, id_step, "serviceEmail", this.serviceEmail);
        rep.saveStepAttribute(id_transformation, id_step, "spreadsheetKey", this.spreadsheetKey);
        rep.saveStepAttribute(id_transformation, id_step, "worksheetId", this.worksheetId);
        rep.saveStepAttribute(id_transformation, id_step, "privateKeyStore", GoogleSpreadsheet.base64EncodePrivateKeyStore(this.privateKeyStore));

        for (int i = 0; i < inputFields.length; i++) {
            TextFileInputField field = inputFields[i];

            rep.saveStepAttribute(id_transformation, id_step, i, "field_name", field.getName());
            rep.saveStepAttribute(id_transformation, id_step, i, "field_type", ValueMeta.getTypeDesc(field.getType()));
            rep.saveStepAttribute(id_transformation, id_step, i, "field_format", field.getFormat());
            rep.saveStepAttribute(id_transformation, id_step, i, "field_currency", field.getCurrencySymbol());
            rep.saveStepAttribute(id_transformation, id_step, i, "field_decimal", field.getDecimalSymbol());
            rep.saveStepAttribute(id_transformation, id_step, i, "field_group", field.getGroupSymbol());
            rep.saveStepAttribute(id_transformation, id_step, i, "field_length", field.getLength());
            rep.saveStepAttribute(id_transformation, id_step, i, "field_precision", field.getPrecision());
            rep.saveStepAttribute(id_transformation, id_step, i, "field_trim_type", ValueMeta.getTrimTypeCode(field.getTrimType()));
        }

    } catch (Exception e) {
        throw new KettleException("Unable to save step information to the repository for id_step=" + id_step, e);
    }
}

开发者ID:GlobalTechnology，项目名称:pdi-google-spreadsheet-plugin，代码行数:27，代码来源:GoogleSpreadsheetInputMeta.java

示例3: setUpLoadSave

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
@Before
public void setUpLoadSave() throws Exception {
  KettleEnvironment.init();
  PluginRegistry.init( true );
  List<String> attributes =
      Arrays.asList( "filename", "filenameField", "includingFilename", "rowNumField", "headerPresent", "delimiter",
          "enclosure", "bufferSize", "lazyConversionActive", "addResultFile", "runningInParallel", "encoding",
          "inputFields" );

  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( "inputFields", new ArrayLoadSaveValidator<TextFileInputField>( new TextFileInputFieldValidator(), 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，代码行数:22，代码来源:ParGzipCsvInputMetaTest.java

示例4: getTestObject

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
@Override
public TextFileInputField getTestObject() {
  TextFileInputField rtn = new TextFileInputField();
  rtn.setCurrencySymbol( UUID.randomUUID().toString() );
  rtn.setDecimalSymbol( UUID.randomUUID().toString() );
  rtn.setFormat( UUID.randomUUID().toString() );
  rtn.setGroupSymbol( UUID.randomUUID().toString() );
  rtn.setName( UUID.randomUUID().toString() );
  rtn.setTrimType( rand.nextInt( 4 ) );
  rtn.setPrecision( rand.nextInt( 9 ) );
  rtn.setLength( rand.nextInt( 50 ) );
  rtn.setType( rand.nextInt( 7 ) );
  // Note - these fields aren't serialized by the meta class ... cannot test for them
  // rtn.setRepeated( rand.nextBoolean() );
  // rtn.setSamples( new String[] { UUID.randomUUID().toString(), UUID.randomUUID().toString(),
  // UUID.randomUUID().toString() } );
  // rtn.setNullString( UUID.randomUUID().toString() );
  // rtn.setIfNullValue( UUID.randomUUID().toString() );
  // rtn.setIgnored( rand.nextBoolean() );
  // rtn.setPosition( rand.nextInt( 10 ) );
  return rtn;
}

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

示例5: validateTestObject

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
@Override
public boolean validateTestObject( TextFileInputField testObject, Object actual ) {
  if ( !( actual instanceof TextFileInputField ) ) {
    return false;
  }

  TextFileInputField another = (TextFileInputField) actual;
  return new EqualsBuilder()
      .append( testObject.getCurrencySymbol(), another.getCurrencySymbol() )
      .append( testObject.getDecimalSymbol(), another.getDecimalSymbol() )
      .append( testObject.getFormat(), another.getFormat() )
      .append( testObject.getGroupSymbol(), another.getGroupSymbol() )
      .append( testObject.getName(), another.getName() )
      .append( testObject.getTrimType(), another.getTrimType() )
      .append( testObject.getPrecision(), another.getPrecision() )
      .append( testObject.getLength(), another.getLength() )
      .append( testObject.getType(), another.getType() )
      // Note - these fields aren't serialized by the meta class ... cannot test for them
      // .append( testObject.isRepeated(), another.isRepeated() )
      // .append( testObject.getSamples(), another.getSamples() )
      // .append( testObject.getNullString(), another.getNullString() )
      // .append( testObject.getIfNullValue(), another.getIfNullValue() )
      // .append( testObject.isIgnored(), another.isIgnored() )
      // .append( testObject.getPosition(), another.getPosition() )
      .isEquals();
}

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

示例6: createMeta

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
private CsvInputMeta createMeta( File file, TextFileInputField[] fields, boolean headerPresent, String delimiter ) {
  CsvInputMeta meta = new CsvInputMeta();

  meta.setFilename( file.getAbsolutePath() );
  meta.setDelimiter( delimiter );
  meta.setEncoding( "utf-8" );
  meta.setEnclosure( "\"" );
  meta.setBufferSize( "1024" );

  if ( !headerPresent ) {
    meta.setInputFields( fields );
  }

  meta.setHeaderPresent( headerPresent );
  meta.setRunningInParallel( true );

  return meta;
}

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

示例7: setDefault

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
@Override
public void setDefault() {
    this.serviceEmail = "";
    this.spreadsheetKey = "";
    this.worksheetId = "od6";
    this.privateKeyStore = null;

    TextFileInputField field = new TextFileInputField();
    field.setName("field");
    field.setType(ValueMetaInterface.TYPE_STRING);

    inputFields = new TextFileInputField[]{
            field,
    };
}

开发者ID:GlobalTechnology，项目名称:pdi-google-spreadsheet-plugin，代码行数:16，代码来源:GoogleSpreadsheetInputMeta.java

示例8: getXML

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
@Override
public String getXML() throws KettleException {
    StringBuilder xml = new StringBuilder();
    try {
        xml.append(XMLHandler.addTagValue("serviceEmail", this.serviceEmail));
        xml.append(XMLHandler.addTagValue("spreadsheetKey", this.spreadsheetKey));
        xml.append(XMLHandler.addTagValue("worksheetId", this.worksheetId));
        xml.append(XMLHandler.openTag("privateKeyStore"));
        xml.append(XMLHandler.buildCDATA(GoogleSpreadsheet.base64EncodePrivateKeyStore(this.privateKeyStore)));
        xml.append(XMLHandler.closeTag("privateKeyStore"));

        xml.append(XMLHandler.openTag("fields"));
        for (TextFileInputField field : inputFields) {
            xml.append(XMLHandler.openTag("field"));
            xml.append(XMLHandler.addTagValue("field_name", field.getName()));
            xml.append(XMLHandler.addTagValue("field_type", ValueMeta.getTypeDesc(field.getType())));
            xml.append(XMLHandler.addTagValue("field_format", field.getFormat()));
            xml.append(XMLHandler.addTagValue("field_currency", field.getCurrencySymbol()));
            xml.append(XMLHandler.addTagValue("field_decimal", field.getDecimalSymbol()));
            xml.append(XMLHandler.addTagValue("field_group", field.getGroupSymbol()));
            xml.append(XMLHandler.addTagValue("field_length", field.getLength()));
            xml.append(XMLHandler.addTagValue("field_precision", field.getPrecision()));
            xml.append(XMLHandler.addTagValue("field_trim_type", ValueMeta.getTrimTypeCode(field.getTrimType())));
            xml.append(XMLHandler.closeTag("field"));
        }
        xml.append(XMLHandler.closeTag("fields"));

    } catch (Exception e) {
        throw new KettleValueException("Unable to write step to XML", e);
    }
    return xml.toString();
}

开发者ID:GlobalTechnology，项目名称:pdi-google-spreadsheet-plugin，代码行数:33，代码来源:GoogleSpreadsheetInputMeta.java

示例9: loadXML

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
@Override
public void loadXML(Node stepnode, List<DatabaseMeta> databases, IMetaStore metaStore) throws KettleXMLException {
    try {
        this.serviceEmail = XMLHandler.getTagValue(stepnode, "serviceEmail");
        this.spreadsheetKey = XMLHandler.getTagValue(stepnode, "spreadsheetKey");
        this.worksheetId = XMLHandler.getTagValue(stepnode, "worksheetId");
        this.privateKeyStore = GoogleSpreadsheet.base64DecodePrivateKeyStore(XMLHandler.getTagValue(stepnode, "privateKeyStore"));

        Node fields = XMLHandler.getSubNode(stepnode, "fields");
        int nrfields = XMLHandler.countNodes(fields, "field");

        allocate(nrfields);

        for (int i = 0; i < nrfields; i++) {
            inputFields[i] = new TextFileInputField();

            Node fnode = XMLHandler.getSubNodeByNr(fields, "field", i);

            inputFields[i].setName(XMLHandler.getTagValue(fnode, "field_name"));
            inputFields[i].setType(ValueMeta.getType(XMLHandler.getTagValue(fnode, "field_type")));
            inputFields[i].setFormat(XMLHandler.getTagValue(fnode, "field_format"));
            inputFields[i].setCurrencySymbol(XMLHandler.getTagValue(fnode, "field_currency"));
            inputFields[i].setDecimalSymbol(XMLHandler.getTagValue(fnode, "field_decimal"));
            inputFields[i].setGroupSymbol(XMLHandler.getTagValue(fnode, "field_group"));
            inputFields[i].setLength(Const.toInt(XMLHandler.getTagValue(fnode, "field_length"), -1));
            inputFields[i].setPrecision(Const.toInt(XMLHandler.getTagValue(fnode, "field_precision"), -1));
            inputFields[i].setTrimType(ValueMeta.getTrimTypeByCode(XMLHandler.getTagValue(fnode, "field_trim_type")));
        }

    } catch (Exception e) {
        throw new KettleXMLException("Unable to load step from XML", e);
    }
}

开发者ID:GlobalTechnology，项目名称:pdi-google-spreadsheet-plugin，代码行数:34，代码来源:GoogleSpreadsheetInputMeta.java

示例10: readRep

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
@Override
public void readRep(Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases) throws KettleException {
    try {
        this.serviceEmail = rep.getStepAttributeString(id_step, "serviceEmail");
        this.spreadsheetKey = rep.getStepAttributeString(id_step, "spreadsheetKey");
        this.worksheetId = rep.getStepAttributeString(id_step, "worksheetId");
        this.privateKeyStore = GoogleSpreadsheet.base64DecodePrivateKeyStore(rep.getStepAttributeString(id_step, "privateKeyStore"));

        int nrfields = rep.countNrStepAttributes(id_step, "field_name");

        allocate(nrfields);

        for (int i = 0; i < nrfields; i++) {
            inputFields[i] = new TextFileInputField();

            inputFields[i].setName(rep.getStepAttributeString(id_step, i, "field_name"));
            inputFields[i].setType(ValueMeta.getType(rep.getStepAttributeString(id_step, i, "field_type")));
            inputFields[i].setFormat(rep.getStepAttributeString(id_step, i, "field_format"));
            inputFields[i].setCurrencySymbol(rep.getStepAttributeString(id_step, i, "field_currency"));
            inputFields[i].setDecimalSymbol(rep.getStepAttributeString(id_step, i, "field_decimal"));
            inputFields[i].setGroupSymbol(rep.getStepAttributeString(id_step, i, "field_group"));
            inputFields[i].setLength((int) rep.getStepAttributeInteger(id_step, i, "field_length"));
            inputFields[i].setPrecision((int) rep.getStepAttributeInteger(id_step, i, "field_precision"));
            inputFields[i].setTrimType(ValueMeta.getTrimTypeByCode(rep.getStepAttributeString(id_step, i, "field_trim_type")));
        }
    } catch (Exception e) {
        throw new KettleException("Unexpected error reading step information from the repository", e);
    }
}

开发者ID:GlobalTechnology，项目名称:pdi-google-spreadsheet-plugin，代码行数:30，代码来源:GoogleSpreadsheetInputMeta.java

示例11: getFields

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
@Override
public void getFields(RowMetaInterface inputRowMeta, String name, RowMetaInterface[] info, StepMeta nextStep, VariableSpace space, Repository repository, IMetaStore metaStore) throws KettleStepException {
    try {
        inputRowMeta.clear(); // Start with a clean slate, eats the input

        for (TextFileInputField field : inputFields) {
            ValueMetaInterface valueMeta = ValueMetaFactory.createValueMeta(field.getName(), field.getType());
            valueMeta.setConversionMask(field.getFormat());
            valueMeta.setLength(field.getLength());
            valueMeta.setPrecision(field.getPrecision());
            valueMeta.setConversionMask(field.getFormat());
            valueMeta.setDecimalSymbol(field.getDecimalSymbol());
            valueMeta.setGroupingSymbol(field.getGroupSymbol());
            valueMeta.setCurrencySymbol(field.getCurrencySymbol());
            valueMeta.setTrimType(field.getTrimType());
            valueMeta.setStorageType(ValueMetaInterface.STORAGE_TYPE_BINARY_STRING);
            valueMeta.setDateFormatLenient(true);
            valueMeta.setStringEncoding("UTF-8");

            ValueMetaInterface storageMetadata = ValueMetaFactory.cloneValueMeta(valueMeta, ValueMetaInterface.TYPE_STRING);
            storageMetadata.setStorageType(ValueMetaInterface.STORAGE_TYPE_NORMAL);
            storageMetadata.setLength(-1, -1); // we don't really know the lengths of the strings read in advance.
            valueMeta.setStorageMetadata(storageMetadata);

            valueMeta.setOrigin(name);

            inputRowMeta.addValueMeta(valueMeta);
        }
    } catch (Exception e) {

    }
}

开发者ID:GlobalTechnology，项目名称:pdi-google-spreadsheet-plugin，代码行数:33，代码来源:GoogleSpreadsheetInputMeta.java

示例12: getData

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
private void getData(GoogleSpreadsheetInputMeta meta) {
    this.wStepname.selectAll();

    this.serviceEmail.setText(meta.getServiceEmail());
    this.spreadsheetKey.setText(meta.getSpreadsheetKey());
    this.worksheetId.setText(meta.getWorksheetId());

    this.privateKeyStore = meta.getPrivateKeyStore();
    if (this.privateKeyStore != null) {
        this.privateKeyInfo.setText("Client ID: " + getPrivateKeyClientID(this.privateKeyStore));
    } else {
        this.privateKeyInfo.setText("Private key not loaded.");
    }

    for (int i = 0; i < meta.getInputFields().length; i++) {
        TextFileInputField field = meta.getInputFields()[i];

        TableItem item = new TableItem(wFields.table, SWT.NONE);
        int colnr = 1;
        item.setText(colnr++, Const.NVL(field.getName(), ""));
        item.setText(colnr++, ValueMeta.getTypeDesc(field.getType()));
        item.setText(colnr++, Const.NVL(field.getFormat(), ""));
        item.setText(colnr++, field.getLength() >= 0 ? Integer.toString(field.getLength()) : "");
        item.setText(colnr++, field.getPrecision() >= 0 ? Integer.toString(field.getPrecision()) : "");
        item.setText(colnr++, Const.NVL(field.getCurrencySymbol(), ""));
        item.setText(colnr++, Const.NVL(field.getDecimalSymbol(), ""));
        item.setText(colnr++, Const.NVL(field.getGroupSymbol(), ""));
        item.setText(colnr++, Const.NVL(field.getTrimTypeDesc(), ""));
    }

    wFields.removeEmptyRows();
    wFields.setRowNums();
    wFields.optWidth(true);
}

开发者ID:GlobalTechnology，项目名称:pdi-google-spreadsheet-plugin，代码行数:35，代码来源:GoogleSpreadsheetInputDialog.java

示例13: setData

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
private void setData(GoogleSpreadsheetInputMeta meta) {
    meta.setServiceEmail(this.serviceEmail.getText());
    meta.setPrivateKeyStore(this.privateKeyStore);
    meta.setSpreadsheetKey(this.spreadsheetKey.getText());
    meta.setWorksheetId(this.worksheetId.getText());

    int nrNonEmptyFields = wFields.nrNonEmpty();
    meta.allocate(nrNonEmptyFields);

    for (int i = 0; i < nrNonEmptyFields; i++) {
        TableItem item = wFields.getNonEmpty(i);
        meta.getInputFields()[i] = new TextFileInputField();

        int colnr = 1;
        meta.getInputFields()[i].setName(item.getText(colnr++));
        meta.getInputFields()[i].setType(ValueMeta.getType(item.getText(colnr++)));
        meta.getInputFields()[i].setFormat(item.getText(colnr++));
        meta.getInputFields()[i].setLength(Const.toInt(item.getText(colnr++), -1));
        meta.getInputFields()[i].setPrecision(Const.toInt(item.getText(colnr++), -1));
        meta.getInputFields()[i].setCurrencySymbol(item.getText(colnr++));
        meta.getInputFields()[i].setDecimalSymbol(item.getText(colnr++));
        meta.getInputFields()[i].setGroupSymbol(item.getText(colnr++));
        meta.getInputFields()[i].setTrimType(ValueMeta.getTrimTypeByDesc(item.getText(colnr++)));
    }
    wFields.removeEmptyRows();
    wFields.setRowNums();
    wFields.optWidth(true);

    meta.setChanged();
}

开发者ID:GlobalTechnology，项目名称:pdi-google-spreadsheet-plugin，代码行数:31，代码来源:GoogleSpreadsheetInputDialog.java

示例14: getXML

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
public String getXML()
{
	StringBuffer retval = new StringBuffer(500);

	retval.append("    ").append(XMLHandler.addTagValue("filename", filename));
	retval.append("    ").append(XMLHandler.addTagValue("filename_field", filenameField));
	retval.append("    ").append(XMLHandler.addTagValue("rownum_field", rowNumField));
	retval.append("    ").append(XMLHandler.addTagValue("include_filename", includingFilename));
	retval.append("    ").append(XMLHandler.addTagValue("separator", delimiter));
	retval.append("    ").append(XMLHandler.addTagValue("enclosure", enclosure));
	retval.append("    ").append(XMLHandler.addTagValue("header", headerPresent));
	retval.append("    ").append(XMLHandler.addTagValue("buffer_size", bufferSize));
	retval.append("    ").append(XMLHandler.addTagValue("lazy_conversion", lazyConversionActive));
	retval.append("    ").append(XMLHandler.addTagValue("add_filename_result", isaddresult));
	retval.append("    ").append(XMLHandler.addTagValue("parallel", runningInParallel));
	retval.append("    ").append(XMLHandler.addTagValue("encoding", encoding));

	retval.append("    <fields>").append(Const.CR);
	for (int i = 0; i < inputFields.length; i++)
	{
		TextFileInputField field = inputFields[i];
		
		retval.append("      <field>").append(Const.CR);
		retval.append("        ").append(XMLHandler.addTagValue("name", field.getName()));
		retval.append("        ").append(XMLHandler.addTagValue("type", ValueMeta.getTypeDesc(field.getType())));
		retval.append("        ").append(XMLHandler.addTagValue("format", field.getFormat()));
		retval.append("        ").append(XMLHandler.addTagValue("currency", field.getCurrencySymbol()));
		retval.append("        ").append(XMLHandler.addTagValue("decimal", field.getDecimalSymbol()));
		retval.append("        ").append(XMLHandler.addTagValue("group", field.getGroupSymbol()));
		retval.append("        ").append(XMLHandler.addTagValue("length", field.getLength()));
		retval.append("        ").append(XMLHandler.addTagValue("precision", field.getPrecision()));
		retval.append("        ").append(XMLHandler.addTagValue("trim_type", ValueMeta.getTrimTypeCode(field.getTrimType())));
		retval.append("      </field>").append(Const.CR);
	}
	retval.append("    </fields>").append(Const.CR);

	return retval.toString();
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:39，代码来源:ParGzipCsvInputMeta.java

示例15: saveRep

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
public void saveRep(Repository rep, long id_transformation, long id_step) throws KettleException
{
	try
	{
		rep.saveStepAttribute(id_transformation, id_step, "filename", filename);
		rep.saveStepAttribute(id_transformation, id_step, "filename_field", filenameField);
		rep.saveStepAttribute(id_transformation, id_step, "rownum_field", rowNumField);
		rep.saveStepAttribute(id_transformation, id_step, "include_filename", includingFilename);
		rep.saveStepAttribute(id_transformation, id_step, "separator", delimiter);
		rep.saveStepAttribute(id_transformation, id_step, "enclosure", enclosure);
		rep.saveStepAttribute(id_transformation, id_step, "buffer_size", bufferSize);
		rep.saveStepAttribute(id_transformation, id_step, "header", headerPresent);
		rep.saveStepAttribute(id_transformation, id_step, "lazy_conversion", lazyConversionActive);
		rep.saveStepAttribute(id_transformation, id_step, "add_filename_result", isaddresult);
		rep.saveStepAttribute(id_transformation, id_step, "parallel", runningInParallel);
		rep.saveStepAttribute(id_transformation, id_step, "encoding", encoding);

		for (int i = 0; i < inputFields.length; i++)
		{
			TextFileInputField field = inputFields[i];
			
			rep.saveStepAttribute(id_transformation, id_step, i, "field_name", field.getName());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_type", ValueMeta.getTypeDesc(field.getType()));
			rep.saveStepAttribute(id_transformation, id_step, i, "field_format", field.getFormat());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_currency", field.getCurrencySymbol());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_decimal", field.getDecimalSymbol());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_group", field.getGroupSymbol());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_length", field.getLength());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_precision", field.getPrecision());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_trim_type", ValueMeta.getTrimTypeCode( field.getTrimType()));
		}
	}
	catch (Exception e)
	{
		throw new KettleException("Unable to save step information to the repository for id_step=" + id_step, e);
	}
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:38，代码来源:ParGzipCsvInputMeta.java

示例16: refreshFields

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
private void refreshFields()
{
	wFields.removeAll();
	for (int i=0;i<fields.size();i++)
	{
		wFields.add( ((TextFileInputField)fields.get(i)).getName() );
	}
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:9，代码来源:TextFileImportWizardPage2.java

示例17: saveRep

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
public void saveRep(Repository rep, ObjectId id_transformation, ObjectId id_step) throws KettleException
{
	try
	{
		rep.saveStepAttribute(id_transformation, id_step, "filename", filename);
		rep.saveStepAttribute(id_transformation, id_step, "filename_field", filenameField);
		rep.saveStepAttribute(id_transformation, id_step, "rownum_field", rowNumField);
		rep.saveStepAttribute(id_transformation, id_step, "include_filename", includingFilename);
		rep.saveStepAttribute(id_transformation, id_step, "separator", delimiter);
		rep.saveStepAttribute(id_transformation, id_step, "enclosure", enclosure);
		rep.saveStepAttribute(id_transformation, id_step, "buffer_size", bufferSize);
		rep.saveStepAttribute(id_transformation, id_step, "header", headerPresent);
		rep.saveStepAttribute(id_transformation, id_step, "lazy_conversion", lazyConversionActive);
		rep.saveStepAttribute(id_transformation, id_step, "add_filename_result", isaddresult);
		rep.saveStepAttribute(id_transformation, id_step, "parallel", runningInParallel);
		rep.saveStepAttribute(id_transformation, id_step, "encoding", encoding);

		for (int i = 0; i < inputFields.length; i++)
		{
			TextFileInputField field = inputFields[i];
			
			rep.saveStepAttribute(id_transformation, id_step, i, "field_name", field.getName());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_type", ValueMeta.getTypeDesc(field.getType()));
			rep.saveStepAttribute(id_transformation, id_step, i, "field_format", field.getFormat());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_currency", field.getCurrencySymbol());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_decimal", field.getDecimalSymbol());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_group", field.getGroupSymbol());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_length", field.getLength());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_precision", field.getPrecision());
			rep.saveStepAttribute(id_transformation, id_step, i, "field_trim_type", ValueMeta.getTrimTypeCode( field.getTrimType()));
		}
	}
	catch (Exception e)
	{
		throw new KettleException("Unable to save step information to the repository for id_step=" + id_step, e);
	}
}

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

示例18: getXML

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
public String getXML()
{
	StringBuffer retval = new StringBuffer(500);
	
	retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("FILENAME"), filename));
	retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("FILENAME_FIELD"), filenameField));
	retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("ROW_NUM_FIELD"), rowNumField));
	retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("INCLUDE_FILENAME"), includingFilename));
	retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("DELIMITER"), delimiter));
	retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("ENCLOSURE"), enclosure));
	retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("HEADER_PRESENT"), headerPresent));
	retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("BUFFERSIZE"), bufferSize));
	retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("LAZY_CONVERSION"), lazyConversionActive));
	retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("ADD_FILENAME_RESULT"), isaddresult));
	retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("PARALLEL"), runningInParallel));
   retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("NEWLINE_POSSIBLE"), newlinePossibleInFields));
	retval.append("    ").append(XMLHandler.addTagValue(getXmlCode("ENCODING"), encoding));

	retval.append("    ").append(XMLHandler.openTag(getXmlCode("FIELDS"))).append(Const.CR);
	for (int i = 0; i < inputFields.length; i++)
	{
		TextFileInputField field = inputFields[i];
		
        retval.append("      ").append(XMLHandler.openTag(getXmlCode("FIELD"))).append(Const.CR);
		retval.append("        ").append(XMLHandler.addTagValue(getXmlCode("FIELD_NAME"), field.getName()));
		retval.append("        ").append(XMLHandler.addTagValue(getXmlCode("FIELD_TYPE"), ValueMeta.getTypeDesc(field.getType())));
		retval.append("        ").append(XMLHandler.addTagValue(getXmlCode("FIELD_FORMAT"), field.getFormat()));
		retval.append("        ").append(XMLHandler.addTagValue(getXmlCode("FIELD_CURRENCY"), field.getCurrencySymbol()));
		retval.append("        ").append(XMLHandler.addTagValue(getXmlCode("FIELD_DECIMAL"), field.getDecimalSymbol()));
		retval.append("        ").append(XMLHandler.addTagValue(getXmlCode("FIELD_GROUP"), field.getGroupSymbol()));
		retval.append("        ").append(XMLHandler.addTagValue(getXmlCode("FIELD_LENGTH"), field.getLength()));
		retval.append("        ").append(XMLHandler.addTagValue(getXmlCode("FIELD_PRECISION"), field.getPrecision()));
		retval.append("        ").append(XMLHandler.addTagValue(getXmlCode("FIELD_TRIM_TYPE"), ValueMeta.getTrimTypeCode(field.getTrimType())));
           retval.append("      ").append(XMLHandler.closeTag(getXmlCode("FIELD"))).append(Const.CR);
	}
       retval.append("    ").append(XMLHandler.closeTag(getXmlCode("FIELDS"))).append(Const.CR);

	return retval.toString();
}

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

示例19: saveRep

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
public void saveRep(Repository rep, ObjectId id_transformation, ObjectId id_step) throws KettleException
{
	try
	{
		rep.saveStepAttribute(id_transformation, id_step, getRepCode("FILENAME"), filename);
		rep.saveStepAttribute(id_transformation, id_step, getRepCode("FILENAME_FIELD"), filenameField);
		rep.saveStepAttribute(id_transformation, id_step, getRepCode("ROW_NUM_FIELD"), rowNumField);
		rep.saveStepAttribute(id_transformation, id_step, getRepCode("INCLUDE_FILENAME"), includingFilename);
		rep.saveStepAttribute(id_transformation, id_step, getRepCode("DELIMITER"), delimiter);
		rep.saveStepAttribute(id_transformation, id_step, getRepCode("ENCLOSURE"), enclosure);
		rep.saveStepAttribute(id_transformation, id_step, getRepCode("BUFFERSIZE"), bufferSize);
		rep.saveStepAttribute(id_transformation, id_step, getRepCode("HEADER_PRESENT"), headerPresent);
		rep.saveStepAttribute(id_transformation, id_step, getRepCode("LAZY_CONVERSION"), lazyConversionActive);
		rep.saveStepAttribute(id_transformation, id_step, getRepCode("ADD_FILENAME_RESULT"), isaddresult);
		rep.saveStepAttribute(id_transformation, id_step, getRepCode("PARALLEL"), runningInParallel);
     rep.saveStepAttribute(id_transformation, id_step, getRepCode("NEWLINE_POSSIBLE"), newlinePossibleInFields);
		rep.saveStepAttribute(id_transformation, id_step, getRepCode("ENCODING"), encoding);

		for (int i = 0; i < inputFields.length; i++)
		{
			TextFileInputField field = inputFields[i];
			
			rep.saveStepAttribute(id_transformation, id_step, i, getRepCode("FIELD_NAME"), field.getName());
			rep.saveStepAttribute(id_transformation, id_step, i, getRepCode("FIELD_TYPE"), ValueMeta.getTypeDesc(field.getType()));
			rep.saveStepAttribute(id_transformation, id_step, i, getRepCode("FIELD_FORMAT"), field.getFormat());
			rep.saveStepAttribute(id_transformation, id_step, i, getRepCode("FIELD_CURRENCY"), field.getCurrencySymbol());
			rep.saveStepAttribute(id_transformation, id_step, i, getRepCode("FIELD_DECIMAL"), field.getDecimalSymbol());
			rep.saveStepAttribute(id_transformation, id_step, i, getRepCode("FIELD_GROUP"), field.getGroupSymbol());
			rep.saveStepAttribute(id_transformation, id_step, i, getRepCode("FIELD_LENGTH"), field.getLength());
			rep.saveStepAttribute(id_transformation, id_step, i, getRepCode("FIELD_PRECISION"), field.getPrecision());
			rep.saveStepAttribute(id_transformation, id_step, i, getRepCode("FIELD_TRIM_TYPE"), ValueMeta.getTrimTypeCode( field.getTrimType()));
		}
	}
	catch (Exception e)
	{
		throw new KettleException("Unable to save step information to the repository for id_step=" + id_step, e);
	}
}

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

示例20: testSerialization

import org.pentaho.di.trans.steps.textfileinput.TextFileInputField; //导入依赖的package包/类
@Test
public void testSerialization() throws KettleException {
  List<String> attributes = Arrays.asList( "AwsAccessKey", "AwsSecretKey", "Bucket", "Filename", "FilenameField",
    "RowNumField", "IncludingFilename", "Delimiter", "Enclosure", "HeaderPresent", "MaxLineSize",
    "LazyConversionActive", "RunningInParallel", "InputFields" );

  Map<String, FieldLoadSaveValidator<?>> typeMap = new HashMap<>();
  typeMap.put( TextFileInputField[].class.getCanonicalName(),
    new ArrayLoadSaveValidator<>( new TextFileInputFieldValidator() ) );
  Map<String, String> getterMap = new HashMap<>();
  Map<String, String> setterMap = new HashMap<>();
  LoadSaveTester<S3CsvInputMeta> tester = new LoadSaveTester<>( S3CsvInputMeta.class, attributes,
    getterMap, setterMap, new HashMap<String, FieldLoadSaveValidator<?>>(), typeMap );
  tester.testSerialization();
}

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

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

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java Attribute类代码示例发布时间：2022-05-22

Java SelectByExampleWithoutBLOBsElementGenerator类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18222|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9658|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8173|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8543|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8450|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9375|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8420|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7855|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8405|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7392|2022-11-06

客服电话

电子邮件

Java TextFileInputField类代码示例

示例1: getTextInputFiles

示例2: saveRep

示例3: setUpLoadSave

示例4: getTestObject

示例5: validateTestObject

示例6: createMeta

示例7: setDefault

示例8: getXML

示例9: loadXML

示例10: readRep

示例11: getFields

示例12: getData

示例13: setData

示例14: getXML

示例15: saveRep

示例16: refreshFields

示例17: saveRep

示例18: getXML

示例19: saveRep

示例20: testSerialization

请发表评论

全部评论

上一篇：

下一篇：

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

medfreeman/markdown-it-toc-and-anchor: m

maxcom/lorsource: Linux.org.ru website e

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053