ETLUtils (venice API)

java.lang.Object

com.linkedin.venice.etl.ETLUtils

public class ETLUtils extends Object

Constructor Summary

Constructors

Constructor

Description

ETLUtils()
Method Summary

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 Details
- ETLUtils
  
  public ETLUtils()
Method Details
- 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.