Package io.aiven.kafka.connect.common.output.parquet

Class ParquetConfig

java.lang.Object
org.apache.kafka.common.config.AbstractConfig
io.aiven.kafka.connect.common.output.parquet.ParquetConfig
public final class ParquetConfig extends org.apache.kafka.common.config.AbstractConfig

  • Field Summary

    Fields inherited from class org.apache.kafka.common.config.AbstractConfig

    CONFIG_PROVIDERS_CONFIG

  • Constructor Summary

    Constructors
    Constructor
    Description
    ParquetConfig(Map<?,?> originals)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.parquet.hadoop.metadata.CompressionCodecName
    compressionCodecName()
     
    static org.apache.parquet.hadoop.metadata.CompressionCodecName
    compressionCodecName(CompressionType compressionType)
     
    org.apache.hadoop.conf.Configuration
    parquetConfiguration()
     

    Methods inherited from class org.apache.kafka.common.config.AbstractConfig

    documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ParquetConfig

      public ParquetConfig(Map<?,?> originals)

  • Method Details

    • parquetConfiguration

      public org.apache.hadoop.conf.Configuration parquetConfiguration()

    • compressionCodecName

      public org.apache.parquet.hadoop.metadata.CompressionCodecName compressionCodecName()

    • compressionCodecName

      public static org.apache.parquet.hadoop.metadata.CompressionCodecName compressionCodecName(CompressionType compressionType)