@Test public void setCompressionType() { metaBase.setCompressionType( "snappy" ); Assert.assertTrue( metaBase.getCompressionType().equals( ParquetOutputMetaBase.CompressionType.SNAPPY.toString() ) ); metaBase.setCompressionType( "Snappy" ); Assert.assertTrue( metaBase.getCompressionType().equals( ParquetOutputMetaBase.CompressionType.SNAPPY.toString() ) ); metaBase.setCompressionType( "SNAPPY" ); Assert.assertTrue( metaBase.getCompressionType().equals( ParquetOutputMetaBase.CompressionType.SNAPPY.toString() ) ); metaBase.setCompressionType( "gzip" ); Assert.assertTrue( metaBase.getCompressionType().equals( ParquetOutputMetaBase.CompressionType.GZIP.toString() ) ); metaBase.setCompressionType( "Gzip" ); Assert.assertTrue( metaBase.getCompressionType().equals( ParquetOutputMetaBase.CompressionType.GZIP.toString() ) ); metaBase.setCompressionType( "GZIP" ); Assert.assertTrue( metaBase.getCompressionType().equals( ParquetOutputMetaBase.CompressionType.GZIP.toString() ) ); metaBase.setCompressionType( "None" ); Assert.assertTrue( metaBase.getCompressionType().equals( ParquetOutputMetaBase.CompressionType.NONE.toString() ) ); metaBase.setCompressionType( "none" ); Assert.assertTrue( metaBase.getCompressionType().equals( ParquetOutputMetaBase.CompressionType.NONE.toString() ) ); metaBase.setCompressionType( "NONE" ); Assert.assertTrue( metaBase.getCompressionType().equals( ParquetOutputMetaBase.CompressionType.NONE.toString() ) ); }
public void setCompressionType( String value ) { compressionType = StringUtil.isVariable( value ) ? value : parseFromToString( value, CompressionType.values(), CompressionType.NONE ).name(); }
ParquetOutputMetaBase extends BaseStepMeta implements StepMetaInterface, ResolvableResource { public void setCompressionType( String value ) { compressionType = StringUtil.isVariable( value ) ? value : parseFromToString( value, CompressionType.values(), CompressionType.NONE ).name(); } }
ParquetOutputMetaBase extends BaseStepMeta implements StepMetaInterface, ResolvableResource { public void setCompressionType( String value ) { compressionType = StringUtil.isVariable( value ) ? value : parseFromToString( value, CompressionType.values(), CompressionType.NONE ).name(); }  }
ParquetOutputMetaBase extends BaseStepMeta implements StepMetaInterface, ResolvableResource { public void setCompressionType( String value ) { compressionType = StringUtil.isVariable( value ) ? value : parseFromToString( value, CompressionType.values(), CompressionType.NONE ).name(); }  @Override void setDefault(); String getFilename(); void setFilename( String filename ); boolean isEnableDictionary(); void setEnableDictionary( boolean enableDictionary ); boolean isOverrideOutput(); void setOverrideOutput( boolean overrideOutput ); boolean isDateInFilename(); void setDateInFilename( boolean dateInFilename ); boolean isTimeInFilename(); void setTimeInFilename( boolean timeInFilename ); String getDateTimeFormat(); void setDateTimeFormat( String dateTimeFormat ); String getExtension(); void setExtension( String extension ); List<ParquetOutputField> getOutputFields(); void setOutputFields( List<ParquetOutputField> outputFields ); @Override void loadXML( Node stepnode, List<DatabaseMeta> databases, IMetaStore metaStore ); @Override String getXML(); @Override void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ); @Override void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_transformation, ObjectId id_step ); @Override void resolve(); String constructOutputFilename(); int getRowGroupSize( VariableSpace vspace ); String getRowGroupSize(); void setRowGroupSize( String value ); String getCompressionType(); void setCompressionType( String value ); CompressionType getCompressionType( VariableSpace vspace ); String getParquetVersion(); void setParquetVersion( String value ); ParquetVersion getParquetVersion( VariableSpace vspace ); int getDataPageSize( VariableSpace vspace ); String getDataPageSize(); void setDataPageSize( String dataPageSize ); int getDictPageSize( VariableSpace vspace ); String getDictPageSize(); void setDictPageSize( String dictPageSize ); String[] getCompressionTypes(); String[] getVersionTypes(); }
ParquetOutputMetaBase extends BaseStepMeta implements StepMetaInterface, ResolvableResource { public void setCompressionType( String value ) { compressionType = StringUtil.isVariable( value ) ? value : parseFromToString( value, CompressionType.values(), CompressionType.NONE ).name(); }  @Override void setDefault(); String getFilename(); void setFilename( String filename ); boolean isEnableDictionary(); void setEnableDictionary( boolean enableDictionary ); boolean isOverrideOutput(); void setOverrideOutput( boolean overrideOutput ); boolean isDateInFilename(); void setDateInFilename( boolean dateInFilename ); boolean isTimeInFilename(); void setTimeInFilename( boolean timeInFilename ); String getDateTimeFormat(); void setDateTimeFormat( String dateTimeFormat ); String getExtension(); void setExtension( String extension ); List<ParquetOutputField> getOutputFields(); void setOutputFields( List<ParquetOutputField> outputFields ); @Override void loadXML( Node stepnode, List<DatabaseMeta> databases, IMetaStore metaStore ); @Override String getXML(); @Override void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ); @Override void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_transformation, ObjectId id_step ); @Override void resolve(); String constructOutputFilename(); int getRowGroupSize( VariableSpace vspace ); String getRowGroupSize(); void setRowGroupSize( String value ); String getCompressionType(); void setCompressionType( String value ); CompressionType getCompressionType( VariableSpace vspace ); String getParquetVersion(); void setParquetVersion( String value ); ParquetVersion getParquetVersion( VariableSpace vspace ); int getDataPageSize( VariableSpace vspace ); String getDataPageSize(); void setDataPageSize( String dataPageSize ); int getDictPageSize( VariableSpace vspace ); String getDictPageSize(); void setDictPageSize( String dictPageSize ); String[] getCompressionTypes(); String[] getVersionTypes(); @Injection( name = "COMPRESSION" )
  public String compressionType; @Injection( name = "PARQUET_VERSION" )
  public String parquetVersion; @Injection( name = "ROW_GROUP_SIZE" )
  public String rowGroupSize; @Injection( name = "DATA_PAGE_SIZE" )
  public String dataPageSize; @Injection( name = "ENABLE_DICTIONARY" )
  public boolean enableDictionary; @Injection( name = "DICT_PAGE_SIZE" )
  public String dictPageSize; @Injection( name = "OVERRIDE_OUTPUT" )
  public boolean overrideOutput; @Injection( name = "FILENAME", group = "FILENAME_LINES" )
  public String filename; }