org.pentaho.di.core.row.value.ValueMetaNumber.<init>()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(14.2k)|赞(0)|评价(0)|浏览(68)

本文整理了Java中org.pentaho.di.core.row.value.ValueMetaNumber.<init>()方法的一些代码示例,展示了ValueMetaNumber.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ValueMetaNumber.<init>()方法的具体详情如下:
包路径:org.pentaho.di.core.row.value.ValueMetaNumber
类名称:ValueMetaNumber
方法名:<init>

ValueMetaNumber.<init>介绍

暂无

代码示例

代码示例来源:origin: pentaho/pentaho-kettle

@Override
public void setDefault() {
 value = new ValueMetaAndData( new ValueMetaNumber( "valuename" ), new Double( 123.456 ) );
 value.getValueMeta().setLength( 12 );
 value.getValueMeta().setPrecision( 4 );
}

代码示例来源:origin: pentaho/pentaho-kettle

public ExcelInputData() {
  super();
  workbook = null;
  filenr = 0;
  sheetnr = 0;
  rownr = -1;
  colnr = -1;

  valueMetaString = new ValueMetaString( "v" );
  valueMetaNumber = new ValueMetaNumber( "v" );
  valueMetaDate = new ValueMetaDate( "v" );
  valueMetaBoolean = new ValueMetaBoolean( "v" );
 }
}

代码示例来源:origin: pentaho/pentaho-kettle

private static void populateMetaAndData( int i, Object[] rowString10, RowMetaInterface metaString10,
 Object[] rowMixed10, RowMetaInterface metaMixed10 ) {
 rowString10[i] = StringUtil.generateRandomString( 20, "", "", false );
 ValueMetaInterface meta = new ValueMetaString( "String" + ( i + 1 ), 20, 0 );
 metaString10.addValueMeta( meta );
 rowMixed10[i * 5 + 0] = StringUtil.generateRandomString( 20, "", "", false );
 ValueMetaInterface meta0 = new ValueMetaString( "String" + ( i * 5 + 1 ), 20, 0 );
 metaMixed10.addValueMeta( meta0 );
 rowMixed10[i * 5 + 1] = new Date();
 ValueMetaInterface meta1 = new ValueMetaDate( "String" + ( i * 5 + 1 ) );
 metaMixed10.addValueMeta( meta1 );
 rowMixed10[i * 5 + 2] = new Double( Math.random() * 1000000 );
 ValueMetaInterface meta2 = new ValueMetaNumber( "String" + ( i * 5 + 1 ), 12, 4 );
 metaMixed10.addValueMeta( meta2 );
 rowMixed10[i * 5 + 3] = new Long( (long) ( Math.random() * 1000000 ) );
 ValueMetaInterface meta3 = new ValueMetaInteger( "String" + ( i * 5 + 1 ), 8, 0 );
 metaMixed10.addValueMeta( meta3 );
 rowMixed10[i * 5 + 4] = Boolean.valueOf( Math.random() > 0.5 ? true : false );
 ValueMetaInterface meta4 = new ValueMetaBoolean( "String" + ( i * 5 + 1 ) );
 metaMixed10.addValueMeta( meta4 );
}

代码示例来源:origin: pentaho/pentaho-kettle

@Test
public void assertNumeric_Number() throws Exception {
 assertNumericForNumberMeta( new ValueMetaNumber( "number" ), 1D );
}

代码示例来源:origin: pentaho/pentaho-kettle

/**
  * Create meta information for rows that are passed to Excel Writer step
  *
  * @return
  * @throws KettleException
  */
 private RowMetaInterface createRowMeta() throws KettleException {
  RowMetaInterface rm = new RowMeta();
  try {
   ValueMetaInterface[] valuesMeta = {
    new ValueMetaInteger( "col 1" ),
    new ValueMetaNumber( "col 2" ),
    new ValueMetaBigNumber( "col 3" ),
    new ValueMetaNumber( "col 4" )
   };
   for ( int i = 0; i < valuesMeta.length; i++ ) {
    rm.addValueMeta( valuesMeta[i] );
   }
  } catch ( Exception ex ) {
   return null;
  }
  return rm;
 }
}

代码示例来源:origin: pentaho/pentaho-kettle

r.addValueMeta( sname );
r.addValueMeta( new ValueMetaNumber(
 BaseMessages.getString( PKG, "BaseStep.ColumnName.Copy" ) ) );
r.addValueMeta( new ValueMetaNumber(
 BaseMessages.getString( PKG, "BaseStep.ColumnName.LinesReaded" ) ) );
r.addValueMeta( new ValueMetaNumber(
 BaseMessages.getString( PKG, "BaseStep.ColumnName.LinesWritten" ) ) );
r.addValueMeta( new ValueMetaNumber(
 BaseMessages.getString( PKG, "BaseStep.ColumnName.LinesUpdated" ) ) );
r.addValueMeta( new ValueMetaNumber(
 BaseMessages.getString( PKG, "BaseStep.ColumnName.LinesSkipped" ) ) );
r.addValueMeta( new ValueMetaNumber(
 BaseMessages.getString( PKG, "BaseStep.ColumnName.Errors" ) ) );
r.addValueMeta( new ValueMetaDate(

代码示例来源:origin: pentaho/pentaho-kettle

public RowMetaInterface getParameterMetaData( String sql, RowMetaInterface inform, Object[] data ) {
 // The database couldn't handle it: try manually!
 int q = countParameters( sql );
 RowMetaInterface par = new RowMeta();
 if ( inform != null && q == inform.size() ) {
  for ( int i = 0; i < q; i++ ) {
   ValueMetaInterface inf = inform.getValueMeta( i );
   ValueMetaInterface v = inf.clone();
   par.addValueMeta( v );
  }
 } else {
  for ( int i = 0; i < q; i++ ) {
   ValueMetaInterface v = new ValueMetaNumber( "name" + i );
   par.addValueMeta( v );
  }
 }
 return par;
}

代码示例来源:origin: pentaho/pentaho-kettle

public ValueMetaAndData( String valueName, Object valueData ) throws KettleValueException {
 this.valueData = valueData;
 if ( valueData instanceof String ) {
  this.valueMeta = new ValueMetaString( valueName );
 } else if ( valueData instanceof Double ) {
  this.valueMeta = new ValueMetaNumber( valueName );
 } else if ( valueData instanceof Long ) {
  this.valueMeta = new ValueMetaInteger( valueName );
 } else if ( valueData instanceof Date ) {
  this.valueMeta = new ValueMetaDate( valueName, ValueMetaInterface.TYPE_DATE );
 } else if ( valueData instanceof BigDecimal ) {
  this.valueMeta = new ValueMetaBigNumber( valueName );
 } else if ( valueData instanceof Boolean ) {
  this.valueMeta = new ValueMetaBoolean( valueName );
 } else if ( valueData instanceof byte[] ) {
  this.valueMeta = new ValueMetaBinary( valueName );
 } else {
  this.valueMeta = new ValueMetaSerializable( valueName );
 }
}

代码示例来源:origin: pentaho/pentaho-kettle

@Test
public void getGetSignature_Number() {
 ValueMetaNumber v = new ValueMetaNumber( "Value" );
 String accessor = FieldHelper.getAccessor( true, "Value" );
 assertEquals( "Double Value = get(Fields.In, \"Value\").getDouble(r);", FieldHelper.getGetSignature( accessor, v ) );
 assertNotNull( getMethod( FieldHelper.class, "getDouble", Object[].class ) );
}

代码示例来源:origin: pentaho/pentaho-kettle

public synchronized ObjectId insertJobEntryAttribute( ObjectId id_job, ObjectId id_jobentry, long nr,
                           String code, double value_num, String value_str )
 throws KettleException {
 ObjectId id = getNextJobEntryAttributeID();
 RowMetaAndData table = new RowMetaAndData();
 //CHECKSTYLE:LineLength:OFF
 table
  .addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_ID_JOBENTRY_ATTRIBUTE ), id );
 table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_ID_JOB ), id_job );
 table
  .addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_ID_JOBENTRY ), id_jobentry );
 table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_NR ), new Long( nr ) );
 table.addValue( new ValueMetaString( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_CODE ), code );
 table.addValue( new ValueMetaNumber( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_VALUE_NUM ),
  new Double( value_num ) );
 table.addValue( new ValueMetaString( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_VALUE_STR ), value_str );
 database.prepareInsert( table.getRowMeta(), KettleDatabaseRepository.TABLE_R_JOBENTRY_ATTRIBUTE );
 database.setValuesInsert( table );
 database.insertRow();
 database.closeInsert();
 return id;
}

代码示例来源:origin: pentaho/pentaho-kettle

v = new ValueMetaNumber( fieldName[i], 10, 5 );
 break;
case TYPE_RANDOM_INTEGER:

代码示例来源:origin: pentaho/pentaho-kettle

data.bulkDateMeta.setStringEncoding( realEncoding );
data.bulkNumberMeta = new ValueMetaNumber( "numberMeta" );
data.bulkNumberMeta.setConversionMask( "#.#" );
data.bulkNumberMeta.setGroupingSymbol( "," );

代码示例来源:origin: pentaho/pentaho-kettle

public synchronized ObjectId insertStepAttribute( ObjectId id_transformation, ObjectId id_step, long nr,
                         String code, double value_num, String value_str )
 throws KettleException {
 ObjectId id = getNextStepAttributeID();
 RowMetaAndData table = new RowMetaAndData();
 table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_STEP_ATTRIBUTE_ID_STEP_ATTRIBUTE ), id );
 table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_STEP_ATTRIBUTE_ID_TRANSFORMATION ),
  id_transformation );
 table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_STEP_ATTRIBUTE_ID_STEP ), id_step );
 table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_STEP_ATTRIBUTE_NR ), new Long( nr ) );
 table.addValue( new ValueMetaString( KettleDatabaseRepository.FIELD_STEP_ATTRIBUTE_CODE ), code );
 table.addValue( new ValueMetaNumber( KettleDatabaseRepository.FIELD_STEP_ATTRIBUTE_VALUE_NUM ),
  new Double( value_num ) );
 table.addValue( new ValueMetaString( KettleDatabaseRepository.FIELD_STEP_ATTRIBUTE_VALUE_STR ), value_str );
 /*
  * If we have prepared the insert, we don't do it again. We assume that all the step insert statements come one
  * after the other.
  */
 if ( psStepAttributesInsert == null ) {
  String sql =
   database.getInsertStatement( KettleDatabaseRepository.TABLE_R_STEP_ATTRIBUTE, table.getRowMeta() );
  psStepAttributesInsert = database.prepareSQL( sql );
 }
 database.setValues( table, psStepAttributesInsert );
 database.insertRow( psStepAttributesInsert, useBatchProcessing );
 if ( log.isDebug() ) {
  log.logDebug( "saved attribute [" + code + "]" );
 }
 return id;
}

代码示例来源:origin: pentaho/pentaho-kettle

@Test
public void testNullsAreZeroDefault() throws Exception {
 variables.setVariable( Const.KETTLE_AGGREGATION_ALL_NULLS_ARE_ZERO, "Y" );
 addColumn( new ValueMetaInteger( "nul" ) );
 addColumn( new ValueMetaInteger( "both" ), -2L, 0L, null, 10L );
 addColumn( new ValueMetaNumber( "both_num" ), -2.0, 0.0, null, 10.0 );
 RowMetaAndData output = runStep();
 assertThat( output.getInteger( "nul_min" ), is( 0L ) );
 assertThat( output.getInteger( "nul_max" ), is( 0L ) );
 assertThat( output.getInteger( "nul_sum" ), is( 0L ) );
 assertThat( output.getInteger( "nul_ave" ), is( 0L ) );
 assertThat( output.getInteger( "nul_count" ), is( 0L ) );
 assertThat( output.getInteger( "nul_count_any" ), is( 4L ) );
 assertThat( output.getInteger( "nul_count_distinct" ), is( 0L ) );
 assertThat( output.getInteger( "both_max" ), is( 10L ) );
 assertThat( output.getInteger( "both_min" ), is( -2L ) );
 assertThat( output.getInteger( "both_sum" ), is( 8L ) );
 assertThat( output.getInteger( "both_ave" ), is( 2L ) );
 assertThat( output.getInteger( "both_count" ), is( 3L ) );
 assertThat( output.getInteger( "both_count_any" ), is( 4L ) );
 assertThat( output.getInteger( "both_count_distinct" ), is( 3L ) );
 assertThat( output.getNumber( "both_num_max", Double.NaN ), is( 10.0 ) );
 assertThat( output.getNumber( "both_num_min", Double.NaN ), is( -2.0 ) );
 assertThat( output.getNumber( "both_num_sum", Double.NaN ), is( 8.0 ) );
 assertEquals( 2.666666, output.getNumber( "both_num_ave", Double.NaN ), 0.000001 /* delta */ );
 assertThat( output.getInteger( "both_num_count" ), is( 3L ) );
 assertThat( output.getInteger( "both_num_count_any" ), is( 4L ) );
 assertThat( output.getInteger( "both_num_count_distinct" ), is( 3L ) );
}

代码示例来源:origin: pentaho/pentaho-kettle

data.monetTimeMeta.setStringEncoding( encoding );
data.monetNumberMeta = new ValueMetaNumber( "numberMeta" );
data.monetNumberMeta.setConversionMask( "#.#" );
data.monetNumberMeta.setGroupingSymbol( "," );

代码示例来源:origin: pentaho/pentaho-kettle

public void assertRound( final double expectedResult, final double value ) throws KettleException {
 RowMeta inputRowMeta = new RowMeta();
 ValueMetaNumber valueMeta = new ValueMetaNumber( "Value" );
 inputRowMeta.addValueMeta( valueMeta );
 RowSet inputRowSet = smh.getMockInputRowSet( new Object[] { value } );
 inputRowSet.setRowMeta( inputRowMeta );
 Calculator calculator = new Calculator( smh.stepMeta, smh.stepDataInterface, 0, smh.transMeta, smh.trans );
 calculator.addRowSetToInputRowSets( inputRowSet );
 calculator.setInputRowMeta( inputRowMeta );
 calculator.init( smh.initStepMetaInterface, smh.initStepDataInterface );
 CalculatorMeta meta = new CalculatorMeta();
 meta.setCalculation( new CalculatorMetaFunction[] { new CalculatorMetaFunction( "test",
   CalculatorMetaFunction.CALC_ROUND_1, "Value", null, null, ValueMetaInterface.TYPE_NUMBER, 2, 0, false, "", "",
   "", "" ) } );
 // Verify output
 try {
  calculator.addRowListener( new RowAdapter() {
   @Override
   public void rowWrittenEvent( RowMetaInterface rowMeta, Object[] row ) throws KettleStepException {
    assertEquals( expectedResult, row[1] );
   }
  } );
  calculator.processRow( meta, new CalculatorData() );
 } catch ( KettleException ke ) {
  ke.printStackTrace();
  fail();
 }
}

代码示例来源:origin: pentaho/pentaho-kettle

public void assertRoundStd( final double expectedResult, final double value ) throws KettleException {
 RowMeta inputRowMeta = new RowMeta();
 ValueMetaNumber valueMeta = new ValueMetaNumber( "Value" );
 inputRowMeta.addValueMeta( valueMeta );
 RowSet inputRowSet = smh.getMockInputRowSet( new Object[] { value } );
 inputRowSet.setRowMeta( inputRowMeta );
 Calculator calculator = new Calculator( smh.stepMeta, smh.stepDataInterface, 0, smh.transMeta, smh.trans );
 calculator.addRowSetToInputRowSets( inputRowSet );
 calculator.setInputRowMeta( inputRowMeta );
 calculator.init( smh.initStepMetaInterface, smh.initStepDataInterface );
 CalculatorMeta meta = new CalculatorMeta();
 meta.setCalculation( new CalculatorMetaFunction[] { new CalculatorMetaFunction( "test",
   CalculatorMetaFunction.CALC_ROUND_STD_1, "Value", null, null, ValueMetaInterface.TYPE_NUMBER, 2, 0, false, "",
   "", "", "" ) } );
 // Verify output
 try {
  calculator.addRowListener( new RowAdapter() {
   @Override
   public void rowWrittenEvent( RowMetaInterface rowMeta, Object[] row ) throws KettleStepException {
    assertEquals( expectedResult, row[1] );
   }
  } );
  calculator.processRow( meta, new CalculatorData() );
 } catch ( KettleException ke ) {
  ke.printStackTrace();
  fail();
 }
}

代码示例来源:origin: pentaho/pentaho-kettle

private RowMetaInterface getInputRowMeta() {
 RowMetaInterface rm = new RowMeta();
 rm.addValueMeta( new ValueMetaString( "myGroupField2" ) );
 rm.addValueMeta( new ValueMetaString( "myGroupField1" ) );
 rm.addValueMeta( new ValueMetaString( "myString" ) );
 rm.addValueMeta( new ValueMetaInteger( "myInteger" ) );
 rm.addValueMeta( new ValueMetaNumber( "myNumber" ) );
 rm.addValueMeta( new ValueMetaBigNumber( "myBigNumber" ) );
 rm.addValueMeta( new ValueMetaBinary( "myBinary" ) );
 rm.addValueMeta( new ValueMetaBoolean( "myBoolean" ) );
 rm.addValueMeta( new ValueMetaDate( "myDate" ) );
 rm.addValueMeta( new ValueMetaTimestamp( "myTimestamp" ) );
 rm.addValueMeta( new ValueMetaInternetAddress( "myInternetAddress" ) );
 return rm;
}
@Test

代码示例来源:origin: pentaho/pentaho-kettle

public void assertRoundStd2( final double expectedResult, final double value, final long precision )
 throws KettleException {
 RowMeta inputRowMeta = new RowMeta();
 ValueMetaNumber valueMeta = new ValueMetaNumber( "Value" );
 ValueMetaInteger precisionMeta = new ValueMetaInteger( "Precision" );
 inputRowMeta.addValueMeta( valueMeta );

代码示例来源:origin: pentaho/pentaho-kettle

public void assertRound2( final double expectedResult, final double value, final long precision )
 throws KettleException {
 RowMeta inputRowMeta = new RowMeta();
 ValueMetaNumber valueMeta = new ValueMetaNumber( "Value" );
 ValueMetaInteger precisionMeta = new ValueMetaInteger( "Precision" );
 inputRowMeta.addValueMeta( valueMeta );

相关文章

微信公众号

最新文章

更多

ValueMetaNumber类方法