Omniduct
stable
Supported protocols
Installation
Quickstart
Deployment
API & IPython Magics
Extensions and Plug-ins
Contributions
Omniduct
Docs
»
Index
Edit on GitHub
Index
_
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
W
_
__init__() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
(omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
(omniduct.duct.Duct method)
(omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.base.FileSystemFile method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.registry.DuctRegistry method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
_prepare() (omniduct.duct.Duct method)
C
Cache (class in omniduct.caches.base)
cached_method() (in module omniduct.caches.base)
connect() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
(omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
(omniduct.duct.Duct method)
(omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
D
DatabaseClient (class in omniduct.databases.base)
dataframe_to_table() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
describe() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
dir() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
disconnect() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
(omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
(omniduct.duct.Duct method)
(omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
download() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
DruidClient (class in omniduct.databases.druid)
DruidClient.Type (class in omniduct.databases.druid)
Duct (class in omniduct.duct)
Duct.Type (class in omniduct.duct)
DuctRegistry (class in omniduct.registry)
E
execute() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
execute_from_file() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
execute_from_template() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
exists() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
F
FileSystemCache (class in omniduct.caches.filesystem)
FileSystemCache.Type (class in omniduct.caches.filesystem)
FileSystemClient (class in omniduct.filesystems.base)
FileSystemFile (class in omniduct.filesystems.base)
FileSystemFileDesc (class in omniduct.filesystems.base)
find() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
for_protocol() (omniduct.caches.filesystem.FileSystemCache class method)
(omniduct.databases.druid.DruidClient class method)
(omniduct.databases.hiveserver2.HiveServer2Client class method)
(omniduct.databases.neo4j.Neo4jClient class method)
(omniduct.databases.presto.PrestoClient class method)
(omniduct.databases.pyspark.PySparkClient class method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient class method)
(omniduct.duct.Duct class method)
(omniduct.filesystems.local.LocalFsClient class method)
(omniduct.filesystems.s3.S3Client class method)
(omniduct.filesystems.webhdfs.WebHdfsClient class method)
(omniduct.remotes.ssh.SSHClient class method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient class method)
G
get() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
get_bytecount() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
get_local_uri() (omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
get_metadata() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
get_proxy() (omniduct.registry.DuctRegistry method)
get_total_bytecount() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
global_writes (omniduct.filesystems.base.FileSystemClient attribute)
(omniduct.filesystems.local.LocalFsClient attribute)
(omniduct.filesystems.s3.S3Client attribute)
(omniduct.filesystems.webhdfs.WebHdfsClient attribute)
(omniduct.remotes.ssh.SSHClient attribute)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient attribute)
H
has_key() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
has_namespace() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
has_port_forward() (omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
HiveServer2Client (class in omniduct.databases.hiveserver2)
HiveServer2Client.Type (class in omniduct.databases.hiveserver2)
host (omniduct.caches.filesystem.FileSystemCache attribute)
(omniduct.databases.druid.DruidClient attribute)
(omniduct.databases.hiveserver2.HiveServer2Client attribute)
(omniduct.databases.neo4j.Neo4jClient attribute)
(omniduct.databases.presto.PrestoClient attribute)
(omniduct.databases.pyspark.PySparkClient attribute)
(omniduct.databases.sqlalchemy.SQLAlchemyClient attribute)
(omniduct.duct.Duct attribute)
(omniduct.filesystems.local.LocalFsClient attribute)
(omniduct.filesystems.s3.S3Client attribute)
(omniduct.filesystems.webhdfs.WebHdfsClient attribute)
(omniduct.remotes.ssh.SSHClient attribute)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient attribute)
I
is_connected() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
(omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
(omniduct.duct.Duct method)
(omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
is_port_bound() (omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
isdir() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
isfile() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
K
keys() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
L
listdir() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
LocalFsClient (class in omniduct.filesystems.local)
LocalFsClient.Type (class in omniduct.filesystems.local)
lookup() (omniduct.registry.DuctRegistry method)
M
MagicsProvider (class in omniduct.utils.magics)
mkdir() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
N
names (omniduct.registry.DuctRegistry attribute)
NAMESPACE_DEFAULTS_READ (omniduct.databases.base.DatabaseClient attribute)
(omniduct.databases.druid.DruidClient attribute)
(omniduct.databases.hiveserver2.HiveServer2Client attribute)
(omniduct.databases.neo4j.Neo4jClient attribute)
(omniduct.databases.presto.PrestoClient attribute)
(omniduct.databases.pyspark.PySparkClient attribute)
(omniduct.databases.sqlalchemy.SQLAlchemyClient attribute)
NAMESPACE_DEFAULTS_WRITE (omniduct.databases.base.DatabaseClient attribute)
(omniduct.databases.druid.DruidClient attribute)
(omniduct.databases.hiveserver2.HiveServer2Client attribute)
(omniduct.databases.neo4j.Neo4jClient attribute)
(omniduct.databases.presto.PrestoClient attribute)
(omniduct.databases.pyspark.PySparkClient attribute)
(omniduct.databases.sqlalchemy.SQLAlchemyClient attribute)
namespaces (omniduct.caches.base.Cache attribute)
(omniduct.caches.filesystem.FileSystemCache attribute)
Neo4jClient (class in omniduct.databases.neo4j)
Neo4jClient.Type (class in omniduct.databases.neo4j)
new() (omniduct.registry.DuctRegistry method)
O
omniduct.caches.base (module)
omniduct.filesystems.base (module)
omniduct.registry (module)
open() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
P
ParamikoSSHClient (class in omniduct.remotes.ssh_paramiko)
ParamikoSSHClient.Type (class in omniduct.remotes.ssh_paramiko)
password (omniduct.caches.filesystem.FileSystemCache attribute)
(omniduct.databases.druid.DruidClient attribute)
(omniduct.databases.hiveserver2.HiveServer2Client attribute)
(omniduct.databases.neo4j.Neo4jClient attribute)
(omniduct.databases.presto.PrestoClient attribute)
(omniduct.databases.pyspark.PySparkClient attribute)
(omniduct.databases.sqlalchemy.SQLAlchemyClient attribute)
(omniduct.duct.Duct attribute)
(omniduct.filesystems.local.LocalFsClient attribute)
(omniduct.filesystems.s3.S3Client attribute)
(omniduct.filesystems.webhdfs.WebHdfsClient attribute)
(omniduct.remotes.ssh.SSHClient attribute)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient attribute)
path_basename() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
path_cwd (omniduct.filesystems.base.FileSystemClient attribute)
(omniduct.filesystems.local.LocalFsClient attribute)
(omniduct.filesystems.s3.S3Client attribute)
(omniduct.filesystems.webhdfs.WebHdfsClient attribute)
(omniduct.remotes.ssh.SSHClient attribute)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient attribute)
path_dirname() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
path_home (omniduct.filesystems.base.FileSystemClient attribute)
(omniduct.filesystems.local.LocalFsClient attribute)
(omniduct.filesystems.s3.S3Client attribute)
(omniduct.filesystems.webhdfs.WebHdfsClient attribute)
(omniduct.remotes.base.RemoteClient attribute)
(omniduct.remotes.ssh.SSHClient attribute)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient attribute)
path_join() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
path_normpath() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
path_separator (omniduct.filesystems.base.FileSystemClient attribute)
(omniduct.filesystems.local.LocalFsClient attribute)
(omniduct.filesystems.s3.S3Client attribute)
(omniduct.filesystems.webhdfs.WebHdfsClient attribute)
(omniduct.remotes.base.RemoteClient attribute)
(omniduct.remotes.ssh.SSHClient attribute)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient attribute)
populate_namespace() (omniduct.registry.DuctRegistry method)
port (omniduct.caches.filesystem.FileSystemCache attribute)
(omniduct.databases.druid.DruidClient attribute)
(omniduct.databases.hiveserver2.HiveServer2Client attribute)
(omniduct.databases.neo4j.Neo4jClient attribute)
(omniduct.databases.presto.PrestoClient attribute)
(omniduct.databases.pyspark.PySparkClient attribute)
(omniduct.databases.sqlalchemy.SQLAlchemyClient attribute)
(omniduct.duct.Duct attribute)
(omniduct.filesystems.local.LocalFsClient attribute)
(omniduct.filesystems.s3.S3Client attribute)
(omniduct.filesystems.webhdfs.WebHdfsClient attribute)
(omniduct.remotes.ssh.SSHClient attribute)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient attribute)
port_forward() (omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
port_forward_stop() (omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
port_forward_stopall() (omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
prepare() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
(omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
(omniduct.duct.Duct method)
(omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
prepare_smartcards() (omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
PrestoClient (class in omniduct.databases.presto)
PrestoClient.Type (class in omniduct.databases.presto)
prune() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
PySparkClient (class in omniduct.databases.pyspark)
PySparkClient.Type (class in omniduct.databases.pyspark)
Q
query() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
query_from_file() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
query_from_template() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
query_to_table() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
R
read_only (omniduct.filesystems.base.FileSystemClient attribute)
(omniduct.filesystems.local.LocalFsClient attribute)
(omniduct.filesystems.s3.S3Client attribute)
(omniduct.filesystems.webhdfs.WebHdfsClient attribute)
(omniduct.remotes.ssh.SSHClient attribute)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient attribute)
reconnect() (omniduct.caches.filesystem.FileSystemCache method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
(omniduct.duct.Duct method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
register() (omniduct.registry.DuctRegistry method)
register_from_config() (omniduct.registry.DuctRegistry method)
register_magics() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
RemoteClient (class in omniduct.remotes.base)
remove() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
reset() (omniduct.caches.filesystem.FileSystemCache method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
(omniduct.duct.Duct method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
S
S3Client (class in omniduct.filesystems.s3)
S3Client.Type (class in omniduct.filesystems.s3)
schemas (omniduct.databases.hiveserver2.HiveServer2Client attribute)
(omniduct.databases.presto.PrestoClient attribute)
(omniduct.databases.sqlalchemy.SQLAlchemyClient attribute)
session_properties (omniduct.databases.base.DatabaseClient attribute)
(omniduct.databases.druid.DruidClient attribute)
(omniduct.databases.hiveserver2.HiveServer2Client attribute)
(omniduct.databases.neo4j.Neo4jClient attribute)
(omniduct.databases.presto.PrestoClient attribute)
(omniduct.databases.pyspark.PySparkClient attribute)
(omniduct.databases.sqlalchemy.SQLAlchemyClient attribute)
set() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
set_metadata() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
show_port_forwards() (omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
showdir() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
SQLAlchemyClient (class in omniduct.databases.sqlalchemy)
SQLAlchemyClient.Type (class in omniduct.databases.sqlalchemy)
SSHClient (class in omniduct.remotes.ssh)
SSHClient.Type (class in omniduct.remotes.ssh)
statement_cleanup() (omniduct.databases.base.DatabaseClient class method)
(omniduct.databases.druid.DruidClient class method)
(omniduct.databases.hiveserver2.HiveServer2Client class method)
(omniduct.databases.neo4j.Neo4jClient class method)
(omniduct.databases.presto.PrestoClient class method)
(omniduct.databases.pyspark.PySparkClient class method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient class method)
statement_hash() (omniduct.databases.base.DatabaseClient class method)
(omniduct.databases.druid.DruidClient class method)
(omniduct.databases.hiveserver2.HiveServer2Client class method)
(omniduct.databases.neo4j.Neo4jClient class method)
(omniduct.databases.presto.PrestoClient class method)
(omniduct.databases.pyspark.PySparkClient class method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient class method)
stream() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
stream_to_file() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
T
table_desc() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
table_drop() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
table_exists() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
table_head() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
table_list() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
table_partition_cols() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
table_props() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
template_add() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
template_get() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
template_names (omniduct.databases.base.DatabaseClient attribute)
(omniduct.databases.druid.DruidClient attribute)
(omniduct.databases.hiveserver2.HiveServer2Client attribute)
(omniduct.databases.neo4j.Neo4jClient attribute)
(omniduct.databases.presto.PrestoClient attribute)
(omniduct.databases.pyspark.PySparkClient attribute)
(omniduct.databases.sqlalchemy.SQLAlchemyClient attribute)
template_render() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
template_variables() (omniduct.databases.base.DatabaseClient method)
(omniduct.databases.druid.DruidClient method)
(omniduct.databases.hiveserver2.HiveServer2Client method)
(omniduct.databases.neo4j.Neo4jClient method)
(omniduct.databases.presto.PrestoClient method)
(omniduct.databases.pyspark.PySparkClient method)
(omniduct.databases.sqlalchemy.SQLAlchemyClient method)
U
unset() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
unset_namespace() (omniduct.caches.base.Cache method)
(omniduct.caches.filesystem.FileSystemCache method)
update_host_keys() (omniduct.remotes.ssh.SSHClient method)
upload() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
username (omniduct.caches.filesystem.FileSystemCache attribute)
(omniduct.databases.druid.DruidClient attribute)
(omniduct.databases.hiveserver2.HiveServer2Client attribute)
(omniduct.databases.neo4j.Neo4jClient attribute)
(omniduct.databases.presto.PrestoClient attribute)
(omniduct.databases.pyspark.PySparkClient attribute)
(omniduct.databases.sqlalchemy.SQLAlchemyClient attribute)
(omniduct.duct.Duct attribute)
(omniduct.filesystems.local.LocalFsClient attribute)
(omniduct.filesystems.s3.S3Client attribute)
(omniduct.filesystems.webhdfs.WebHdfsClient attribute)
(omniduct.remotes.ssh.SSHClient attribute)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient attribute)
W
walk() (omniduct.filesystems.base.FileSystemClient method)
(omniduct.filesystems.local.LocalFsClient method)
(omniduct.filesystems.s3.S3Client method)
(omniduct.filesystems.webhdfs.WebHdfsClient method)
(omniduct.remotes.base.RemoteClient method)
(omniduct.remotes.ssh.SSHClient method)
(omniduct.remotes.ssh_paramiko.ParamikoSSHClient method)
WebHdfsClient (class in omniduct.filesystems.webhdfs)
WebHdfsClient.Type (class in omniduct.filesystems.webhdfs)
Read the Docs
v: stable
Versions
latest
stable
Downloads
pdf
html
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.