入力ファイルブロックの開始

読み取られるブロックの開始オフセットを返します。利用できない場合は -1 を返します。

構文

Python

from pyspark.sql import functions as sf

sf.input_file_block_start()

例

例1 : 入力ファイルブロックの開始オフセットを取得する

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|
+------------------------+