Index

_

__init__() (nxcals.api.extraction.data.builders.Builder method) (nxcals.api.extraction.data.builders.BuildStage method) (nxcals.api.extraction.data.builders.DataFrame method) (nxcals.api.extraction.data.builders.DataQuery method) (nxcals.api.extraction.data.builders.DevicePropertyDataQuery method) (nxcals.api.extraction.data.builders.DeviceStage method) (nxcals.api.extraction.data.builders.DeviceStageV2 method) (nxcals.api.extraction.data.builders.EntityAliasStage method) (nxcals.api.extraction.data.builders.EntityQuery method) (nxcals.api.extraction.data.builders.EntityStage method) (nxcals.api.extraction.data.builders.EntityStageLoop method) (nxcals.api.extraction.data.builders.KeyValuesStage method) (nxcals.api.extraction.data.builders.ParameterDataQuery method) (nxcals.api.extraction.data.builders.SparkSession method) (nxcals.api.extraction.data.builders.StartStage method) (nxcals.api.extraction.data.builders.SystemOrIdStage method) (nxcals.api.extraction.data.builders.SystemStage method) (nxcals.api.extraction.data.builders.SystemStageV2 method) (nxcals.api.extraction.data.builders.VariableAliasStage method) (nxcals.api.extraction.data.builders.VariableStage method) (nxcals.api.extraction.data.builders.VariableStageLoop method) (nxcals.api.extraction.data.builders.VariableStageV2 method)

A

active() (nxcals.api.extraction.data.builders.SparkSession class method) addArtifact() (nxcals.api.extraction.data.builders.SparkSession method) addArtifacts() (nxcals.api.extraction.data.builders.SparkSession method) addTag() (nxcals.api.extraction.data.builders.SparkSession method) agg() (nxcals.api.extraction.data.builders.DataFrame method)

alias() (nxcals.api.extraction.data.builders.DataFrame method) approxQuantile() (nxcals.api.extraction.data.builders.DataFrame method) ArgumentError atTime() (nxcals.api.extraction.data.builders.EntityStageLoop method) (nxcals.api.extraction.data.builders.StartStage method) (nxcals.api.extraction.data.builders.VariableStageLoop method)

B

build() (nxcals.api.extraction.data.builders.BuildStage method) Builder (class in nxcals.api.extraction.data.builders) builder (nxcals.api.extraction.data.builders.SparkSession attribute), [1] builder() (nxcals.api.extraction.data.builders.DataQuery static method) (nxcals.api.extraction.data.builders.DevicePropertyDataQuery static method) (nxcals.api.extraction.data.builders.ParameterDataQuery static method)

builders_package() (in module nxcals.api.extraction.data.builders) BuildStage (class in nxcals.api.extraction.data.builders) byEntities() (nxcals.api.extraction.data.builders.DataQuery method) byVariables() (nxcals.api.extraction.data.builders.DataQuery method)

C

cache() (nxcals.api.extraction.data.builders.DataFrame method) catalog (nxcals.api.extraction.data.builders.SparkSession property) checkpoint() (nxcals.api.extraction.data.builders.DataFrame method) clearTags() (nxcals.api.extraction.data.builders.SparkSession method) client (nxcals.api.extraction.data.builders.SparkSession property) coalesce() (nxcals.api.extraction.data.builders.DataFrame method) collect() (nxcals.api.extraction.data.builders.DataFrame method) colRegex() (nxcals.api.extraction.data.builders.DataFrame method) columns (nxcals.api.extraction.data.builders.DataFrame property) conf (nxcals.api.extraction.data.builders.SparkSession property) copyFromLocalToFs() (nxcals.api.extraction.data.builders.SparkSession method)

corr() (nxcals.api.extraction.data.builders.DataFrame method) count() (nxcals.api.extraction.data.builders.DataFrame method) cov() (nxcals.api.extraction.data.builders.DataFrame method) createDataFrame() (nxcals.api.extraction.data.builders.SparkSession method) createGlobalTempView() (nxcals.api.extraction.data.builders.DataFrame method) createOrReplaceGlobalTempView() (nxcals.api.extraction.data.builders.DataFrame method) createOrReplaceTempView() (nxcals.api.extraction.data.builders.DataFrame method) createTempView() (nxcals.api.extraction.data.builders.DataFrame method) crossJoin() (nxcals.api.extraction.data.builders.DataFrame method) crosstab() (nxcals.api.extraction.data.builders.DataFrame method) cube() (nxcals.api.extraction.data.builders.DataFrame method)

D

DataFrame (class in nxcals.api.extraction.data.builders) DataQuery (class in nxcals.api.extraction.data.builders) describe() (nxcals.api.extraction.data.builders.DataFrame method) device() (nxcals.api.extraction.data.builders.DeviceStage method) deviceEq() (nxcals.api.extraction.data.builders.DeviceStageV2 method) deviceLike() (nxcals.api.extraction.data.builders.DeviceStage method) (nxcals.api.extraction.data.builders.DeviceStageV2 method) DevicePropertyDataQuery (class in nxcals.api.extraction.data.builders)

DeviceStage (class in nxcals.api.extraction.data.builders) DeviceStageV2 (in module nxcals.api.extraction.data.builders) distinct() (nxcals.api.extraction.data.builders.DataFrame method) drop() (nxcals.api.extraction.data.builders.DataFrame method) drop_duplicates() (nxcals.api.extraction.data.builders.DataFrame method) dropDuplicates() (nxcals.api.extraction.data.builders.DataFrame method) dropDuplicatesWithinWatermark() (nxcals.api.extraction.data.builders.DataFrame method) dropna() (nxcals.api.extraction.data.builders.DataFrame method) dtypes (nxcals.api.extraction.data.builders.DataFrame property)

E

entities() (nxcals.api.extraction.data.builders.DataQuery method) entity() (nxcals.api.extraction.data.builders.EntityAliasStage method) EntityAliasStage (class in nxcals.api.extraction.data.builders) EntityQuery (class in nxcals.api.extraction.data.builders)

EntityStage (class in nxcals.api.extraction.data.builders) EntityStageLoop (class in nxcals.api.extraction.data.builders) exceptAll() (nxcals.api.extraction.data.builders.DataFrame method) explain() (nxcals.api.extraction.data.builders.DataFrame method)

F

fieldAlias() (nxcals.api.extraction.data.builders.EntityAliasStage method) (nxcals.api.extraction.data.builders.VariableAliasStage method) fieldAliases() (nxcals.api.extraction.data.builders.BuildStage method) (nxcals.api.extraction.data.builders.EntityAliasStage method) (nxcals.api.extraction.data.builders.VariableAliasStage method)

fillna() (nxcals.api.extraction.data.builders.DataFrame method) filter() (nxcals.api.extraction.data.builders.DataFrame method) first() (nxcals.api.extraction.data.builders.DataFrame method) foreach() (nxcals.api.extraction.data.builders.DataFrame method) foreachPartition() (nxcals.api.extraction.data.builders.DataFrame method) freqItems() (nxcals.api.extraction.data.builders.DataFrame method)

G

getActiveSession() (nxcals.api.extraction.data.builders.SparkSession class method) getForEntities() (nxcals.api.extraction.data.builders.DataQuery static method) getForVariables() (nxcals.api.extraction.data.builders.DataQuery static method)

getTags() (nxcals.api.extraction.data.builders.SparkSession method) groupBy() (nxcals.api.extraction.data.builders.DataFrame method) groupby() (nxcals.api.extraction.data.builders.DataFrame method)

H

has_wildcards() (nxcals.api.extraction.data.builders.EntityQuery method)

head() (nxcals.api.extraction.data.builders.DataFrame method) hint() (nxcals.api.extraction.data.builders.DataFrame method)

I

idEq() (nxcals.api.extraction.data.builders.EntityStage method) (nxcals.api.extraction.data.builders.EntityStageLoop method) (nxcals.api.extraction.data.builders.SystemOrIdStage method) (nxcals.api.extraction.data.builders.VariableStageLoop method) (nxcals.api.extraction.data.builders.VariableStageV2 method) idIn() (nxcals.api.extraction.data.builders.EntityStage method) (nxcals.api.extraction.data.builders.EntityStageLoop method) (nxcals.api.extraction.data.builders.SystemOrIdStage method) (nxcals.api.extraction.data.builders.VariableStageLoop method) (nxcals.api.extraction.data.builders.VariableStageV2 method)

inputFiles() (nxcals.api.extraction.data.builders.DataFrame method) interruptAll() (nxcals.api.extraction.data.builders.SparkSession method) interruptOperation() (nxcals.api.extraction.data.builders.SparkSession method) interruptTag() (nxcals.api.extraction.data.builders.SparkSession method) intersect() (nxcals.api.extraction.data.builders.DataFrame method) intersectAll() (nxcals.api.extraction.data.builders.DataFrame method) isEmpty() (nxcals.api.extraction.data.builders.DataFrame method) isLocal() (nxcals.api.extraction.data.builders.DataFrame method) isStreaming (nxcals.api.extraction.data.builders.DataFrame property)

J

join() (nxcals.api.extraction.data.builders.DataFrame method)

K

keyValue() (nxcals.api.extraction.data.builders.KeyValuesStage method) keyValueLike() (nxcals.api.extraction.data.builders.KeyValuesStage method) keyValues() (nxcals.api.extraction.data.builders.KeyValuesStage method) keyValuesEq() (nxcals.api.extraction.data.builders.EntityStage method) (nxcals.api.extraction.data.builders.EntityStageLoop method)

keyValuesIn() (nxcals.api.extraction.data.builders.EntityStage method) (nxcals.api.extraction.data.builders.EntityStageLoop method) keyValuesLike() (nxcals.api.extraction.data.builders.EntityStage method) (nxcals.api.extraction.data.builders.EntityStageLoop method) (nxcals.api.extraction.data.builders.KeyValuesStage method) KeyValuesStage (class in nxcals.api.extraction.data.builders)

L

limit() (nxcals.api.extraction.data.builders.DataFrame method)

localCheckpoint() (nxcals.api.extraction.data.builders.DataFrame method)

M

mapInArrow() (nxcals.api.extraction.data.builders.DataFrame method) mapInPandas() (nxcals.api.extraction.data.builders.DataFrame method)

melt() (nxcals.api.extraction.data.builders.DataFrame method) module nxcals.api.extraction.data.builders

N

na (nxcals.api.extraction.data.builders.DataFrame property) nameEq() (nxcals.api.extraction.data.builders.VariableStageLoop method) (nxcals.api.extraction.data.builders.VariableStageV2 method) nameIn() (nxcals.api.extraction.data.builders.VariableStageLoop method) (nxcals.api.extraction.data.builders.VariableStageV2 method)

nameLike() (nxcals.api.extraction.data.builders.VariableStageLoop method) (nxcals.api.extraction.data.builders.VariableStageV2 method) newSession() (nxcals.api.extraction.data.builders.SparkSession method) nxcals.api.extraction.data.builders module

O

observe() (nxcals.api.extraction.data.builders.DataFrame method)

offset() (nxcals.api.extraction.data.builders.DataFrame method) orderBy() (nxcals.api.extraction.data.builders.DataFrame method)

P

pandas_api() (nxcals.api.extraction.data.builders.DataFrame method) parameter() (nxcals.api.extraction.data.builders.DeviceStage method) ParameterDataQuery (class in nxcals.api.extraction.data.builders) parameterEq() (nxcals.api.extraction.data.builders.DeviceStageV2 method) parameterIn() (nxcals.api.extraction.data.builders.DeviceStageV2 method)

parameterLike() (nxcals.api.extraction.data.builders.DeviceStage method) (nxcals.api.extraction.data.builders.DeviceStageV2 method) parameters() (nxcals.api.extraction.data.builders.DeviceStage method) persist() (nxcals.api.extraction.data.builders.DataFrame method) printSchema() (nxcals.api.extraction.data.builders.DataFrame method)

R

randomSplit() (nxcals.api.extraction.data.builders.DataFrame method) range() (nxcals.api.extraction.data.builders.SparkSession method) rdd (nxcals.api.extraction.data.builders.DataFrame property) read (nxcals.api.extraction.data.builders.SparkSession property) readStream (nxcals.api.extraction.data.builders.SparkSession property)

registerTempTable() (nxcals.api.extraction.data.builders.DataFrame method) removeTag() (nxcals.api.extraction.data.builders.SparkSession method) repartition() (nxcals.api.extraction.data.builders.DataFrame method) repartitionByRange() (nxcals.api.extraction.data.builders.DataFrame method) replace() (nxcals.api.extraction.data.builders.DataFrame method) rollup() (nxcals.api.extraction.data.builders.DataFrame method)

S

sameSemantics() (nxcals.api.extraction.data.builders.DataFrame method) sample() (nxcals.api.extraction.data.builders.DataFrame method) sampleBy() (nxcals.api.extraction.data.builders.DataFrame method) schema (nxcals.api.extraction.data.builders.DataFrame property) select() (nxcals.api.extraction.data.builders.DataFrame method) selectExpr() (nxcals.api.extraction.data.builders.DataFrame method) semanticHash() (nxcals.api.extraction.data.builders.DataFrame method) show() (nxcals.api.extraction.data.builders.DataFrame method) sort() (nxcals.api.extraction.data.builders.DataFrame method) sortWithinPartitions() (nxcals.api.extraction.data.builders.DataFrame method) sparkContext (nxcals.api.extraction.data.builders.SparkSession property) SparkSession (class in nxcals.api.extraction.data.builders) sparkSession (nxcals.api.extraction.data.builders.DataFrame property) sql() (nxcals.api.extraction.data.builders.SparkSession method)

sql_ctx (nxcals.api.extraction.data.builders.DataFrame property) StartStage (class in nxcals.api.extraction.data.builders) startTime() (nxcals.api.extraction.data.builders.StartStage method) stat (nxcals.api.extraction.data.builders.DataFrame property) stop() (nxcals.api.extraction.data.builders.SparkSession method) storageLevel (nxcals.api.extraction.data.builders.DataFrame property) streams (nxcals.api.extraction.data.builders.SparkSession property) subtract() (nxcals.api.extraction.data.builders.DataFrame method) summary() (nxcals.api.extraction.data.builders.DataFrame method) system() (nxcals.api.extraction.data.builders.SystemOrIdStage method) (nxcals.api.extraction.data.builders.SystemStage method) (nxcals.api.extraction.data.builders.SystemStageV2 method) SystemOrIdStage (class in nxcals.api.extraction.data.builders) SystemStage (class in nxcals.api.extraction.data.builders) SystemStageV2 (in module nxcals.api.extraction.data.builders)

T

table() (nxcals.api.extraction.data.builders.SparkSession method) tail() (nxcals.api.extraction.data.builders.DataFrame method) take() (nxcals.api.extraction.data.builders.DataFrame method) timeWindow() (nxcals.api.extraction.data.builders.EntityStageLoop method) (nxcals.api.extraction.data.builders.VariableStageLoop method) to() (nxcals.api.extraction.data.builders.DataFrame method)

to_koalas() (nxcals.api.extraction.data.builders.DataFrame method) to_pandas_on_spark() (nxcals.api.extraction.data.builders.DataFrame method) toDF() (nxcals.api.extraction.data.builders.DataFrame method) toJSON() (nxcals.api.extraction.data.builders.DataFrame method) toLocalIterator() (nxcals.api.extraction.data.builders.DataFrame method) toPandas() (nxcals.api.extraction.data.builders.DataFrame method) transform() (nxcals.api.extraction.data.builders.DataFrame method)

U

udf (nxcals.api.extraction.data.builders.SparkSession property) udtf (nxcals.api.extraction.data.builders.SparkSession property) union() (nxcals.api.extraction.data.builders.DataFrame method)

unionAll() (nxcals.api.extraction.data.builders.DataFrame method) unionByName() (nxcals.api.extraction.data.builders.DataFrame method) unpersist() (nxcals.api.extraction.data.builders.DataFrame method) unpivot() (nxcals.api.extraction.data.builders.DataFrame method)

V

variable() (nxcals.api.extraction.data.builders.VariableAliasStage method) (nxcals.api.extraction.data.builders.VariableStage method) VariableAliasStage (class in nxcals.api.extraction.data.builders) variableLike() (nxcals.api.extraction.data.builders.VariableAliasStage method) (nxcals.api.extraction.data.builders.VariableStage method) variables() (nxcals.api.extraction.data.builders.DataQuery method) (nxcals.api.extraction.data.builders.VariableAliasStage method) (nxcals.api.extraction.data.builders.VariableStage method)

variablesLike() (nxcals.api.extraction.data.builders.VariableAliasStage method) (nxcals.api.extraction.data.builders.VariableStage method) VariableStage (class in nxcals.api.extraction.data.builders) VariableStageLoop (class in nxcals.api.extraction.data.builders) VariableStageV2 (in module nxcals.api.extraction.data.builders) version (nxcals.api.extraction.data.builders.SparkSession property)

W

where() (nxcals.api.extraction.data.builders.DataFrame method) withColumn() (nxcals.api.extraction.data.builders.DataFrame method) withColumnRenamed() (nxcals.api.extraction.data.builders.DataFrame method) withColumns() (nxcals.api.extraction.data.builders.DataFrame method) withColumnsRenamed() (nxcals.api.extraction.data.builders.DataFrame method)

withMetadata() (nxcals.api.extraction.data.builders.DataFrame method) withWatermark() (nxcals.api.extraction.data.builders.DataFrame method) write (nxcals.api.extraction.data.builders.DataFrame property) writeStream (nxcals.api.extraction.data.builders.DataFrame property) writeTo() (nxcals.api.extraction.data.builders.DataFrame method)