dataframe

package module

Go to main page

Versions in this module

v1

v1.0.8

Aug 16, 2024

Changes in this version

type DataFrame

+ func (frame *DataFrame) AddRecordByReference(newData []string)

+ func (frame DataFrame) Where(fieldName, operator, value string) DataFrame

v1.0.7

Nov 30, 2023

v1.0.6

Nov 30, 2023

v1.0.5

Oct 18, 2023

Changes in this version

type DataFrame

+ func (frame *DataFrame) ColumnVal(fieldName string, headers map[string]int) []string

+ func (frame *DataFrame) SortByColumns(columns []string, sortOrderAscending bool)

type Record

+ func (x Record) SafeConvertToFloat(fieldName string, headers map[string]int) (float64, error)

+ func (x Record) SafeConvertToInt(fieldName string, headers map[string]int) (int64, error)

+ func (x Record) SafeUpdate(fieldName, value string, headers map[string]int) error

+ func (x Record) SafeVal(fieldName string, headers map[string]int) (string, error)

v1.0.2

Jul 13, 2023

Changes in this version

type DataFrame

+ func Merge(dfs ...DataFrame) (DataFrame, error)

+ func (frame *DataFrame) Sort(columnName string)

v1.0.0

Jul 11, 2023

Changes in this version

+ func Stream(path, fileName string, c chan StreamingRecord)

+ func UploadFileToAwsS3(path, filename, bucket, region string) error

+ type DataFrame struct

+ FrameRecords []Record

+ Headers map[string]int

+ func CreateDataFrame(path, fileName string) DataFrame

+ func CreateDataFrameFromAwsS3(path, item, bucket, region, awsAccessKey, awsSecretKey string) DataFrame

+ func CreateDataFrameFromBytes(b []byte) DataFrame

+ func CreateDataFrameFromCsvReader(reader *csv.Reader) DataFrame

+ func CreateNewDataFrame(headers []string) DataFrame

+ func LoadFrames(filePath string, files []string) ([]DataFrame, error)

+ func (frame *DataFrame) Average(fieldName string) float64

+ func (frame *DataFrame) CountRecords() int

+ func (frame *DataFrame) Max(fieldName string) float64

+ func (frame *DataFrame) Min(fieldName string) float64

+ func (frame *DataFrame) NewField(fieldName string)

+ func (frame *DataFrame) Rename(originalColumnName, newColumnName string) error

+ func (frame *DataFrame) SaveDataFrame(path, fileName string) bool

+ func (frame *DataFrame) StandardDeviation(fieldName string) (float64, error)

+ func (frame *DataFrame) Sum(fieldName string) float64

+ func (frame *DataFrame) Unique(fieldName string) []string

+ func (frame DataFrame) AddRecord(newData []string) DataFrame

+ func (frame DataFrame) Columns() []string

+ func (frame DataFrame) ConcatFrames(dfNew *DataFrame) (DataFrame, error)

+ func (frame DataFrame) Copy() DataFrame

+ func (frame DataFrame) Exclude(fieldName string, value ...string) DataFrame

+ func (frame DataFrame) Filtered(fieldName string, value ...string) DataFrame

+ func (frame DataFrame) FilteredAfter(fieldName, desiredDate string) DataFrame

+ func (frame DataFrame) FilteredBefore(fieldName, desiredDate string) DataFrame

+ func (frame DataFrame) FilteredBetween(fieldName, startDate, endDate string) DataFrame

+ func (frame DataFrame) GreaterThanOrEqualTo(fieldName string, value float64) (DataFrame, error)

+ func (frame DataFrame) InnerMerge(dfRight *DataFrame, primaryKey string) DataFrame

+ func (frame DataFrame) KeepColumns(columns []string) DataFrame

+ func (frame DataFrame) LessThanOrEqualTo(fieldName string, value float64) (DataFrame, error)

+ func (frame DataFrame) Merge(dfRight *DataFrame, primaryKey string, columns ...string)

+ func (frame DataFrame) RemoveColumns(columns ...string) DataFrame

+ func (frame DataFrame) ViewColumns()

+ type Record struct

+ Data []string

+ func (x Record) ConvertToDate(fieldName string, headers map[string]int) time.Time

+ func (x Record) ConvertToFloat(fieldName string, headers map[string]int) float64

+ func (x Record) ConvertToInt(fieldName string, headers map[string]int) int64

+ func (x Record) Update(fieldName, value string, headers map[string]int)

+ func (x Record) Val(fieldName string, headers map[string]int) string

+ type StreamingRecord struct

+ Data []string

+ Headers map[string]int

+ func (x StreamingRecord) ConvertToFloat(fieldName string) float64

+ func (x StreamingRecord) ConvertToInt(fieldName string) int64

+ func (x StreamingRecord) Val(fieldName string) string

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