Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CsvAppBuilder ¶
type CsvAppBuilder interface {
Build(k uint32, cfg CsvParserAppConfig) CsvApp
}
type CsvParserApp ¶
type CsvParserApp struct {
// contains filtered or unexported fields
}
func NewCsvParserApp ¶
func NewCsvParserApp(k uint32, cfg CsvParserAppConfig) *CsvParserApp
NewCsvParserApp returns new CsvParserApp by k and config.
type CsvParserAppConfig ¶
type CsvParserAppConfig struct {
// Column index of entity(user/repo) ID from events.csv file.
EventsEntityColumnIndex int
// Column index of event type from events.csv file.
EventsEventTypeColumnIndex int
// Column index of entity(user/repo) ID from entity file (actors.csv, repos.csv).
EntityEntityColumnIndex int
// Column index of entity(user/repo) name from entity file (actors.csv, repos.csv).
EntityNameColumnIndex int
// Event types to filter.
EventTypes []string
// Reader of events.csv
EventsFileReader *csv.Reader
// Reader of entity file (actors.csv, repos.csv).
EntityFileReader *csv.Reader
// Writer to output the results.
Writer io.Writer
}
CsvParserAppConfig represents config values required to process csv file and entity file. There are 3 steps of this app, described in Run.
Click to show internal directories.
Click to hide internal directories.