@Test public void getXmlTest() { metaBase.getXML(); verify( embedManager ).registerUrl( anyString() ); }
@Override public String getXML() { StringBuilder retval = new StringBuilder( 800 ); final String INDENT = " "; retval.append( INDENT ).append( XMLHandler.addTagValue( FILE_NAME, filename ) ); parentStepMeta.getParentTransMeta().getNamedClusterEmbedManager().registerUrl( filename ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.OVERRIDE_OUTPUT, overrideOutput ) ); retval.append( " <fields>" ).append( Const.CR ); for ( int i = 0; i < outputFields.size(); i++ ) { AvroOutputField field = outputFields.get( i ); if ( field.getPentahoFieldName() != null && field.getPentahoFieldName().length() != 0 ) { retval.append( " <field>" ).append( Const.CR ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "path", field.getFormatFieldName() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "name", field.getPentahoFieldName() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "type", field.getAvroType().getId() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( PRECISION, field.getPrecision() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( SCALE, field.getScale() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( NULLABLE, field.getAllowNull() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( DEFAULT, field.getDefaultValue() ) ); retval.append( " </field>" ).append( Const.CR ); } } retval.append( " </fields>" ).append( Const.CR ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.COMPRESSION, compressionType ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DATE_FORMAT, dateTimeFormat ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DATE_IN_FILE_NAME, dateInFileName ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.TIME_IN_FILE_NAME, timeInFileName ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.SCHEMA_FILENAME, schemaFilename ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.NAMESPACE, namespace ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DOC_VALUE, docValue ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.RECORD_NAME, recordName ) ); return retval.toString(); }
AvroOutputMetaBase extends BaseStepMeta implements StepMetaInterface,  ResolvableResource { @Override public String getXML() { StringBuilder retval = new StringBuilder( 800 ); final String INDENT = " "; retval.append( INDENT ).append( XMLHandler.addTagValue( FILE_NAME, filename ) ); parentStepMeta.getParentTransMeta().getNamedClusterEmbedManager().registerUrl( filename ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.OVERRIDE_OUTPUT, overrideOutput ) ); retval.append( " <fields>" ).append( Const.CR ); for ( int i = 0; i < outputFields.size(); i++ ) { AvroOutputField field = outputFields.get( i ); if ( field.getPentahoFieldName() != null && field.getPentahoFieldName().length() != 0 ) { retval.append( " <field>" ).append( Const.CR ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "path", field.getFormatFieldName() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "name", field.getPentahoFieldName() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "type", field.getAvroType().getId() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( PRECISION, field.getPrecision() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( SCALE, field.getScale() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( NULLABLE, field.getAllowNull() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( DEFAULT, field.getDefaultValue() ) ); retval.append( " </field>" ).append( Const.CR ); } } retval.append( " </fields>" ).append( Const.CR ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.COMPRESSION, compressionType ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DATE_FORMAT, dateTimeFormat ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DATE_IN_FILE_NAME, dateInFileName ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.TIME_IN_FILE_NAME, timeInFileName ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.SCHEMA_FILENAME, schemaFilename ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.NAMESPACE, namespace ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DOC_VALUE, docValue ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.RECORD_NAME, recordName ) ); return retval.toString(); } }
AvroOutputMetaBase extends BaseStepMeta implements StepMetaInterface,  ResolvableResource { @Override public String getXML() { StringBuilder retval = new StringBuilder( 800 ); final String INDENT = " "; retval.append( INDENT ).append( XMLHandler.addTagValue( FILE_NAME, filename ) ); parentStepMeta.getParentTransMeta().getNamedClusterEmbedManager().registerUrl( filename ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.OVERRIDE_OUTPUT, overrideOutput ) ); retval.append( " <fields>" ).append( Const.CR ); for ( int i = 0; i < outputFields.size(); i++ ) { AvroOutputField field = outputFields.get( i ); if ( field.getPentahoFieldName() != null && field.getPentahoFieldName().length() != 0 ) { retval.append( " <field>" ).append( Const.CR ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "path", field.getFormatFieldName() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "name", field.getPentahoFieldName() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "type", field.getAvroType().getId() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( PRECISION, field.getPrecision() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( SCALE, field.getScale() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( NULLABLE, field.getAllowNull() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( DEFAULT, field.getDefaultValue() ) ); retval.append( " </field>" ).append( Const.CR ); } } retval.append( " </fields>" ).append( Const.CR ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.COMPRESSION, compressionType ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DATE_FORMAT, dateTimeFormat ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DATE_IN_FILE_NAME, dateInFileName ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.TIME_IN_FILE_NAME, timeInFileName ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.SCHEMA_FILENAME, schemaFilename ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.NAMESPACE, namespace ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DOC_VALUE, docValue ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.RECORD_NAME, recordName ) ); return retval.toString(); }  }
AvroOutputMetaBase extends BaseStepMeta implements StepMetaInterface,  ResolvableResource { @Override public String getXML() { StringBuilder retval = new StringBuilder( 800 ); final String INDENT = " "; retval.append( INDENT ).append( XMLHandler.addTagValue( FILE_NAME, filename ) ); parentStepMeta.getParentTransMeta().getNamedClusterEmbedManager().registerUrl( filename ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.OVERRIDE_OUTPUT, overrideOutput ) ); retval.append( " <fields>" ).append( Const.CR ); for ( int i = 0; i < outputFields.size(); i++ ) { AvroOutputField field = outputFields.get( i ); if ( field.getPentahoFieldName() != null && field.getPentahoFieldName().length() != 0 ) { retval.append( " <field>" ).append( Const.CR ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "path", field.getFormatFieldName() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "name", field.getPentahoFieldName() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "type", field.getAvroType().getId() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( PRECISION, field.getPrecision() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( SCALE, field.getScale() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( NULLABLE, field.getAllowNull() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( DEFAULT, field.getDefaultValue() ) ); retval.append( " </field>" ).append( Const.CR ); } } retval.append( " </fields>" ).append( Const.CR ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.COMPRESSION, compressionType ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DATE_FORMAT, dateTimeFormat ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DATE_IN_FILE_NAME, dateInFileName ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.TIME_IN_FILE_NAME, timeInFileName ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.SCHEMA_FILENAME, schemaFilename ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.NAMESPACE, namespace ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DOC_VALUE, docValue ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.RECORD_NAME, recordName ) ); return retval.toString(); }  @Override void setDefault(); boolean isOverrideOutput(); void setOverrideOutput( boolean overrideOutput ); String getFilename(); void setFilename( String filename ); List<AvroOutputField> getOutputFields(); void setOutputFields( List<AvroOutputField> outputFields ); boolean isDateInFileName(); void setDateInFileName( boolean dateInFileName ); boolean isTimeInFileName(); void setTimeInFileName( boolean timeInFileName ); String getDateTimeFormat(); void setDateTimeFormat( String dateTimeFormat ); @Override void loadXML( Node stepnode, List<DatabaseMeta> databases, IMetaStore metaStore ); @Override String getXML(); @Override void readRep( Repository rep, IMetaStore metaStore, ObjectId stepId, List<DatabaseMeta> databases ); @Override void saveRep( Repository rep, IMetaStore metaStore, ObjectId transformationId, ObjectId stepId ); @Override void resolve(); String getSchemaFilename(); void setSchemaFilename( String schemaFilename ); String getNamespace(); void setNamespace( String namespace ); String getRecordName(); void setRecordName( String recordName ); String getDocValue(); void setDocValue( String docValue ); String getCompressionType(); void setCompressionType( String value ); CompressionType getCompressionType( VariableSpace vspace ); String[] getCompressionTypes(); String constructOutputFilename( String file ); }
AvroOutputMetaBase extends BaseStepMeta implements StepMetaInterface,  ResolvableResource { @Override public String getXML() { StringBuilder retval = new StringBuilder( 800 ); final String INDENT = " "; retval.append( INDENT ).append( XMLHandler.addTagValue( FILE_NAME, filename ) ); parentStepMeta.getParentTransMeta().getNamedClusterEmbedManager().registerUrl( filename ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.OVERRIDE_OUTPUT, overrideOutput ) ); retval.append( " <fields>" ).append( Const.CR ); for ( int i = 0; i < outputFields.size(); i++ ) { AvroOutputField field = outputFields.get( i ); if ( field.getPentahoFieldName() != null && field.getPentahoFieldName().length() != 0 ) { retval.append( " <field>" ).append( Const.CR ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "path", field.getFormatFieldName() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "name", field.getPentahoFieldName() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( "type", field.getAvroType().getId() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( PRECISION, field.getPrecision() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( SCALE, field.getScale() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( NULLABLE, field.getAllowNull() ) ); retval.append( SPACES_8 ).append( XMLHandler.addTagValue( DEFAULT, field.getDefaultValue() ) ); retval.append( " </field>" ).append( Const.CR ); } } retval.append( " </fields>" ).append( Const.CR ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.COMPRESSION, compressionType ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DATE_FORMAT, dateTimeFormat ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DATE_IN_FILE_NAME, dateInFileName ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.TIME_IN_FILE_NAME, timeInFileName ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.SCHEMA_FILENAME, schemaFilename ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.NAMESPACE, namespace ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.DOC_VALUE, docValue ) ); retval.append( INDENT ).append( XMLHandler.addTagValue( FieldNames.RECORD_NAME, recordName ) ); return retval.toString(); }  @Override void setDefault(); boolean isOverrideOutput(); void setOverrideOutput( boolean overrideOutput ); String getFilename(); void setFilename( String filename ); List<AvroOutputField> getOutputFields(); void setOutputFields( List<AvroOutputField> outputFields ); boolean isDateInFileName(); void setDateInFileName( boolean dateInFileName ); boolean isTimeInFileName(); void setTimeInFileName( boolean timeInFileName ); String getDateTimeFormat(); void setDateTimeFormat( String dateTimeFormat ); @Override void loadXML( Node stepnode, List<DatabaseMeta> databases, IMetaStore metaStore ); @Override String getXML(); @Override void readRep( Repository rep, IMetaStore metaStore, ObjectId stepId, List<DatabaseMeta> databases ); @Override void saveRep( Repository rep, IMetaStore metaStore, ObjectId transformationId, ObjectId stepId ); @Override void resolve(); String getSchemaFilename(); void setSchemaFilename( String schemaFilename ); String getNamespace(); void setNamespace( String namespace ); String getRecordName(); void setRecordName( String recordName ); String getDocValue(); void setDocValue( String docValue ); String getCompressionType(); void setCompressionType( String value ); CompressionType getCompressionType( VariableSpace vspace ); String[] getCompressionTypes(); String constructOutputFilename( String file );  }