Documentation ¶
Index ¶
- type CompressionType
- type Param
- type Splitter
- func (s *Splitter) Do(ctx context.Context, files []string, param Param) (retErr error)
- func (s *Splitter) ParallelFileScan(ctx context.Context, cancel func(), files []string, parallelism int, ...) (_ *errgroup.Group, retErr error)
- func (s *Splitter) ParallelScan(ctx context.Context, cancel func(), chIn <-chan readTarget, parallelism int, ...) (_ *errgroup.Group, retErr error)
- func (s *Splitter) ParallelWrite(ctx context.Context, cancel func(), chIn <-chan line, parallelism int, ...) (_ *errgroup.Group, retErr error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CompressionType ¶
type CompressionType int
const ( CompressionUnknown CompressionType = iota CompressionNone CompressionGzip )
func (CompressionType) String ¶
func (i CompressionType) String() string
type Splitter ¶
type Splitter struct {
// contains filtered or unexported fields
}
func NewSplitter ¶
func NewSplitter() *Splitter
func (*Splitter) ParallelFileScan ¶
func (*Splitter) ParallelScan ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.