File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -41,9 +41,9 @@ import org.apache.spark.util.RpcUtils
4141
4242/**
4343 * The overall strategy here is:
44- * ContinuousMemoryStream maintains a list of records for each partition. addData() will
44+ * * ContinuousMemoryStream maintains a list of records for each partition. addData() will
4545 * distribute records evenly-ish across partitions.
46- * RecordEndpoint is set up as an endpoint for executor-side
46+ * * RecordEndpoint is set up as an endpoint for executor-side
4747 * ContinuousMemoryStreamInputPartitionReader instances to poll. It returns the record at
4848 * the specified offset within the list, or null if that offset doesn't yet have a record.
4949 */
You can’t perform that action at this time.
0 commit comments