merge

Documentation

Index

• func New(mergeFunc string) (map[string]Func, error)
• func ToBlock(input interface{}) ([]byte, error)
• func ToOrc(input interface{}) ([]byte, error)
• func ToParquet(input interface{}) ([]byte, error)
• type Func

Functions

func New

func New(mergeFunc string) (map[string]Func, error)

New creates a new merge function

func ToBlock

func ToBlock(input interface{}) ([]byte, error)

ToBlock merges multiple blocks together and outputs merged Block bytes

func ToOrc

func ToOrc(input interface{}) ([]byte, error)

ToOrc merges multiple blocks together and outputs a key and merged orc data

func ToParquet

func ToParquet(input interface{}) ([]byte, error)

ToParquet merges multiple blocks together and outputs a key and merged Parquet data

Types

type Func

type Func func(interface{}) ([]byte, error)

Func represents merge function