Class ETLUtils


  • public class ETLUtils
    extends java.lang.Object
    • Constructor Summary

      Constructors 
      Constructor Description
      ETLUtils()  
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static org.apache.avro.Schema getValueSchemaFromETLValueSchema​(org.apache.avro.Schema etlValueSchema, ETLValueSchemaTransformation transformation)
      Get the store's value schema from it's value schema in the ETL output and the transformation that was applied to construct it.
      static org.apache.avro.Schema transformValueSchemaForETL​(org.apache.avro.Schema valueSchema)
      Modify a store value schema to the value schema that can be used for ETL by allowing "null" values to be set
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • ETLUtils

        public ETLUtils()
    • Method Detail

      • transformValueSchemaForETL

        public static org.apache.avro.Schema transformValueSchemaForETL​(org.apache.avro.Schema valueSchema)
        Modify a store value schema to the value schema that can be used for ETL by allowing "null" values to be set
        Parameters:
        valueSchema - The store's value schema
        Returns:
        A schema that can be used for ETL by allowing "null" values to be set
      • getValueSchemaFromETLValueSchema

        public static org.apache.avro.Schema getValueSchemaFromETLValueSchema​(org.apache.avro.Schema etlValueSchema,
                                                                              ETLValueSchemaTransformation transformation)
        Get the store's value schema from it's value schema in the ETL output and the transformation that was applied to construct it.
        Parameters:
        etlValueSchema - Schema of the "value" field in the ETL data.
        transformation - The transformation that was applied to construct the schema of the "value" field in ETL data from the store's value schema.
        Returns:
        The store's value schema that would have been used to construct the schema of "value" field in ETL data.