File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -34,9 +34,9 @@ trait Source {
3434 def getOffset : Option [Offset ]
3535
3636 /**
37- * Returns the data that is between the offsets (`start`, `end`]. When `start` is `None` then the
38- * returned data should begin with the first available record. This method must always return the
37+ * Returns the data that is between the offsets (`start`, `end`]. When `start` is `None` then
38+ * the batch should begin with the first available record. This method must always return the
3939 * same data for a particular `start` and `end` pair.
4040 */
41- def getData (start : Option [Offset ], end : Offset ): DataFrame
41+ def getBatch (start : Option [Offset ], end : Offset ): DataFrame
4242}
You can’t perform that action at this time.
0 commit comments