MaxCountIPAnswer

package

v1.1.0 Latest Latest Go to latest Published: Jun 30, 2022 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ncghost1/MassDataProcessingDemo

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (
	IPMod = 256
)

Variables ¶

View Source

var (
	NumPartFile = uint64(100)
)

NumPartFile: Number of partition file （小文件/分割文件数量） partFile: An array that holds pointers to partition files (存放指向小文件的文件指针的数组） partMaxVal: A map that stores the maximum count of IP in each partition file and its count （保存每个小文件中出现次数最多的 IP 和它的次数的 map） srcPath: Source file path 源文件（大文件）路径 partPathPrefix: partition path prefix 小文件的路径前缀

Functions ¶

func GenerateBigFile ¶

func GenerateBigFile(Row int)

func GenerateIP ¶

func GenerateIP() string

func GetPartMax ¶

func GetPartMax()

func RemoveAndClosePartFile ¶

func RemoveAndClosePartFile()

func SplitBigFile ¶

func SplitBigFile(NumPartFile uint64)

Types ¶

type Item ¶

type Item struct {
	IP string
	// contains filtered or unexported fields
}

func GetMax ¶

func GetMax() Item

type ItemHeap ¶

type ItemHeap []Item

func (ItemHeap) Len ¶

func (h ItemHeap) Len() int

func (ItemHeap) Less ¶

func (h ItemHeap) Less(i, j int) bool

func (*ItemHeap) Pop ¶

func (h *ItemHeap) Pop() interface{}

func (*ItemHeap) Push ¶

func (h *ItemHeap) Push(val interface{})

func (ItemHeap) Swap ¶

func (h ItemHeap) Swap(i, j int)

Source Files ¶

View all Source files

MaxCountIP.go

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