Skip to content

Commit

Permalink
comment updates
Browse files Browse the repository at this point in the history
  • Loading branch information
JoshRosen committed Aug 11, 2015
1 parent c188a21 commit eabacca
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -56,6 +56,7 @@ case class SortMergeJoin(
protected[this] def isUnsafeMode: Boolean = {
(codegenEnabled && unsafeEnabled
&& UnsafeProjection.canSupport(leftKeys)
&& UnsafeProjection.canSupport(rightKeys)
&& UnsafeProjection.canSupport(schema))
}

Expand Down Expand Up @@ -122,15 +123,14 @@ case class SortMergeJoin(
/**
* Helper class that is used to implement [[SortMergeJoin]] and [[SortMergeOuterJoin]].
*
* The streamed input is the left side of a left outer join or the right side of a right outer join.
*
* To perform an inner (outer) join, users of this class call [[findNextInnerJoinRows()]]
* ([[findNextOuterJoinRows()]]), which returns `true` if a result has been produced and `false`
* otherwise. If a result has been produced, then the caller may call [[getStreamedRow]] to return
* the matching row from the streamed input and may call [[getBufferedMatches]] to return the
* sequence of matching rows from the buffered input (in the case of an outer join, this will return
* an empty sequence). For efficiency, both of these methods return mutable objects which are
* re-used across calls to the `findNext*JoinRows()` methods.
* an empty sequence if there are no matches from the buffered input). For efficiency, both of these
* methods return mutable objects which are re-used across calls to the `findNext*JoinRows()`
* methods.
*
* @param streamedKeyGenerator a projection that produces join keys from the streamed input.
* @param bufferedKeyGenerator a projection that produces join keys from the buffered input.
Expand Down

0 comments on commit eabacca

Please sign in to comment.