We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent acfafb5 commit 5b3b631Copy full SHA for 5b3b631
tests/integration/test_deletes.py
@@ -43,7 +43,7 @@ def run_spark_commands(spark: SparkSession, sqls: list[str]) -> None:
43
def test_table(session_catalog: RestCatalog) -> Generator[Table, None, None]:
44
identifier = "default.__test_table"
45
arrow_table = pa.Table.from_arrays([pa.array([1, 2, 3, 4, 5]), pa.array(["a", "b", "c", "d", "e"])], names=["idx", "value"])
46
- test_table = session_catalog.create_table_if_not_exists(
+ test_table = session_catalog.create_table(
47
identifier,
48
schema=Schema(
49
NestedField(1, "idx", LongType()),
0 commit comments