filehandler

Documentation

Index

• Constants
• func NewParquetReader(pFile source.ParquetFile, obj interface{}, np int64) (*reader.ParquetReader, error)
• type Case
• type GZIPLocalFileHandler
  • func NewGZIPLocalFileHandler(casing Case) *GZIPLocalFileHandler
  • func (h *GZIPLocalFileHandler) Read(_ context.Context, path string) error
  • func (h *GZIPLocalFileHandler) RemoveIdentity(ctx context.Context, attributes []model.User) error
  • func (h *GZIPLocalFileHandler) Write(_ context.Context, path string) error
• type LocalFileHandler
• type ParquetLocalFileHandler
  • func NewParquetLocalFileHandler() *ParquetLocalFileHandler
  • func (h *ParquetLocalFileHandler) Read(_ context.Context, path string) error
  • func (h *ParquetLocalFileHandler) RemoveIdentity(_ context.Context, attributes []model.User) error
  • func (h *ParquetLocalFileHandler) Write(_ context.Context, path string) error

Constants

const (
	SnakeCase = iota
	CamelCase
	UpperCase
)

Functions

func NewParquetReader

func NewParquetReader(pFile source.ParquetFile, obj interface{}, np int64) (*reader.ParquetReader, error)

Types

type Case

type Case uint

type GZIPLocalFileHandler

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

func NewGZIPLocalFileHandler

func NewGZIPLocalFileHandler(casing Case) *GZIPLocalFileHandler

func (*GZIPLocalFileHandler) Read

func (h *GZIPLocalFileHandler) Read(_ context.Context, path string) error

func (*GZIPLocalFileHandler) RemoveIdentity

func (h *GZIPLocalFileHandler) RemoveIdentity(ctx context.Context, attributes []model.User) error

func (*GZIPLocalFileHandler) Write

func (h *GZIPLocalFileHandler) Write(_ context.Context, path string) error

type LocalFileHandler

type LocalFileHandler interface {
	Read(ctx context.Context, path string) error
	RemoveIdentity(ctx context.Context, attributes []model.User) error
	Write(ctx context.Context, path string) error
}

type ParquetLocalFileHandler

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

func NewParquetLocalFileHandler

func NewParquetLocalFileHandler() *ParquetLocalFileHandler

func (*ParquetLocalFileHandler) Read

func (h *ParquetLocalFileHandler) Read(_ context.Context, path string) error

func (*ParquetLocalFileHandler) RemoveIdentity

func (h *ParquetLocalFileHandler) RemoveIdentity(_ context.Context, attributes []model.User) error

func (*ParquetLocalFileHandler) Write

func (h *ParquetLocalFileHandler) Write(_ context.Context, path string) error