File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
streaming/src/main/scala/org/apache/spark/streaming Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -367,6 +367,7 @@ class StreamingContext private[streaming] (
367367 * Files must be written to the monitored directory by "moving" them from another
368368 * location within the same file system. File names starting with . are ignored.
369369 * @param directory HDFS directory to monitor for new file
370+ * @param conf Hadoop configuration
370371 * @tparam K Key type for reading HDFS file
371372 * @tparam V Value type for reading HDFS file
372373 * @tparam F Input format for reading HDFS file
@@ -398,6 +399,7 @@ class StreamingContext private[streaming] (
398399 * by "moving" them from another location within the same file system. File names
399400 * starting with . are ignored.
400401 * @param directory HDFS directory to monitor for new file
402+ * @param recordLength length of each record in bytes
401403 */
402404 def binaryRecordsStream (
403405 directory : String ,
You can’t perform that action at this time.
0 commit comments