hashmap

type HashMap interface {
	// HasNull returns whether the hash map considers the null values.
	HasNull() bool
	// Free method frees the hash map.
	Free()
	// AddGroup adds 1 to the row count of hash map.
	AddGroup()
	// AddGroups adds N to the row count of hash map.
	AddGroups(uint64)
	// GroupCount returns the hash map's row count.
	GroupCount() uint64
	// Size returns the hash map's size
	Size() int64
	// MarshalBinary serializes the hash map into a byte slice.
	MarshalBinary() ([]byte, error)
	// UnmarshalBinary deserializes a byte slice into the hash map.
	UnmarshalBinary(data []byte, mp *mpool.MPool) error
	// WriteTo serializes the hash map to a writer.
	WriteTo(w io.Writer) (int64, error)
	// UnmarshalFrom deserializes a byte slice from a reader.
	UnmarshalFrom(r io.Reader, mp *mpool.MPool) (int64, error)
	// FillGroupHashes appends all group hash codes into dst and returns the result.
	FillGroupHashes(dst []uint64) []uint64
}

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

type Iterator interface {
	// not safe for multi parallel!!!!
	// Insert vecs[start, start+count) into hashmap
	// vs  : the number of rows corresponding to each value in the hash table (start with 1)
	// zvs : if zvs[i] is 0 indicates the presence null, 1 indicates the absence of a null.
	Insert(start, count int, vecs []*vector.Vector) (vs []uint64, zvs []int64, err error)

	// not safe for multi parallel!!!!
	// Insert a row from multiple columns into the hashmap, return true if it is new, otherwise false
	DetectDup(vecs []*vector.Vector, row int) (bool, error)

	//safe for multi parallel
	// Find vecs[start, start+count) in hashmap
	// vs  : the number of rows corresponding to each value in the hash table (start with 1, and 0 means not found.)
	// zvs : if zvs[i] is 0 indicates the presence null, 1 indicates the absence of a null.
	Find(start, count int, vecs []*vector.Vector) (vs []uint64, zvs []int64)
}

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