You may want to take a look at these files in Drill's source on github
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinProbe.java exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinHelper.java exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatchCreator.java exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinProbeTemplate.java ________________________________ From: weijie tong <[email protected]> Sent: Saturday, May 13, 2017 3:51:08 PM To: [email protected] Subject: questions about Drill's implementation detail to implement HashJoin HI Drillers: Any one could give a detail description of Drill's HashJoin implementation , a picture of the HashTable's data structure ? I also wonder the HashTable implementation difference between Drill and Flink . Seems Drill is batch model while Flink is not . Am I right ?
