Skip to content

Instantly share code, notes, and snippets.

View AnkitKiet's full-sized avatar
🎯
Focusing

Ankit Maurya AnkitKiet

🎯
Focusing
View GitHub Profile
@Benchmark
public void C3_hugeListStreamPartitioned() {
final List<List<Integer>> result = list.stream()
.collect(partitioned(chunkSize));
assertThat(result).hasSize(expectedSize);
assertThat(result.get(chunkIndex)).isEqualTo(expectedChunk);
}
@Benchmark
public final class Partition<T> extends AbstractList<List<T>> {
private final List<T> list;
private final int chunkSize;
public Partition(List<T> list, int chunkSize) {
this.list = new ArrayList<>(list);
this.chunkSize = chunkSize;
}
@Benchmark
public void A3_smallListStreamPartitioned() {
final List<List<Integer>> result = list.stream()
.collect(partitioned(chunkSize));
assertThat(result).hasSize(partitionedSize);
assertThat(result.get(chunkIndex)).isEqualTo(expectedChunk);
}
@Benchmark
public void A4_smallListToPartition() {
private static final int LIST_SIZE = 20;
private int chunkSize;
private List<Integer> expectedChunk;
private int chunkIndex;
private int partitionedSize;
private static final List<Integer> list = IntStream.range(0, LIST_SIZE + random.nextInt(13)).boxed().collect(toList());
@Setup(Level.Iteration)
public void setup() {
import edu.optimization.imageupload.entity.Image;
import edu.optimization.imageupload.service.ImageService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.env.Environment;
import org.springframework.core.io.ByteArrayResource;
import org.springframework.core.io.Resource;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
@AnkitKiet
AnkitKiet / SubReducer.java
Last active September 8, 2019 12:06
Upgrad Partitioner
package com.upgrad.average;
import java.io.IOException;
import org.apache.hadoop.io.FloatWritable;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;
import java.util.BitSet;
/*
* @author: Ankit.Maurya
*/
public class BloomFilter {
BitSet bitset = null;
int numOfHashFun;
import java.util.HashMap;
import java.util.Map.Entry;
class Record {
String name;
long number;
}
public class HashDictionary {
@AnkitKiet
AnkitKiet / DemoChild.java
Last active May 22, 2019 16:40
upgrad-constructor-demo
import java.util.Arrays;
public class DemoChild extends DemoConstructor {
public DemoChild(int[] array) {
super(array);
System.out.println("Child" + Arrays.toString(array));
}
public static void main(String[] args) {
console.log(new Date().getTime() + (5*60*60*1000)+(30*60*1000));
var d = new Date(new Date().getTime() + (5*60*60*1000)+(30*60*1000)); // Calculationsa are to convert into IST
console.log(d.toISOString().replace('T',' ').substring(0,19));