pyspark.SparkContext.binaryRecords

SparkContext。 binaryRecords ( 路徑:str,recordLength:int )→pyspark.rdd.RDD(字節]

加載數據從一個平坦的二進製文件,假設每個記錄是一組數字與指定的數值格式(見ByteBuffer),和每個記錄的字節數是恒定的。

參數

路徑 str

輸入數據文件目錄

recordLength int

將記錄的長度

以前的

pyspark.SparkContext.binaryFiles

下一個

pyspark.SparkContext.broadcast