Skip to content

Commit

Permalink
Format with black.
Browse files Browse the repository at this point in the history
  • Loading branch information
theoctober19th committed Jan 30, 2024
1 parent c230cf7 commit fff7f4a
Showing 1 changed file with 5 additions and 9 deletions.
14 changes: 5 additions & 9 deletions tests/integration/resources/test-iceberg.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,16 +9,12 @@
args = parser.parse_args()
num_rows = args.num_rows

spark = SparkSession\
.builder\
.appName("IcebergExample")\
.getOrCreate()
spark = SparkSession.builder.appName("IcebergExample").getOrCreate()


schema = StructType([
StructField("row_id", LongType(), True),
StructField("row_val", LongType(), True)
])
schema = StructType(
[StructField("row_id", LongType(), True), StructField("row_val", LongType(), True)]
)

data = []
for idx in range(num_rows):
Expand All @@ -31,4 +27,4 @@

df = spark.table("demo.foo.bar")
count = df.count()
print(f"Number of rows inserted: {count}")
print(f"Number of rows inserted: {count}")

0 comments on commit fff7f4a

Please sign in to comment.