Skip to content

这是一个用Go语言实现的pipeline并行处理管道

Notifications You must be signed in to change notification settings

wxning1107/pipeline

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

5 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Pipeline

Pipeline is a simple pipeline written in Go. It builds a parallel processing pipeline in Go language to realize an external sort pipeline.

Introduction

Pipeline reads the data source from the file(stdin/stdout). The reading is in blocks. Using internal sorting to sort each block. And then merge them two by two.

Each merged node is sorted for big data. Then merging them two by two. And finally it will be written to the file.

Finally, the final version provides external services for external sort.

Document introduction

pipeline introduction

About

这是一个用Go语言实现的pipeline并行处理管道

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages