読み取るブロックの開始オフセットを返します。使用できない場合は -1 します。
構文
from pyspark.sql import functions as sf
sf.input_file_block_start()
例示
例 1: 入力ファイル ブロックの開始オフセットを取得する
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()
+------------------------+
|input_file_block_start()|
+------------------------+
| 0|
| 0|
| 0|
| 0|
| 0|
| 0|
| 0|
| 0|
+------------------------+