From c50dec3fcfe1939ced008813621d88739c29cc3b Mon Sep 17 00:00:00 2001
From: Mahima0312 <48762483+Mahima0312@users.noreply.github.com>
Date: Thu, 24 Oct 2019 23:25:43 +0530
Subject: [PATCH] Create [MedianOfRunningStream]_<Mahima0312>.java

---
 .../[MedianOfRunningStream]_<Mahima0312>.java | 67 +++++++++++++++++++
 1 file changed, 67 insertions(+)
 create mode 100644 java/[MedianOfRunningStream]_<Mahima0312>.java

diff --git a/java/[MedianOfRunningStream]_<Mahima0312>.java b/java/[MedianOfRunningStream]_<Mahima0312>.java
new file mode 100644
index 0000000..e2509ca
--- /dev/null
+++ b/java/[MedianOfRunningStream]_<Mahima0312>.java
@@ -0,0 +1,67 @@
+import java.util.Collections;
+import java.util.PriorityQueue;
+
+public class medianofstream {
+	
+	public static void main(String[] args) {
+		int[] arr= { 5,7,10,15};
+		
+		PriorityQueue<Integer> minheap= new PriorityQueue<>();
+		PriorityQueue<Integer> maxheap= new PriorityQueue<>(Collections.reverseOrder());
+		
+		
+		double med= arr[0];
+		maxheap.add(arr[0]);
+		System.out.println(med);
+		for(int i=1;i<arr.length;i++)
+		{
+			int x= arr[i];
+			
+			if(minheap.size()<maxheap.size())
+			{
+				if(x<med)
+				{
+					minheap.add(maxheap.remove());
+					maxheap.add(x);
+				}else {
+					minheap.add(x);
+				}
+				med= (double) (maxheap.peek()+ minheap.peek())/2;
+			}
+			else if(minheap.size()== maxheap.size())
+			{
+				if(x>med)
+				{
+					minheap.add(x);
+					med= (double)(minheap.peek());
+					
+					
+				}else {
+					maxheap.add(x);
+					med= (double)(maxheap.peek());
+					
+				}
+				
+			}else {
+				
+				if(x>med) {
+				
+				maxheap.add(minheap.remove());
+				minheap.add(x);
+				}
+				else {
+					maxheap.add(x);
+				}
+				
+				med= (double) (maxheap.peek()+ minheap.peek())/2;
+				
+			}
+			System.out.println(med);
+			
+			
+			
+		}
+		
+	}
+
+}