napkin-1.0.0
Safe HaskellNone
LanguageGHC2021

Napkin.Run.BigQuery

Documentation

newtype BigQueryRunError #

Constructors

ProtoErrors (NonEmpty ErrorProto) 

Instances

Instances details
Exception BigQueryRunError # 
Instance details

Defined in Napkin.Run.BigQuery.Types

Methods

toException :: BigQueryRunError -> SomeException #

fromException :: SomeException -> Maybe BigQueryRunError #

displayException :: BigQueryRunError -> String #

Show BigQueryRunError # 
Instance details

Defined in Napkin.Run.BigQuery.Types

Methods

showsPrec :: Int -> BigQueryRunError -> ShowS #

show :: BigQueryRunError -> String #

showList :: [BigQueryRunError] -> ShowS #

Eq BigQueryRunError # 
Instance details

Defined in Napkin.Run.BigQuery.Types

Methods

(==) :: BigQueryRunError -> BigQueryRunError -> Bool #

(/=) :: BigQueryRunError -> BigQueryRunError -> Bool #

data family BackendConn b #

Instances

Instances details
Generic (BackendConn Postgres) # 
Instance details

Defined in Napkin.Run.Postgres

Associated Types

type Rep (BackendConn Postgres) 
Instance details

Defined in Napkin.Run.Postgres

type Rep (BackendConn Postgres) = D1 ('MetaData "BackendConn" "Napkin.Run.Postgres" "napkin-1.0.0-5YkWAC9Wc776PT0LDghaFb" 'False) (C1 ('MetaCons "PostgresConn" 'PrefixI 'True) (S1 ('MetaSel ('Just "getConnectionString") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ConnectionString) :*: S1 ('MetaSel ('Just "getPostgresConn") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Pool Connection))))

Methods

from :: BackendConn Postgres -> Rep (BackendConn Postgres) x #

to :: Rep (BackendConn Postgres) x -> BackendConn Postgres #

data BackendConn BigQuery # 
Instance details

Defined in Napkin.Run.BigQuery

data BackendConn BigQuery = BigQueryEnv {}
data BackendConn MsSql # 
Instance details

Defined in Napkin.Run.MsSql

data BackendConn MsSql = MsSqlConn {}
data BackendConn Postgres # 
Instance details

Defined in Napkin.Run.Postgres

data BackendConn Postgres = PostgresConn {}
data BackendConn Redshift # 
Instance details

Defined in Napkin.Run.Redshift

data BackendConn Redshift = RedshiftConn ConnectionString (Pool Connection)
data BackendConn Sqlite # 
Instance details

Defined in Napkin.Run.Sqlite

data BackendConn Sqlite = SqliteConn {}
type Rep (BackendConn Postgres) # 
Instance details

Defined in Napkin.Run.Postgres

type Rep (BackendConn Postgres) = D1 ('MetaData "BackendConn" "Napkin.Run.Postgres" "napkin-1.0.0-5YkWAC9Wc776PT0LDghaFb" 'False) (C1 ('MetaCons "PostgresConn" 'PrefixI 'True) (S1 ('MetaSel ('Just "getConnectionString") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ConnectionString) :*: S1 ('MetaSel ('Just "getPostgresConn") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Pool Connection))))

data family BackendSchemaField (bk :: k) #

Instances

Instances details
Command GetRelationSchema [BackendSchemaField BigQuery] BigQuery # 
Instance details

Defined in Napkin.Run.BigQuery

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> GetRelationSchema -> m [BackendSchemaField BigQuery] #

Command GetRelationSchema [BackendSchemaField MsSql] MsSql # 
Instance details

Defined in Napkin.Run.MsSql

Methods

execCommand :: MonadNapkin MsSql m => BackendConn MsSql -> GetRelationSchema -> m [BackendSchemaField MsSql] #

Command GetRelationSchema [BackendSchemaField Postgres] Postgres # 
Instance details

Defined in Napkin.Run.Postgres

Methods

execCommand :: MonadNapkin Postgres m => BackendConn Postgres -> GetRelationSchema -> m [BackendSchemaField Postgres] #

Command GetRelationSchema [BackendSchemaField Redshift] Redshift # 
Instance details

Defined in Napkin.Run.Redshift

Methods

execCommand :: MonadNapkin Redshift m => BackendConn Redshift -> GetRelationSchema -> m [BackendSchemaField Redshift] #

Command GetRelationSchema [BackendSchemaField Sqlite] Sqlite # 
Instance details

Defined in Napkin.Run.Sqlite

Methods

execCommand :: MonadNapkin Sqlite m => BackendConn Sqlite -> GetRelationSchema -> m [BackendSchemaField Sqlite] #

Show (BackendSchemaField BigQuery) # 
Instance details

Defined in Napkin.Run.BigQuery

Methods

showsPrec :: Int -> BackendSchemaField BigQuery -> ShowS #

show :: BackendSchemaField BigQuery -> String #

showList :: [BackendSchemaField BigQuery] -> ShowS #

Show (BackendSchemaField MsSql) # 
Instance details

Defined in Napkin.Run.MsSql

Methods

showsPrec :: Int -> BackendSchemaField MsSql -> ShowS #

show :: BackendSchemaField MsSql -> String #

showList :: [BackendSchemaField MsSql] -> ShowS #

Show (BackendSchemaField Postgres) # 
Instance details

Defined in Napkin.Run.Postgres

Methods

showsPrec :: Int -> BackendSchemaField Postgres -> ShowS #

show :: BackendSchemaField Postgres -> String #

showList :: [BackendSchemaField Postgres] -> ShowS #

Show (BackendSchemaField Redshift) # 
Instance details

Defined in Napkin.Run.Redshift

Methods

showsPrec :: Int -> BackendSchemaField Redshift -> ShowS #

show :: BackendSchemaField Redshift -> String #

showList :: [BackendSchemaField Redshift] -> ShowS #

Show (BackendSchemaField Sqlite) # 
Instance details

Defined in Napkin.Run.Sqlite

Methods

showsPrec :: Int -> BackendSchemaField Sqlite -> ShowS #

show :: BackendSchemaField Sqlite -> String #

showList :: [BackendSchemaField Sqlite] -> ShowS #

Eq (BackendSchemaField BigQuery) # 
Instance details

Defined in Napkin.Run.BigQuery

Methods

(==) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool #

(/=) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool #

Eq (BackendSchemaField MsSql) # 
Instance details

Defined in Napkin.Run.MsSql

Methods

(==) :: BackendSchemaField MsSql -> BackendSchemaField MsSql -> Bool #

(/=) :: BackendSchemaField MsSql -> BackendSchemaField MsSql -> Bool #

Eq (BackendSchemaField Postgres) # 
Instance details

Defined in Napkin.Run.Postgres

Methods

(==) :: BackendSchemaField Postgres -> BackendSchemaField Postgres -> Bool #

(/=) :: BackendSchemaField Postgres -> BackendSchemaField Postgres -> Bool #

Eq (BackendSchemaField Redshift) # 
Instance details

Defined in Napkin.Run.Redshift

Methods

(==) :: BackendSchemaField Redshift -> BackendSchemaField Redshift -> Bool #

(/=) :: BackendSchemaField Redshift -> BackendSchemaField Redshift -> Bool #

Eq (BackendSchemaField Sqlite) # 
Instance details

Defined in Napkin.Run.Sqlite

Methods

(==) :: BackendSchemaField Sqlite -> BackendSchemaField Sqlite -> Bool #

(/=) :: BackendSchemaField Sqlite -> BackendSchemaField Sqlite -> Bool #

FromRow (BackendSchemaField Sqlite) # 
Instance details

Defined in Napkin.Run.Sqlite

Methods

fromRow :: RowParser (BackendSchemaField Sqlite) #

data BackendSchemaField BigQuery # 
Instance details

Defined in Napkin.Run.BigQuery

data BackendSchemaField BigQuery = BigQuerySchemaField TableFieldSchema
data BackendSchemaField MsSql # 
Instance details

Defined in Napkin.Run.MsSql

data BackendSchemaField MsSql = MsSqlSchemaField MsSchemaField
data BackendSchemaField Postgres # 
Instance details

Defined in Napkin.Run.Postgres

data BackendSchemaField Postgres = PostgresSchemaField PGSchemaField
data BackendSchemaField Redshift # 
Instance details

Defined in Napkin.Run.Redshift

data BackendSchemaField Redshift = RedshiftSchemaField PGSchemaField
data BackendSchemaField Sqlite # 
Instance details

Defined in Napkin.Run.Sqlite

data BackendSchemaField Sqlite = SqliteSchemaField {}

mkBigQueryEnvWithCredentials :: (MonadCatch m, Katip m) => Maybe Text -> Credentials BigQueryScopes -> DbBackendOptions BigQuery -> BQProjectId -> m (BackendConn BigQuery) #

mkBigQueryEnvWithJsonCredentials :: (MonadCatch m, Katip m) => Maybe Text -> CredentialsJson -> DbBackendOptions BigQuery -> BQProjectId -> m (BackendConn BigQuery) #

mkBigQueryEnvWithCredentialsFile :: (MonadCatch m, Katip m) => FilePath -> DbBackendOptions BigQuery -> BQProjectId -> m (BackendConn BigQuery) #

bqValidator :: (SpecDependency -> Ref Table) -> SpecsDeps -> [Text] #

parseBigQueryURI :: Text -> Maybe BigQueryURI #

data BigQueryURI #

Constructors

BigQueryURI 

Fields

calcCost :: MonadNapkin BigQuery m => Job -> m Job #

executePoll :: Katip m => GoogleEnv -> BigQueryJobsInsert -> BQProjectId -> m Job #

jobInsert :: BQProjectId -> JobConfiguration -> BigQueryJobsInsert #

jobConfiguration :: Labels -> JobConfiguration #

jobConfigurationQuery :: Text -> JobConfigurationQuery #

Orphan instances

Backend BigQuery # 
Instance details

Associated Types

data BackendConn BigQuery 
Instance details

Defined in Napkin.Run.BigQuery

data BackendConn BigQuery = BigQueryEnv {}

Methods

backendQuery :: (MonadNapkin BigQuery m, RenderSql q BigQuery) => BackendConn BigQuery -> q -> m [Map Text Value] #

backendConnectionString :: BackendConn BigQuery -> ConnectionString #

RunBackendConn BigQuery # 
Instance details

Methods

runBackendConn :: LogEnv -> DbBackendOptions BigQuery -> ConnectionString -> AppName -> Maybe CredentialsPath -> SpecFile -> Maybe AuthPort -> (Pipeline -> BackendConn BigQuery -> IO a) -> IO a #

HasBackendSchemaField BigQuery # 
Instance details

Associated Types

data BackendSchemaField BigQuery 
Instance details

Defined in Napkin.Run.BigQuery

data BackendSchemaField BigQuery = BigQuerySchemaField TableFieldSchema

Methods

fieldName :: BackendSchemaField BigQuery -> Text #

fieldType :: BackendSchemaField BigQuery -> Type #

CSVImport BigQuery # 
Instance details

Methods

chunkLimit :: Int #

isEnabled :: Bool #

HasBackendQueryStats BigQuery # 
Instance details

Associated Types

data BackendQueryStats BigQuery 
Instance details

Defined in Napkin.Run.BigQuery

data BackendQueryStats BigQuery = BackendQueryStats {}

Methods

prettyPrint :: BackendQueryStats BigQuery -> Maybe String #

Command AEDA TableDiagnostics BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> AEDA -> m TableDiagnostics #

Command AnnotateCommand () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> AnnotateCommand -> m () #

Command CheckTableExists Bool BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CheckTableExists -> m Bool #

Command CopyTable () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CopyTable -> m () #

Command DeleteFrom () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> DeleteFrom -> m () #

Command DropTable () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> DropTable -> m () #

Command DropView () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> DropView -> m () #

Command GetTableKind TableKind BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> GetTableKind -> m TableKind #

Command InsertIntoQuery () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> InsertIntoQuery -> m () #

Command InsertIntoTable () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> InsertIntoTable -> m () #

Command ReadAnnotationCommand TableAnnotations BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> ReadAnnotationCommand -> m TableAnnotations #

Command RenameTable () BigQuery #

BQ implements rename via copy-then-drop

Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> RenameTable -> m () #

Command Grant () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> Grant -> m () #

Command UpdateQuery () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> UpdateQuery -> m () #

Command GetRelationSchema [BackendSchemaField BigQuery] BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> GetRelationSchema -> m [BackendSchemaField BigQuery] #

Command ListTables (Set ListedTable) BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> ListTables -> m (Set ListedTable) #

Command NormalizeTableNames (Map (Ref Table) NormalizedTable) BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> NormalizeTableNames -> m (Map (Ref Table) NormalizedTable) #

Command (CreateMaterializedView MaterializedViewMeta) () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CreateMaterializedView MaterializedViewMeta -> m () #

Command (CreateTable TableMeta) () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CreateTable TableMeta -> m () #

Command (CreateTable ()) () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CreateTable () -> m () #

Command (CreateTableDDL TableMeta) () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CreateTableDDL TableMeta -> m () #

Command (CreateView ViewMeta) () BigQuery # 
Instance details

Methods

execCommand :: MonadNapkin BigQuery m => BackendConn BigQuery -> CreateView ViewMeta -> m () #

FromJSON (BackendQueryStats BigQuery) # 
Instance details

Methods

parseJSON :: Value -> Parser (BackendQueryStats BigQuery) #

parseJSONList :: Value -> Parser [BackendQueryStats BigQuery] #

omittedField :: Maybe (BackendQueryStats BigQuery) #

ToJSON (BackendQueryStats BigQuery) # 
Instance details

Methods

toJSON :: BackendQueryStats BigQuery -> Value #

toEncoding :: BackendQueryStats BigQuery -> Encoding #

toJSONList :: [BackendQueryStats BigQuery] -> Value #

toEncodingList :: [BackendQueryStats BigQuery] -> Encoding #

omitField :: BackendQueryStats BigQuery -> Bool #

Monoid (BackendQueryStats BigQuery) # 
Instance details

Methods

mempty :: BackendQueryStats BigQuery #

mappend :: BackendQueryStats BigQuery -> BackendQueryStats BigQuery -> BackendQueryStats BigQuery #

mconcat :: [BackendQueryStats BigQuery] -> BackendQueryStats BigQuery #

Semigroup (BackendQueryStats BigQuery) # 
Instance details

Methods

(<>) :: BackendQueryStats BigQuery -> BackendQueryStats BigQuery -> BackendQueryStats BigQuery #

sconcat :: NonEmpty (BackendQueryStats BigQuery) -> BackendQueryStats BigQuery #

stimes :: Integral b => b -> BackendQueryStats BigQuery -> BackendQueryStats BigQuery #

Show (BackendSchemaField BigQuery) # 
Instance details

Methods

showsPrec :: Int -> BackendSchemaField BigQuery -> ShowS #

show :: BackendSchemaField BigQuery -> String #

showList :: [BackendSchemaField BigQuery] -> ShowS #

Show (BackendQueryStats BigQuery) # 
Instance details

Methods

showsPrec :: Int -> BackendQueryStats BigQuery -> ShowS #

show :: BackendQueryStats BigQuery -> String #

showList :: [BackendQueryStats BigQuery] -> ShowS #

Eq (BackendSchemaField BigQuery) # 
Instance details

Methods

(==) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool #

(/=) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool #

Eq (BackendQueryStats BigQuery) # 
Instance details

Methods

(==) :: BackendQueryStats BigQuery -> BackendQueryStats BigQuery -> Bool #

(/=) :: BackendQueryStats BigQuery -> BackendQueryStats BigQuery -> Bool #