Index

A

AccumulatingSnapshotFactTable (class in pygrametl.tables) additions() (pygrametl.drawntabletesting.Table method) addpart() (pygrametl.tables.BasePartitioner method) Aggregator (class in pygrametl.aggregators)

assertDisjoint() (pygrametl.drawntabletesting.Table method) assertEqual() (pygrametl.drawntabletesting.Table method) assertSubset() (pygrametl.drawntabletesting.Table method) Avg (class in pygrametl.aggregators) awaitingrows (pygrametl.tables.BatchFactTable property)

B

BackgroundJDBCConnectionWrapper (class in pygrametl.JDBCConnectionWrapper) BackgroundSource (in module pygrametl.datasources) BasePartitioner (class in pygrametl.tables)

BatchFactTable (class in pygrametl.tables) BulkDimension (class in pygrametl.tables) BulkFactTable (class in pygrametl.tables)

C

CachedBulkDimension (class in pygrametl.tables) CachedDimension (class in pygrametl.tables) clear() (pygrametl.drawntabletesting.Table class method) close() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method) (pygrametl.jythonmultiprocessing.JoinableQueue method) closecurrent() (pygrametl.tables.SlowlyChangingDimension method) commit() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method) ConditionalStep (class in pygrametl.steps) ConnectionWrapper (class in pygrametl)

connectionwrapper() (in module pygrametl.drawntabletesting) connectsteps() (in module pygrametl.steps) copy() (in module pygrametl) CopyStep (class in pygrametl.steps) Count (class in pygrametl.aggregators) CountDistinct (class in pygrametl.aggregators) create() (pygrametl.drawntabletesting.Table method) createflow() (in module pygrametl.parallel) CrossTabbingSource (class in pygrametl.datasources) CSVSource (in module pygrametl.datasources) cursor() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method)

D

daemon (pygrametl.jythonmultiprocessing.Process property) datereader() (in module pygrametl) datespan() (in module pygrametl) datetimereader() (in module pygrametl) Decoupled (class in pygrametl.parallel) DecoupledDimension (class in pygrametl.tables) DecoupledFactTable (class in pygrametl.tables) defaultworker() (pygrametl.steps.ConditionalStep method) (pygrametl.steps.CopyStep method) (pygrametl.steps.DimensionStep method) (pygrametl.steps.MappingStep method) (pygrametl.steps.PrintStep method) (pygrametl.steps.RenamingFromToStep method) (pygrametl.steps.RenamingToFromStep method) (pygrametl.steps.SCDimensionStep method) (pygrametl.steps.Step method) (pygrametl.steps.ValueMappingStep method)

definequote() (in module pygrametl.tables) Dimension (class in pygrametl.tables) DimensionPartitioner (class in pygrametl.tables) DimensionStep (class in pygrametl.steps) drop() (pygrametl.drawntabletesting.Table method) droppart() (pygrametl.tables.BasePartitioner method) DynamicForEachSource (class in pygrametl.datasources)

E

empty() (pygrametl.jythonmultiprocessing.Queue method) endload() (in module pygrametl) (pygrametl.tables.BasePartitioner method) (pygrametl.tables.BatchFactTable method) (pygrametl.tables.DecoupledDimension method) (pygrametl.tables.DecoupledFactTable method) (pygrametl.tables.Dimension method) (pygrametl.tables.FactTable method) (pygrametl.tables.SnowflakedDimension method) (pygrametl.tables.SubprocessFactTable method) endsplits() (in module pygrametl.parallel) ensure() (pygrametl.drawntabletesting.Table method) (pygrametl.tables.AccumulatingSnapshotFactTable method) (pygrametl.tables.DecoupledDimension method) (pygrametl.tables.DecoupledFactTable method) (pygrametl.tables.Dimension method) (pygrametl.tables.DimensionPartitioner method) (pygrametl.tables.FactTable method) (pygrametl.tables.FactTablePartitioner method) (pygrametl.tables.SnowflakedDimension method)

execute() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method) executemany() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method)

F

FactTable (class in pygrametl.tables) FactTablePartitioner (class in pygrametl.tables) fetchalltuples() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method) fetchmanytuples() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method) fetchone() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method)

fetchonetuple() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method) FIFODict (in module pygrametl.FIFODict) FilteringSource (class in pygrametl.datasources) finish() (pygrametl.aggregators.Aggregator method) (pygrametl.aggregators.Avg method) (pygrametl.aggregators.CountDistinct method) (pygrametl.aggregators.SimpleAggregator method) full() (pygrametl.jythonmultiprocessing.Queue method)

G

GarbageStep (class in pygrametl.steps) get() (pygrametl.jythonmultiprocessing.Queue method) get_nowait() (pygrametl.jythonmultiprocessing.Queue method) getbool() (in module pygrametl) getbykey() (pygrametl.tables.BulkDimension method) (pygrametl.tables.CachedBulkDimension method) (pygrametl.tables.DecoupledDimension method) (pygrametl.tables.Dimension method) (pygrametl.tables.DimensionPartitioner method) (pygrametl.tables.SnowflakedDimension method) getbyvals() (pygrametl.tables.DecoupledDimension method) (pygrametl.tables.Dimension method) (pygrametl.tables.DimensionPartitioner method) (pygrametl.tables.SnowflakedDimension method) getdate() (in module pygrametl) getdbfriendlystr() (in module pygrametl) getdefaulttargetconnection() (in module pygrametl) getfloat() (in module pygrametl)

getint() (in module pygrametl) getlong() (in module pygrametl) getpart() (pygrametl.tables.BasePartitioner method) (pygrametl.tables.DimensionPartitioner method) (pygrametl.tables.FactTablePartitioner method) getsharedsequencefactory() (in module pygrametl.parallel) getSQLToCreate() (pygrametl.drawntabletesting.Table method) getSQLToInsert() (pygrametl.drawntabletesting.Table method) getstep() (pygrametl.steps.Step class method) getstr() (in module pygrametl) getstrippedstr() (in module pygrametl) getstrornullvalue() (in module pygrametl) gettimestamp() (in module pygrametl) getunderlyingmodule() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method) getvalue() (in module pygrametl) getvalueor() (in module pygrametl)

H

HashJoiningSource (class in pygrametl.datasources)

I

insert() (pygrametl.tables.BulkDimension method) (pygrametl.tables.CachedBulkDimension method) (pygrametl.tables.DecoupledDimension method) (pygrametl.tables.DecoupledFactTable method) (pygrametl.tables.Dimension method) (pygrametl.tables.DimensionPartitioner method) (pygrametl.tables.FactTable method) (pygrametl.tables.FactTablePartitioner method) (pygrametl.tables.SnowflakedDimension method) (pygrametl.tables.SubprocessFactTable method)

J

JDBCConnectionWrapper (class in pygrametl.JDBCConnectionWrapper) join() (pygrametl.jythonmultiprocessing.Queue method)

JoinableQueue (class in pygrametl.jythonmultiprocessing) JoiningSource (in module pygrametl.datasources)

K

keepasis() (in module pygrametl)

key() (pygrametl.drawntabletesting.Table method)

L

lookup() (pygrametl.tables.CachedBulkDimension method) (pygrametl.tables.CachedDimension method) (pygrametl.tables.DecoupledDimension method) (pygrametl.tables.DecoupledFactTable method) (pygrametl.tables.Dimension method) (pygrametl.tables.DimensionPartitioner method) (pygrametl.tables.FactTable method) (pygrametl.tables.FactTablePartitioner method) (pygrametl.tables.SlowlyChangingDimension method) (pygrametl.tables.SnowflakedDimension method)

lookupasof() (pygrametl.tables.SlowlyChangingDimension method)

M

MappingSource (class in pygrametl.datasources) MappingStep (class in pygrametl.steps) Max (class in pygrametl.aggregators) MergeJoiningSource (class in pygrametl.datasources) Min (class in pygrametl.aggregators) module pygrametl pygrametl.aggregators pygrametl.datasources pygrametl.drawntabletesting pygrametl.FIFODict pygrametl.JDBCConnectionWrapper pygrametl.jythonmultiprocessing pygrametl.parallel pygrametl.steps pygrametl.tables

N

name (pygrametl.jythonmultiprocessing.Process property) name() (pygrametl.steps.Step method)

next() (pygrametl.datasources.TypedCSVSource method) now() (in module pygrametl)

P

PandasSource (class in pygrametl.datasources) parts() (pygrametl.tables.BasePartitioner method) pid (pygrametl.jythonmultiprocessing.Process attribute) PrintStep (class in pygrametl.steps) Process (class in pygrametl.jythonmultiprocessing) process() (pygrametl.aggregators.Aggregator method) (pygrametl.aggregators.Avg method) (pygrametl.aggregators.Count method) (pygrametl.aggregators.CountDistinct method) (pygrametl.aggregators.Max method) (pygrametl.aggregators.Min method) (pygrametl.aggregators.SimpleAggregator method) (pygrametl.aggregators.Sum method) (pygrametl.steps.GarbageStep method) (pygrametl.steps.Step method) ProcessSource (class in pygrametl.datasources) project() (in module pygrametl) put() (pygrametl.jythonmultiprocessing.Queue method) put_nowait() (pygrametl.jythonmultiprocessing.Queue method) pygrametl module

pygrametl.aggregators module pygrametl.datasources module pygrametl.drawntabletesting module pygrametl.FIFODict module pygrametl.JDBCConnectionWrapper module pygrametl.jythonmultiprocessing module pygrametl.parallel module pygrametl.steps module pygrametl.tables module Python Enhancement Proposals PEP 249, [1], [2], [3], [4], [5], [6], [7], [8], [9], [10], [11], [12], [13], [14], [15], [16], [17], [18] PEP 249#paramstyle

Q

qsize() (pygrametl.jythonmultiprocessing.Queue method)

Queue (class in pygrametl.jythonmultiprocessing)

R

rename() (in module pygrametl) renamefromto() (in module pygrametl) renametofrom() (in module pygrametl) RenamingFromToStep (class in pygrametl.steps) RenamingStep (in module pygrametl.steps) RenamingToFromStep (class in pygrametl.steps) reset() (pygrametl.drawntabletesting.Table method) resultnames() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method)

rollback() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method) RoundRobinSource (class in pygrametl.datasources) rowcount() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method) rowfactory() (in module pygrametl) (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method)

S

scdensure() (pygrametl.tables.DecoupledDimension method) (pygrametl.tables.DimensionPartitioner method) (pygrametl.tables.SlowlyChangingDimension method) (pygrametl.tables.SnowflakedDimension method) (pygrametl.tables.TypeOneSlowlyChangingDimension method) SCDimensionStep (class in pygrametl.steps) setasdefault() (pygrametl.ConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method) (pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method) setdefaults() (in module pygrametl) shareconnectionwrapper() (in module pygrametl.parallel)

shutdowndecoupled() (pygrametl.parallel.Decoupled method) SimpleAggregator (class in pygrametl.aggregators) SlowlyChangingDimension (class in pygrametl.tables) SnowflakedDimension (class in pygrametl.tables) SourceStep (class in pygrametl.steps) splitpoint() (in module pygrametl.parallel) SQLSource (class in pygrametl.datasources) SQLTransformingSource (class in pygrametl.datasources) start() (pygrametl.steps.SourceStep method) Step (class in pygrametl.steps) SubprocessFactTable (class in pygrametl.tables) Sum (class in pygrametl.aggregators)

T

Table (class in pygrametl.drawntabletesting) task_done() (pygrametl.jythonmultiprocessing.Queue method) today() (in module pygrametl) tolower() (in module pygrametl)

toupper() (in module pygrametl) TransformingSource (class in pygrametl.datasources) TypedCSVSource (class in pygrametl.datasources) TypeOneSlowlyChangingDimension (class in pygrametl.tables)

U

UnionSource (class in pygrametl.datasources) update() (pygrametl.drawntabletesting.Table method) (pygrametl.tables.AccumulatingSnapshotFactTable method) (pygrametl.tables.Dimension method) (pygrametl.tables.DimensionPartitioner method) (pygrametl.tables.SnowflakedDimension method)

V

Value (class in pygrametl.jythonmultiprocessing)

ValueMappingStep (class in pygrametl.steps)

Y

ymdhmsparser() (in module pygrametl)

ymdparser() (in module pygrametl)