design pattern

slgithub · slgithub · commit a2edbf882a86 · 2015-05-05T09:30:25.000+05:30
diff --git a/DesignPatternByExample/.classpath b/DesignPatternByExample/.classpath
@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" path="src"/>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
+	<classpathentry kind="output" path="bin"/>
+</classpath>
diff --git a/DesignPatternByExample/.gitignore b/DesignPatternByExample/.gitignore
@@ -0,0 +1 @@
+/bin/
diff --git a/DesignPatternByExample/.project b/DesignPatternByExample/.project
@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>DesignPatternByExample</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+	</natures>
+</projectDescription>
diff --git a/DesignPatternByExample/src/com/design/chainofresponsibility/ATMdispencer/ATMDispenseChain.java b/DesignPatternByExample/src/com/design/chainofresponsibility/ATMdispencer/ATMDispenseChain.java
@@ -0,0 +1,37 @@
+package com.design.chainofresponsibility.ATMdispencer;
+
+import java.util.Scanner;
+
+public class ATMDispenseChain {
+
+	private DispenseChain c1;
+
+	public ATMDispenseChain() {
+		// initialize the chain
+		this.c1 = new Dollar50Dispenser();
+		DispenseChain c2 = new Dollar20Dispenser();
+		DispenseChain c3 = new Dollar10Dispenser();
+
+		// set the chain of responsibility
+		c1.setNextChain(c2);
+		c2.setNextChain(c3);
+	}
+
+	public static void main(String[] args) {
+		ATMDispenseChain atmDispenser = new ATMDispenseChain();
+		while (true) {
+			int amount = 0;
+			System.out.println("Enter amount to dispense");
+			Scanner input = new Scanner(System.in);
+			amount = input.nextInt();
+			if (amount % 10 != 0) {
+				System.out.println("Amount should be in multiple of 10s.");
+				return;
+			}
+			// process the request
+			atmDispenser.c1.dispense(new Currency(amount));
+		}
+
+	}
+
+}
diff --git a/DesignPatternByExample/src/com/design/chainofresponsibility/ATMdispencer/Currency.java b/DesignPatternByExample/src/com/design/chainofresponsibility/ATMdispencer/Currency.java
@@ -0,0 +1,14 @@
+package com.design.chainofresponsibility.ATMdispencer;
+
+public class Currency {
+
+	private int amount;
+
+	public Currency(int amt) {
+		this.amount = amt;
+	}
+
+	public int getAmount() {
+		return this.amount;
+	}
+}
diff --git a/DesignPatternByExample/src/com/design/chainofresponsibility/ATMdispencer/DispenseChain.java b/DesignPatternByExample/src/com/design/chainofresponsibility/ATMdispencer/DispenseChain.java
@@ -0,0 +1,8 @@
+package com.design.chainofresponsibility.ATMdispencer;
+
+public interface DispenseChain {
+
+	void setNextChain(DispenseChain nextChain);
+
+	void dispense(Currency cur);
+}
diff --git a/DesignPatternByExample/src/com/design/chainofresponsibility/ATMdispencer/Dollar10Dispenser.java b/DesignPatternByExample/src/com/design/chainofresponsibility/ATMdispencer/Dollar10Dispenser.java
@@ -0,0 +1,25 @@
+package com.design.chainofresponsibility.ATMdispencer;
+
+public class Dollar10Dispenser implements DispenseChain {
+
+	private DispenseChain chain;
+
+	@Override
+	public void setNextChain(DispenseChain nextChain) {
+		this.chain = nextChain;
+	}
+
+	@Override
+	public void dispense(Currency cur) {
+		if (cur.getAmount() >= 10) {
+			int num = cur.getAmount() / 10;
+			int remainder = cur.getAmount() % 10;
+			System.out.println("Dispensing " + num + " 10$ note");
+			if (remainder != 0)
+				this.chain.dispense(new Currency(remainder));
+		} else {
+			this.chain.dispense(cur);
+		}
+	}
+
+}
diff --git a/DesignPatternByExample/src/com/design/chainofresponsibility/ATMdispencer/Dollar20Dispenser.java b/DesignPatternByExample/src/com/design/chainofresponsibility/ATMdispencer/Dollar20Dispenser.java
@@ -0,0 +1,25 @@
+package com.design.chainofresponsibility.ATMdispencer;
+
+public class Dollar20Dispenser implements DispenseChain {
+
+	private DispenseChain chain;
+
+	@Override
+	public void setNextChain(DispenseChain nextChain) {
+		this.chain = nextChain;
+	}
+
+	@Override
+	public void dispense(Currency cur) {
+		if (cur.getAmount() >= 20) {
+			int num = cur.getAmount() / 20;
+			int remainder = cur.getAmount() % 20;
+			System.out.println("Dispensing " + num + " 20$ note");
+			if (remainder != 0)
+				this.chain.dispense(new Currency(remainder));
+		} else {
+			this.chain.dispense(cur);
+		}
+	}
+
+}
diff --git a/DesignPatternByExample/src/com/design/chainofresponsibility/ATMdispencer/Dollar50Dispenser.java b/DesignPatternByExample/src/com/design/chainofresponsibility/ATMdispencer/Dollar50Dispenser.java
@@ -0,0 +1,25 @@
+package com.design.chainofresponsibility.ATMdispencer;
+
+public class Dollar50Dispenser implements DispenseChain {
+
+	private DispenseChain chain;
+
+	@Override
+	public void setNextChain(DispenseChain nextChain) {
+		this.chain = nextChain;
+	}
+
+	@Override
+	public void dispense(Currency cur) {
+		if (cur.getAmount() >= 50) {
+			int num = cur.getAmount() / 50;
+			int remainder = cur.getAmount() % 50;
+			System.out.println("Dispensing " + num + " 50$ note");
+			if (remainder != 0)
+				this.chain.dispense(new Currency(remainder));
+		} else {
+			this.chain.dispense(cur);
+		}
+	}
+
+}
diff --git a/DesignPatternByExample/src/com/design/mediator/ChatClient.java b/DesignPatternByExample/src/com/design/mediator/ChatClient.java
@@ -0,0 +1,20 @@
+package com.design.mediator;
+
+public class ChatClient {
+
+	public static void main(String[] args) {
+		ChatMediator mediator = new ChatMediatorImpl();
+		User user1 = new UserImpl(mediator, "Pankaj");
+		User user2 = new UserImpl(mediator, "Lisa");
+		User user3 = new UserImpl(mediator, "Saurabh");
+		User user4 = new UserImpl(mediator, "David");
+		mediator.addUser(user1);
+		mediator.addUser(user2);
+		mediator.addUser(user3);
+		mediator.addUser(user4);
+
+		user1.send("Hi All");
+
+	}
+
+}
diff --git a/DesignPatternByExample/src/com/design/mediator/ChatMediator.java b/DesignPatternByExample/src/com/design/mediator/ChatMediator.java
@@ -0,0 +1,8 @@
+package com.design.mediator;
+
+public interface ChatMediator {
+	 
+    public void sendMessage(String msg, User user);
+ 
+    void addUser(User user);
+}
diff --git a/DesignPatternByExample/src/com/design/mediator/ChatMediatorImpl.java b/DesignPatternByExample/src/com/design/mediator/ChatMediatorImpl.java
@@ -0,0 +1,29 @@
+package com.design.mediator;
+
+import java.util.ArrayList;
+import java.util.List;
+ 
+public class ChatMediatorImpl implements ChatMediator {
+ 
+    private List<User> users;
+     
+    public ChatMediatorImpl(){
+        this.users=new ArrayList<>();
+    }
+     
+    @Override
+    public void addUser(User user){
+        this.users.add(user);
+    }
+     
+    @Override
+    public void sendMessage(String msg, User user) {
+        for(User u : this.users){
+            //message should not be received by the user sending it
+            if(u != user){
+                u.receive(msg);
+            }
+        }
+    }
+ 
+}
diff --git a/DesignPatternByExample/src/com/design/mediator/User.java b/DesignPatternByExample/src/com/design/mediator/User.java
@@ -0,0 +1,15 @@
+package com.design.mediator;
+
+public abstract class User {
+	protected ChatMediator mediator;
+	protected String name;
+
+	public User(ChatMediator med, String name) {
+		this.mediator = med;
+		this.name = name;
+	}
+
+	public abstract void send(String msg);
+
+	public abstract void receive(String msg);
+}
diff --git a/DesignPatternByExample/src/com/design/mediator/UserImpl.java b/DesignPatternByExample/src/com/design/mediator/UserImpl.java
@@ -0,0 +1,19 @@
+package com.design.mediator;
+
+public class UserImpl extends User {
+	 
+    public UserImpl(ChatMediator med, String name) {
+        super(med, name);
+    }
+ 
+    @Override
+    public void send(String msg){
+        System.out.println(this.name+": Sending Message="+msg);
+        mediator.sendMessage(msg, this);
+    }
+    @Override
+    public void receive(String msg) {
+        System.out.println(this.name+": Received Message:"+msg);
+    }
+ 
+}
diff --git a/DesignPatternByExample/src/com/javapapers/designpattern/mediator/ATCMediator.java b/DesignPatternByExample/src/com/javapapers/designpattern/mediator/ATCMediator.java
@@ -0,0 +1,25 @@
+package com.javapapers.designpattern.mediator;
+
+public class ATCMediator implements IATCMediator {
+	private Flight flight;
+	private Runway runway;
+	public boolean land;
+
+	public void registerRunway(Runway runway) {
+		this.runway = runway;
+	}
+
+	public void registerFlight(Flight flight) {
+		this.flight = flight;
+	}
+
+	public boolean isLandingOk() {
+		return land;
+	}
+
+	@Override
+	public void setLandingStatus(boolean status) {
+		land = status;
+
+	}
+}
diff --git a/DesignPatternByExample/src/com/javapapers/designpattern/mediator/Command.java b/DesignPatternByExample/src/com/javapapers/designpattern/mediator/Command.java
@@ -0,0 +1,5 @@
+package com.javapapers.designpattern.mediator;
+
+public interface Command {
+	void land();
+}
diff --git a/DesignPatternByExample/src/com/javapapers/designpattern/mediator/Flight.java b/DesignPatternByExample/src/com/javapapers/designpattern/mediator/Flight.java
@@ -0,0 +1,22 @@
+package com.javapapers.designpattern.mediator;
+
+public class Flight implements Command {
+	private IATCMediator atcMediator;
+
+	public Flight(IATCMediator atcMediator) {
+		this.atcMediator = atcMediator;
+	}
+
+	public void land() {
+		if (atcMediator.isLandingOk()) {
+			System.out.println("Landing done....");
+			atcMediator.setLandingStatus(true);
+		} else
+			System.out.println("Will wait to land....");
+	}
+
+	public void getReady() {
+		System.out.println("Getting ready...");
+	}
+
+}
diff --git a/DesignPatternByExample/src/com/javapapers/designpattern/mediator/IATCMediator.java b/DesignPatternByExample/src/com/javapapers/designpattern/mediator/IATCMediator.java
@@ -0,0 +1,12 @@
+package com.javapapers.designpattern.mediator;
+
+public interface IATCMediator {
+
+	public void registerRunway(Runway runway);
+
+	public void registerFlight(Flight flight);
+
+	public boolean isLandingOk();
+
+	public void setLandingStatus(boolean status);
+}
diff --git a/DesignPatternByExample/src/com/javapapers/designpattern/mediator/MediatorDesignPattern.java b/DesignPatternByExample/src/com/javapapers/designpattern/mediator/MediatorDesignPattern.java
@@ -0,0 +1,15 @@
+package com.javapapers.designpattern.mediator;
+
+public class MediatorDesignPattern {
+	public static void main(String args[]) {
+
+		IATCMediator atcMediator = new ATCMediator();
+		Flight sparrow101 = new Flight(atcMediator);
+		Runway mainRunway = new Runway(atcMediator);
+		atcMediator.registerFlight(sparrow101);
+		atcMediator.registerRunway(mainRunway);
+		sparrow101.getReady();
+		mainRunway.land();
+		sparrow101.land();
+	}
+}
diff --git a/DesignPatternByExample/src/com/javapapers/designpattern/mediator/Runway.java b/DesignPatternByExample/src/com/javapapers/designpattern/mediator/Runway.java
@@ -0,0 +1,17 @@
+package com.javapapers.designpattern.mediator;
+
+public class Runway implements Command {
+	private IATCMediator atcMediator;
+
+	public Runway(IATCMediator atcMediator) {
+		this.atcMediator = atcMediator;
+		atcMediator.setLandingStatus(true);
+	}
+
+	@Override
+	public void land() {
+		System.out.println("Landing permission granted...");
+		atcMediator.setLandingStatus(true);
+	}
+
+}
diff --git a/pigudf/src/pig/BATTING.pig b/pigudf/src/pig/BATTING.pig
@@ -3,8 +3,11 @@
  grp_by_player= GROUP players BY playerID;
  GRP_YR_PLAYER= FOREACH grp_by_player GENERATE group as playerID,players.year as play_yr,players.runs as player_run; 
  max_runs_player_bag = FOREACH grp_by_player GENERATE group as playerID,MAX(players.runs) as max_runs_player;
- max_player_year= JOIN max_runs_player_bag BY (playerID,max_runs_player) LEFT OUTER,players BY (playerID,runs)
+ max_player_year= JOIN max_runs_player_bag BY (playerID,max_runs_player) LEFT OUTER,players BY (playerID,runs);
  
+ final_result_player_run= FOREACH max_player_year GENERATE $0 as playerID,$3 as year,$1 as run;
+ 
+ final_result_player_run_order = ORDER final_result_player_run by playerID,year;
  
  
  sp_player = filter players by playerID == 'zuverge01';
diff --git a/pigudf/src/pig/test.pig b/pigudf/src/pig/test.pig
