Pular para o conteúdo principal
Última atualização em

início do bloco de arquivo de entrada

Retorna o deslocamento inicial do bloco que está sendo lido, ou -1 se não estiver disponível.

Sintaxe​

Python
from pyspark.sql import functions as sf

sf.input_file_block_start()

Exemplos​

Exemplo 1 : Obter o deslocamento inicial do bloco do arquivo de entrada

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_start()).show()
Output
+------------------------+
|input_file_block_start()|
+------------------------+
|                       0|
|                       0|
|                       0|
|                       0|
|                       0|
|                       0|
|                       0|
|                       0|
+------------------------+