Index

_

__contains__() (pyswark.gluedb.db.Db method)

A

acquire() (in module pyswark.core.io.api) (pyswark.core.models.record.Record method) acquireFromDb() (pyswark.gluedb.hub.Hub method) add() (pyswark.workflow.workflow.Extracts method) addStep() (pyswark.workflow.workflow.Workflow method) after() (pyswark.core.models.datetime.Datetime method) (pyswark.tensor.tensor.Inputs method) after_data_dtype() (pyswark.core.models.datetime.Datetime class method) after_dtype() (pyswark.core.models.datetime.Datetime static method) after_tzname() (pyswark.core.models.datetime.Datetime class method) Alias (class in pyswark.lib.aenum) AliasEnum (class in pyswark.lib.aenum) AliasEnumError aliases (pyswark.lib.aenum.AliasEnum property) all() (pyswark.query.interface.Query method)

AllowedInstances (pyswark.core.models.db.Db attribute) (pyswark.core.models.db.MixinDb attribute) AllowedTypes (pyswark.core.models.db.Db attribute) (pyswark.core.models.db.MixinDb attribute) any() (pyswark.query.interface.Query method) asDict() (pyswark.core.models.collection.Dict method) (pyswark.core.models.collection.List method) (pyswark.lib.enum.Mixin class method) (pyswark.lib.enum.Mixin method) asPythonCode() (pyswark.lib.enum.Mixin class method) (pyswark.lib.enum.Mixin method) asSQLModel() (pyswark.core.models.body.Body method) (pyswark.core.models.db.MixinDb method) (pyswark.core.models.info.Info method) (pyswark.core.models.record.Record method) astype() (pyswark.core.models.datetime.DatetimeList method)

B

backend (pyswark.workflow.state.Interface attribute) (pyswark.workflow.state.StateWithGlueDb attribute) Base (pyswark.core.models.body.Body attribute) basedt (pyswark.core.models.datetime.DatetimeList attribute) (pyswark.core.models.datetime.DatetimeList property) BaseInputs (class in pyswark.core.models.xputs)

BaseModel (class in pyswark.lib.pydantic.base), [1] BaseOutputs (class in pyswark.core.models.xputs) before_data() (pyswark.core.models.datetime.Datetime class method) before_dtype() (pyswark.core.models.datetime.Datetime class method) Body (class in pyswark.core.models.body) body (pyswark.core.models.record.Record attribute) Bool (class in pyswark.core.models.primitive)

C

clone() (pyswark.core.models.info.Info method) close() (pyswark.lib.fsspec.implementations.PythonFile method) collect (pyswark.query.interface.Query attribute) collectResults() (pyswark.query.interface.Query class method) connect() (pyswark.core.models.db.MixinDb class method) contents (pyswark.core.models.body.Body attribute)

convert() (pyswark.core.models.converter.ConverterModel class method) (pyswark.core.models.datetime.DatetimeList static method) (pyswark.tensor.tensor.Tensor class method) ConverterModel (class in pyswark.core.models.converter) createDynamically() (pyswark.lib.enum.Mixin class method) (pyswark.lib.enum.Mixin method)

D

data (pyswark.core.models.datetime.Datetime attribute) (pyswark.tensor.tensor.Inputs attribute) (pyswark.workflow.workflow.Extracts attribute) datahandler (pyswark.core.models.db.MixinDb attribute) date_created (pyswark.core.models.info.Info attribute) date_modified (pyswark.core.models.info.Info attribute) Datetime (class in pyswark.core.models.datetime) datetime (pyswark.core.models.datetime.Datetime property) DatetimeList (class in pyswark.core.models.datetime) Db (class in pyswark.core.models.db) (class in pyswark.gluedb.db) delete() (pyswark.gluedb.db.Db method) (pyswark.workflow.state.Interface method) (pyswark.workflow.state.State method) (pyswark.workflow.state.StateWithGlueDb method)

deleteByName() (pyswark.core.models.db.MixinDb method) deleteFromDb() (pyswark.gluedb.hub.Hub method) deltas (pyswark.core.models.datetime.DatetimeList attribute) (pyswark.core.models.datetime.DatetimeList property) Dict (class in pyswark.core.models.collection) dt (pyswark.core.models.datetime.Datetime property) (pyswark.core.models.datetime.DatetimeList attribute) (pyswark.core.models.datetime.DatetimeList property) (pyswark.ts.tsvector.TsVector property) dtype (pyswark.core.models.datetime.Datetime attribute) (pyswark.core.models.datetime.DatetimeList property) (pyswark.tensor.tensor.Inputs attribute)

E

engine_url (pyswark.core.models.db.MixinDb attribute) Enum (class in pyswark.lib.enum) enum (pyswark.core.models.db.MixinDb property) equal() (pyswark.workflow.workflow.Extracts method) Equals (class in pyswark.query.interface) exists() (pyswark.lib.fsspec.implementations.PythonFileSystem method) ExtraAllowed (class in pyswark.lib.pydantic.base) extract() (pyswark.core.models.body.Body method) (pyswark.core.models.collection.Dict method) (pyswark.core.models.collection.Set method) (pyswark.core.models.collection.Tuple method) (pyswark.gluedb.db.Db method) (pyswark.gluedb.hub.Hub method) (pyswark.workflow.state.Interface method) (pyswark.workflow.state.State method) (pyswark.workflow.state.StateWithGlueDb method)

extractFromDb() (pyswark.gluedb.hub.Hub method) extractModelFromModelInput() (pyswark.workflow.step.Step method) extractModelInputFromStateInput() (pyswark.workflow.step.Step method) extractRecords() (pyswark.query.interface.Query class method) Extracts (class in pyswark.workflow.workflow) extractStateInputFromState() (pyswark.workflow.step.Step method) extractStateOutputFromModelOutput() (pyswark.workflow.step.Step method) ExtraForbidden (class in pyswark.lib.pydantic.base)

F

filesystem() (in module pyswark.lib.fsspec.fsspec) Float (class in pyswark.core.models.primitive) fromDict() (in module pyswark.lib.pydantic.ser_des) (pyswark.lib.pydantic.base.BaseModel static method), [1]

fromJson() (in module pyswark.lib.pydantic.ser_des), [1] (pyswark.lib.pydantic.base.BaseModel static method), [1] function() (pyswark.core.models.function.FunctionModel static method) FunctionModel (class in pyswark.core.models.function)

G

get() (in module pyswark.sekrets.api) (pyswark.gluedb.db.Db method) (pyswark.lib.aenum.AliasEnum class method) (pyswark.lib.aenum.AliasEnum method) (pyswark.workflow.workflow.Extracts method) getByName() (pyswark.core.models.db.MixinDb method) getDb() (in module pyswark.sekrets.api) getFromDb() (pyswark.gluedb.hub.Hub method) getHub() (in module pyswark.sekrets.api) getModel() (pyswark.workflow.workflow.Workflow method) getModelInput() (pyswark.workflow.workflow.Workflow method)

getModelInputNames() (pyswark.workflow.step.Step method) getModelOutput() (pyswark.workflow.workflow.Workflow method) getModelOutputNames() (pyswark.workflow.step.Step method) getNames() (pyswark.gluedb.db.Db method) getRerunState() (pyswark.workflow.runner.Runner method) getRerunWorkflow() (pyswark.workflow.runner.Runner method) getState() (pyswark.workflow.runner.Runner method) getStateInputNames() (pyswark.workflow.step.Step method) getStateOutputNames() (pyswark.workflow.step.Step method) getUri() (pyswark.lib.pydantic.base.BaseModel class method), [1] getWorkflow() (pyswark.workflow.runner.Runner method)

H

Hub (class in pyswark.gluedb.hub)

I

id (pyswark.core.models.record.Record attribute) index (pyswark.ts.tsvector.TsVector attribute) Info (class in pyswark.core.models.info) info (pyswark.core.models.record.Record attribute) Inputs (class in pyswark.tensor.tensor) inputs (pyswark.core.models.collection.Dict attribute) (pyswark.core.models.collection.List attribute) (pyswark.core.models.converter.ConverterModel attribute) (pyswark.core.models.datetime.DatetimeList attribute) (pyswark.core.models.function.FunctionModel attribute) (pyswark.core.models.primitive.Bool attribute) (pyswark.core.models.primitive.Float attribute) (pyswark.core.models.primitive.Int attribute) (pyswark.core.models.primitive.String attribute) (pyswark.query.interface.Equals attribute) (pyswark.query.interface.OneOf attribute) (pyswark.query.interface.Param attribute) (pyswark.tensor.tensor.Matrix attribute) (pyswark.tensor.tensor.Tensor attribute) (pyswark.tensor.tensor.Vector attribute) (pyswark.workflow.step.Step attribute)

Int (class in pyswark.core.models.primitive) Interface (class in pyswark.workflow.state) isUri() (in module pyswark.core.io.api)

L

List (class in pyswark.core.models.collection)

load() (pyswark.gluedb.hub.Hub method) locate() (pyswark.lib.fsspec.implementations.PythonFile method)

M

Matrix (class in pyswark.tensor.tensor) matrix (pyswark.tensor.tensor.Matrix property) merge() (pyswark.gluedb.db.Db method) mergeToDb() (pyswark.gluedb.hub.Hub method) Mixin (class in pyswark.lib.enum) MixinDb (class in pyswark.core.models.db) model (pyswark.core.models.body.Body attribute) (pyswark.workflow.step.Step attribute) model_config (pyswark.core.models.body.Body attribute) (pyswark.core.models.collection.Dict attribute) (pyswark.core.models.collection.List attribute) (pyswark.core.models.collection.Set attribute) (pyswark.core.models.collection.Tuple attribute) (pyswark.core.models.converter.ConverterModel attribute) (pyswark.core.models.datetime.Datetime attribute) (pyswark.core.models.datetime.DatetimeList attribute) (pyswark.core.models.db.Db attribute) (pyswark.core.models.db.MixinDb attribute) (pyswark.core.models.function.FunctionModel attribute) (pyswark.core.models.info.Info attribute) (pyswark.core.models.primitive.Bool attribute) (pyswark.core.models.primitive.Float attribute) (pyswark.core.models.primitive.Int attribute) (pyswark.core.models.primitive.String attribute) (pyswark.core.models.record.Record attribute) (pyswark.core.models.xputs.BaseInputs attribute) (pyswark.core.models.xputs.BaseOutputs attribute) (pyswark.lib.pydantic.base.BaseModel attribute), [1] (pyswark.lib.pydantic.base.ExtraAllowed attribute) (pyswark.lib.pydantic.base.ExtraForbidden attribute) (pyswark.query.interface.Equals attribute) (pyswark.query.interface.OneOf attribute) (pyswark.query.interface.Param attribute) (pyswark.query.interface.Query attribute) (pyswark.tensor.tensor.Inputs attribute) (pyswark.tensor.tensor.Matrix attribute) (pyswark.tensor.tensor.Tensor attribute) (pyswark.tensor.tensor.Vector attribute) (pyswark.ts.tsvector.TsVector attribute) (pyswark.workflow.runner.Runner attribute) (pyswark.workflow.state.Interface attribute) (pyswark.workflow.state.State attribute) (pyswark.workflow.state.StateWithGlueDb attribute) (pyswark.workflow.step.Step attribute) (pyswark.workflow.workflow.Extracts attribute) (pyswark.workflow.workflow.Workflow attribute)

modelInputs (pyswark.workflow.workflow.Workflow attribute) modelOutputs (pyswark.workflow.workflow.Workflow attribute) module pyswark.core.io.api pyswark.core.models.body pyswark.core.models.collection pyswark.core.models.converter pyswark.core.models.db pyswark.core.models.function pyswark.core.models.info pyswark.core.models.primitive pyswark.core.models.record pyswark.core.models.xputs pyswark.lib.aenum pyswark.lib.enum pyswark.lib.fsspec.fsspec pyswark.lib.fsspec.implementations pyswark.lib.pydantic.base pyswark.lib.pydantic.ser_des pyswark.query.interface pyswark.sekrets.api pyswark.tensor.tensor pyswark.workflow.runner pyswark.workflow.state pyswark.workflow.step pyswark.workflow.workflow mutable (pyswark.workflow.state.Interface attribute)

N

name (pyswark.core.models.info.Info attribute) (pyswark.lib.aenum.AliasEnum property)

now() (pyswark.core.models.datetime.Datetime class method)

O

OneOf (class in pyswark.query.interface) open() (in module pyswark.lib.fsspec.fsspec) (pyswark.lib.fsspec.implementations.PythonFileSystem method)

outputs (pyswark.core.models.converter.ConverterModel property) (pyswark.core.models.function.FunctionModel attribute) (pyswark.workflow.step.Step attribute)

P

Param (class in pyswark.query.interface) params (pyswark.query.interface.Query attribute) persist (pyswark.core.models.db.MixinDb attribute) persistToFile() (pyswark.core.models.db.MixinDb method) populateExtracts (pyswark.workflow.workflow.Workflow attribute) post() (pyswark.core.models.db.MixinDb method) (pyswark.workflow.state.Interface method) (pyswark.workflow.state.State method) (pyswark.workflow.state.StateWithGlueDb method) postAll() (pyswark.core.models.db.MixinDb method) postStateOutputToState() (pyswark.workflow.step.Step method) postToDb() (pyswark.gluedb.hub.Hub method) put() (pyswark.core.models.db.MixinDb method) putToDb() (pyswark.gluedb.hub.Hub method) pyswark.core.io.api module pyswark.core.models.body module pyswark.core.models.collection module pyswark.core.models.converter module pyswark.core.models.db module pyswark.core.models.function module pyswark.core.models.info module pyswark.core.models.primitive module pyswark.core.models.record module

pyswark.core.models.xputs module pyswark.lib.aenum module pyswark.lib.enum module pyswark.lib.fsspec.fsspec module pyswark.lib.fsspec.implementations module pyswark.lib.pydantic.base module pyswark.lib.pydantic.ser_des module pyswark.query.interface module pyswark.sekrets.api module pyswark.tensor.tensor module pyswark.workflow.runner module pyswark.workflow.state module pyswark.workflow.step module pyswark.workflow.workflow module PythonFile (class in pyswark.lib.fsspec.implementations) PythonFileSystem (class in pyswark.lib.fsspec.implementations)

Q

Query (class in pyswark.query.interface)

R

read() (in module pyswark.core.io.api) Record (class in pyswark.core.models.record) records (pyswark.core.models.db.MixinDb attribute) rerun() (pyswark.workflow.runner.Runner method) rerunState (pyswark.workflow.runner.Runner attribute) rerunWorkflow (pyswark.workflow.runner.Runner attribute)

resample() (pyswark.core.models.datetime.DatetimeList method) run() (pyswark.workflow.runner.Runner method) (pyswark.workflow.step.Step method) (pyswark.workflow.workflow.Workflow method) runAll() (pyswark.query.interface.Query method) runAny() (pyswark.query.interface.Query method) Runner (class in pyswark.workflow.runner)

S

Set (class in pyswark.core.models.collection) shape (pyswark.tensor.tensor.Tensor attribute) (pyswark.tensor.tensor.Tensor property) State (class in pyswark.workflow.state) state (pyswark.workflow.runner.Runner attribute)

StateWithGlueDb (class in pyswark.workflow.state) Step (class in pyswark.workflow.step) steps (pyswark.workflow.workflow.Workflow attribute) stepsRan (pyswark.workflow.workflow.Workflow attribute), [1] stepsSkipped (pyswark.workflow.workflow.Workflow attribute), [1] String (class in pyswark.core.models.primitive)

T

Tensor (class in pyswark.tensor.tensor) tensor (pyswark.tensor.tensor.Tensor attribute) (pyswark.tensor.tensor.Tensor property) toDb() (pyswark.gluedb.hub.Hub method) toDict() (in module pyswark.lib.pydantic.ser_des) (pyswark.lib.pydantic.base.BaseModel method), [1] toDtype() (pyswark.core.models.datetime.Datetime method) toJson() (in module pyswark.lib.pydantic.ser_des), [1] (pyswark.lib.pydantic.base.BaseModel method), [1]

toMapping() (pyswark.lib.aenum.AliasEnum class method) (pyswark.lib.aenum.AliasEnum method) toTimezone() (pyswark.core.models.datetime.Datetime method) tryGet() (pyswark.lib.aenum.AliasEnum class method) (pyswark.lib.aenum.AliasEnum method) TsVector (class in pyswark.ts.tsvector) Tuple (class in pyswark.core.models.collection) tzname (pyswark.core.models.datetime.Datetime attribute)

U

url (pyswark.core.models.db.MixinDb attribute)

useExtracts (pyswark.workflow.workflow.Workflow attribute)

V

validate() (pyswark.core.models.converter.ConverterModel class method) (pyswark.core.models.function.FunctionModel class method) value (pyswark.lib.aenum.AliasEnum property) values (pyswark.ts.tsvector.TsVector attribute)

valueset (pyswark.lib.aenum.Alias attribute) (pyswark.lib.aenum.Alias property) Vector (class in pyswark.tensor.tensor) vector (pyswark.tensor.tensor.Vector property)

W

Workflow (class in pyswark.workflow.workflow) workflow (pyswark.workflow.runner.Runner attribute)

write() (in module pyswark.core.io.api) (pyswark.lib.pydantic.base.BaseModel method), [1]