-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
add implementation of weighted random
- Loading branch information
Yingyi Zhang
committed
Oct 26, 2017
1 parent
3d3980a
commit 152bc64
Showing
2 changed files
with
116 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,19 @@ | ||
import java.util.*; | ||
|
||
public class Main{ | ||
|
||
public static void main(String[] args){ | ||
WeightedRandom wr = new WeightedRandom(); | ||
wr.Insert("a", 4); | ||
wr.Insert("b", 2); | ||
wr.Insert("c", 1); | ||
wr.Insert("d", 3); | ||
wr.Update("c", 3); | ||
wr.Remove("c"); | ||
wr.Insert("e", 1); | ||
wr.Insert("f", 2); | ||
//wr.Update("d", 1); | ||
for(int i = 1; i <= 12; ++i) | ||
System.out.println(wr.GetRandom(i)); | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,97 @@ | ||
/* implement a data structure to store Object-Weight Pair | ||
* it should support operations as follows: | ||
* (1) Update | ||
* (2) Insert | ||
* (3) Remove | ||
* (4) GetRandom | ||
* The random probability = weight of Object / total sum of weights | ||
* Try to reduce time complexity of all operations. | ||
* */ | ||
import java.util.*; | ||
|
||
public class WeightedRandom{ // suppose the object-weight is String-int pair | ||
|
||
ArrayList<Integer> tree; | ||
int M; // smallest power of 2 which 2^N >= input size | ||
Queue<Integer> queue; // track available pos in leaf nodes | ||
HashMap<String, Integer> str2intMap; | ||
HashMap<Integer, String> int2strMap; | ||
public WeightedRandom(){ | ||
M = 2; | ||
tree = new ArrayList<Integer>(); | ||
queue = new LinkedList<Integer>(); | ||
str2intMap = new HashMap<String, Integer>(); | ||
int2strMap = new HashMap<Integer, String>(); | ||
for(int i = 0; i < M; ++i){ | ||
queue.offer(i); // add all available position into queue | ||
} | ||
for(int i = 0; i < 2*M; ++i) tree.add(0); // build tree with zero value | ||
} | ||
|
||
public void Insert(String str, int weight){ | ||
if(queue.isEmpty()) { | ||
resize(); | ||
System.out.println("Resize the tree. The input is " + str + ", " + weight); | ||
} | ||
int index = queue.poll(); | ||
str2intMap.put(str, index); | ||
int2strMap.put(index, str); // update two hashmaps | ||
index += M; | ||
int diff = weight; | ||
for(int i = index; i > 0; i >>= 1){ | ||
tree.set(i, tree.get(i) + diff); // update the tree | ||
} | ||
|
||
} | ||
|
||
public void Update(String str, int newWeight){ | ||
int index = str2intMap.get(str); | ||
int diff = newWeight - tree.get(index + M); | ||
for(int i = index + M; i > 0; i >>= 1){ | ||
tree.set(i, tree.get(i) + diff); | ||
} | ||
} | ||
|
||
public void Remove(String str){ | ||
int index = str2intMap.get(str); | ||
queue.offer(index); // add new avaiable position | ||
int diff = 0 - tree.get(index + M); | ||
for(int i = index + M; i > 0; i >>= 2){ | ||
tree.set(i, tree.get(i) + diff); | ||
} | ||
str2intMap.remove(str); | ||
int2strMap.remove(index); | ||
} | ||
|
||
public String GetRandom(int num){ | ||
int sum = tree.get(1); | ||
Random rand = new Random(); | ||
//int num = rand.nextInt(sum) + 1; // generate [1, sum] random number | ||
int i = 1; | ||
while(i < M){ | ||
i <<= 1; | ||
if(num > tree.get(i)) { | ||
num -= tree.get(i); | ||
i += 1; | ||
} | ||
} | ||
int index = i - M; | ||
return int2strMap.get(index); | ||
} | ||
|
||
public void resize(){ | ||
// extend current arrayList, double the size | ||
for(int i = 0; i < 2*M; ++i){ | ||
tree.add(0); | ||
if(i < M){ | ||
queue.offer(i + M); // add new available positions | ||
} | ||
} | ||
int offset = M; | ||
for(int i = 2*M -1 ; i > 0; --i){ | ||
tree.set(i + offset, tree.get(i)); | ||
if(i == offset) offset >>= 1; | ||
} | ||
M = M * 2; // update the number of elements in the tree | ||
} | ||
} |