join

README

join

Overview

Description

join two data objects like the Join command in SQL

Implementation details

Input left - map[string][]interface{} : map key is column name, map value are column values. Optional=False right - map[string][]interface{} : map key is column name, map value are column values. Optional=False leftindex - []string : index column names of first map. rightindex - []string : index column names. Params on - []string - either index or the column name. Optional=True Default= array of “index” how - [string] Options: left, right, inner, outer Optional=False

OutputType - [matrix or map]

Compliance to Spec

Rough level of compliance

100%

Documentation

Index

• func CheckDataFrame(val interface{}) (interface{}, error)
• func GetKey(indexColumn []string, tuple map[string]interface{}) common.Index
• func New(ctx operation.InitContext) (operation.Operation, error)
• type Input
  • func (i *Input) FromMap(values map[string]interface{}) error
• type Operation
  • func (operation *Operation) Eval(inputs map[string]interface{}) (interface{}, error)
• type Params

Functions

func CheckDataFrame

func CheckDataFrame(val interface{}) (interface{}, error)

func GetKey

func GetKey(indexColumn []string, tuple map[string]interface{}) common.Index

func New

func New(ctx operation.InitContext) (operation.Operation, error)

Types

type Input

type Input struct {
	Left       interface{} `md:"left"`
	Right      interface{} `md:"right"`
	LeftIndex  interface{} `md:"leftindex"`
	RightIndex interface{} `md:"rightindex"`
}

func (*Input) FromMap

func (i *Input) FromMap(values map[string]interface{}) error

type Operation

type Operation struct {
	// contains filtered or unexported fields
}

func (*Operation) Eval

func (operation *Operation) Eval(inputs map[string]interface{}) (interface{}, error)

type Params

type Params struct {
	On  []string `md:"on"`
	How string   `md:"how"`
}