Index

A | B | C | D | E | F | G | H | I | J | K | L | M | N | P | Q | R | S | T | U | V | Y

A

addpart() (pygrametl.tables.BasePartitioner method)
Aggregator (class in pygrametl.aggregators)
Avg (class in pygrametl.aggregators)

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)
close() (pygrametl.ConnectionWrapper method)
(pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method)
(pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method)
(pygrametl.jythonmultiprocessing.JoinableQueue method)
commit() (pygrametl.ConnectionWrapper method)
(pygrametl.JDBCConnectionWrapper.BackgroundJDBCConnectionWrapper method)
(pygrametl.JDBCConnectionWrapper.JDBCConnectionWrapper method)
ConditionalStep (class in pygrametl.steps)
ConnectionWrapper (class in pygrametl)
connectsteps() (in module pygrametl.steps)
copy() (in module pygrametl)
CopyStep (class in pygrametl.steps)
Count (class in pygrametl.aggregators)
CountDistinct (class in pygrametl.aggregators)
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 attribute)
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)
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.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)
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)

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)

M

MappingStep (class in pygrametl.steps)
Max (class in pygrametl.aggregators)
MergeJoiningSource (class in pygrametl.datasources)
Min (class in pygrametl.aggregators)

N

name (pygrametl.jythonmultiprocessing.Process attribute)
name() (pygrametl.steps.Step method)
next() (pygrametl.datasources.TypedCSVSource method)
now() (in module pygrametl)

P

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.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]
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)
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)
start() (pygrametl.steps.SourceStep method)
Step (class in pygrametl.steps)
SubprocessFactTable (class in pygrametl.tables)
Sum (class in pygrametl.aggregators)

T

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.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)