join

package

v0.1.6 Latest Latest Go to latest Published: Feb 18, 2020 License: BSD-3-Clause Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/project-flogo/catalystml-flogo

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL