Index

A

agg() (spark_tests.sql.FakeGroupedData method) alias() (spark_tests.delta.FakeDeltaTable method)

alias_name (spark_tests.delta.FakeDeltaTable attribute) (spark_tests.sql.FakeDataFrame attribute)

C

clear() (spark_tests.delta.FakeDeltaMerge method) (spark_tests.sql.FakeDFWriter method) (spark_tests.sql.FakeSparkSession method)

condition (spark_tests.delta.FakeDeltaMerge attribute) createDataFrame() (spark_tests.sql.FakeSparkSession method)

E

execute() (spark_tests.delta.FakeDeltaMergeBuilder method)

F

FAKE_DELTA_MERGE (in module spark_tests.delta) FAKE_DF_WRITER (in module spark_tests.sql) fake_now (spark_tests.datetime.FakeDatetime.cls attribute) FakeDataFrame (class in spark_tests.sql) FakeDate (class in spark_tests.datetime) FakeDatetime (class in spark_tests.datetime) FakeDeltaMerge (class in spark_tests.delta)

FakeDeltaMergeBuilder (class in spark_tests.delta) FakeDeltaTable (class in spark_tests.delta) FakeDFWriter (class in spark_tests.sql) FakeGroupedData (class in spark_tests.sql) FakeSparkSession (class in spark_tests.sql) format() (spark_tests.sql.FakeDFWriter method) forName() (spark_tests.delta.FakeDeltaTable class method) forPath() (spark_tests.delta.FakeDeltaTable class method)

I

is_executed (spark_tests.delta.FakeDeltaMerge attribute)

is_saved (spark_tests.sql.FakeDFWriter attribute)

M

matched_action (spark_tests.delta.FakeDeltaMerge attribute) matched_condition (spark_tests.delta.FakeDeltaMerge attribute) matched_update (spark_tests.delta.FakeDeltaMerge attribute) merge() (spark_tests.delta.FakeDeltaTable method)

mode() (spark_tests.sql.FakeDFWriter method) module spark_tests.datetime spark_tests.delta spark_tests.sql

N

name (spark_tests.delta.FakeDeltaTable attribute) (spark_tests.sql.FakeDFWriter attribute) not_matched_action (spark_tests.delta.FakeDeltaMerge attribute)

not_matched_condition (spark_tests.delta.FakeDeltaMerge attribute) not_matched_insert (spark_tests.delta.FakeDeltaMerge attribute) now() (spark_tests.datetime.FakeDatetime class method)

O

option() (spark_tests.sql.FakeDFWriter method)

options() (spark_tests.sql.FakeDFWriter method)

P

partition_by (spark_tests.sql.FakeDFWriter attribute) partitionBy() (spark_tests.sql.FakeDFWriter method)

path (spark_tests.delta.FakeDeltaTable attribute) (spark_tests.sql.FakeDFWriter attribute) pivot() (spark_tests.sql.FakeGroupedData method)

R

real (spark_tests.sql.FakeDataFrame attribute) (spark_tests.sql.FakeGroupedData attribute) (spark_tests.sql.FakeSparkSession attribute)

S

save() (spark_tests.sql.FakeDFWriter method) save_format (spark_tests.sql.FakeDFWriter attribute) save_mode (spark_tests.sql.FakeDFWriter attribute) save_options (spark_tests.sql.FakeDFWriter attribute) saveAsTable() (spark_tests.sql.FakeDFWriter method) set_fake_now() (spark_tests.datetime.FakeDatetime class method) source (spark_tests.delta.FakeDeltaMerge attribute) (spark_tests.delta.FakeDeltaTable attribute) (spark_tests.sql.FakeDFWriter attribute) spark (spark_tests.delta.FakeDeltaTable attribute)

spark_tests.datetime module spark_tests.delta module spark_tests.sql module sparkContext (spark_tests.sql.FakeSparkSession property) sql() (spark_tests.sql.FakeSparkSession method) sql_queries (spark_tests.sql.FakeSparkSession attribute) sum() (spark_tests.sql.FakeGroupedData method)

T

table() (spark_tests.sql.FakeSparkSession method) target (spark_tests.delta.FakeDeltaMerge attribute)

today() (spark_tests.datetime.FakeDate class method) (spark_tests.datetime.FakeDatetime class method)

W

whenMatchedDelete() (spark_tests.delta.FakeDeltaMergeBuilder method) whenMatchedUpdate() (spark_tests.delta.FakeDeltaMergeBuilder method)

whenNotMatchedInsert() (spark_tests.delta.FakeDeltaMergeBuilder method) write (spark_tests.sql.FakeDataFrame property)