input_file_block_length

Renvoie la longueur du bloc lu, ou -1 s'il n'est pas disponible.

Syntaxe

Python

from pyspark.sql import functions as sf

sf.input_file_block_length()

Exemples

Exemple 1 : Obtenir la longueur de bloc du fichier d'entrée

Python

from pyspark.sql import functions as sf
df = spark.read.text("python/test_support/sql/ages_newlines.csv", lineSep=",")
df.select(sf.input_file_block_length()).show()

Output

+-------------------------+
|input_file_block_length()|
+-------------------------+
|                       87|
|                       87|
|                       87|
|                       87|
|                       87|
|                       87|
|                       87|
|                       87|
+-------------------------+