Package io.kestra.plugin.jdbc.pinot

Class Queries

java.lang.Object
io.kestra.core.models.tasks.Task
io.kestra.plugin.jdbc.AbstractJdbcBaseQuery
io.kestra.plugin.jdbc.AbstractJdbcQueries
io.kestra.plugin.jdbc.pinot.Queries
All Implemented Interfaces:
io.kestra.core.models.Plugin, io.kestra.core.models.PluginVersioning, io.kestra.core.models.tasks.RunnableTask<io.kestra.plugin.jdbc.AbstractJdbcQueries.MultiQueryOutput>, io.kestra.core.models.tasks.TaskInterface, io.kestra.core.models.WorkerJobLifecycle, io.kestra.plugin.jdbc.JdbcConnectionInterface, io.kestra.plugin.jdbc.JdbcQueriesInterface, io.kestra.plugin.jdbc.JdbcQueryInterface, io.kestra.plugin.jdbc.JdbcStatementInterface, PinotConnectionInterface
@Plugin(examples=@Example(full=true,code="id: pinot_queries\nnamespace: company.team\n\ntasks:\n - id: queries\n type: io.kestra.plugin.jdbc.pinot.Queries\n url: jdbc:pinot://localhost:9000\n username: \"{{ secret(\'PINOT_USERNAME\') }}\"\n password: \"{{ secret(\'PINOT_PASSWORD\') }}\"\n sql: |\n SELECT * FROM airlineStats WHERE __time >= 1672531200000;\n SELECT * FROM airlineStats LIMIT 1000;\n fetchType: FETCH\n"), metrics=@Metric(name="fetch.size",type="counter",unit="rows",description="The number of fetched rows.")) public class Queries extends io.kestra.plugin.jdbc.AbstractJdbcQueries implements PinotConnectionInterface

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.kestra.plugin.jdbc.AbstractJdbcQueries

    io.kestra.plugin.jdbc.AbstractJdbcQueries.AbstractJdbcQueriesBuilder<C extends io.kestra.plugin.jdbc.AbstractJdbcQueries,B extends io.kestra.plugin.jdbc.AbstractJdbcQueries.AbstractJdbcQueriesBuilder<C,B>>, io.kestra.plugin.jdbc.AbstractJdbcQueries.MultiQueryOutput

    Nested classes/interfaces inherited from class io.kestra.plugin.jdbc.AbstractJdbcBaseQuery

    io.kestra.plugin.jdbc.AbstractJdbcBaseQuery.AbstractJdbcBaseQueryBuilder<C extends io.kestra.plugin.jdbc.AbstractJdbcBaseQuery,B extends io.kestra.plugin.jdbc.AbstractJdbcBaseQuery.AbstractJdbcBaseQueryBuilder<C,B>>, io.kestra.plugin.jdbc.AbstractJdbcBaseQuery.Output

    Nested classes/interfaces inherited from class io.kestra.core.models.tasks.Task

    io.kestra.core.models.tasks.Task.TaskBuilder<C extends io.kestra.core.models.tasks.Task,B extends io.kestra.core.models.tasks.Task.TaskBuilder<C,B>>

  • Field Summary

    Fields inherited from class io.kestra.plugin.jdbc.AbstractJdbcQueries

    transaction

    Fields inherited from class io.kestra.plugin.jdbc.AbstractJdbcBaseQuery

    additionalVars, afterSQL, fetchSize, fetchType, outputFiles, parameters, sql

    Fields inherited from class io.kestra.core.models.tasks.Task

    disabled, id, retry, timeout, type, version

    Fields inherited from interface io.kestra.core.models.PluginVersioning

    DESCRIPTION, TITLE

  • Constructor Summary

    Constructors
    Constructor
    Description
    Queries()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected PreparedStatement
    createPreparedStatement(Connection conn, String preparedSql)
     
    protected io.kestra.plugin.jdbc.AbstractCellConverter
    getCellConverter(ZoneId zoneId)
     
    protected Integer
    getFetchSize(io.kestra.core.runners.RunContext runContext)
     
    void
    registerDriver()
     

    Methods inherited from class io.kestra.plugin.jdbc.AbstractJdbcQueries

    beforeExecute, canEqual, equals, fetch, getTransaction, hashCode, kill, run, toString

    Methods inherited from class io.kestra.plugin.jdbc.AbstractJdbcBaseQuery

    createStatement, fetchResult, fetchResults, fetchToFile, getAfterSQL, getConnectionPooling, getConnectionPoolSize, getFetchSize, getFetchType, getOutputFiles, getParameters, getPassword, getSql, getTimeZoneId, getUrl, getUsername, isFetch, isFetchOne, isStore, kill, kill, mapResultSetToMap, prepareStatement, renderFetchType, supportsMultiStatements, tags, upsertAsset

    Methods inherited from class io.kestra.core.models.tasks.Task

    findById, findById, getAssets, getDescription, getDisabled, getId, getLogLevel, getRetry, getRunIf, getTaskCache, getTimeout, getType, getVersion, getWorkerGroup, isAllowFailure, isAllowWarning, isFlowable, isLogToFile, isSendToWorkerTask

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

    Methods inherited from interface io.kestra.plugin.jdbc.JdbcConnectionInterface

    connection, connectionProperties, connectionProperties, getConnectionPooling, getConnectionPoolSize, getPassword, getUrl, getUsername, usesConnectionPool, validateUrl

    Methods inherited from interface io.kestra.plugin.jdbc.JdbcStatementInterface

    zoneId

    Methods inherited from interface io.kestra.plugin.jdbc.pinot.PinotConnectionInterface

    getScheme

    Methods inherited from interface io.kestra.core.models.WorkerJobLifecycle

    stop

  • Constructor Details

    • Queries

      public Queries()

  • Method Details

    • getCellConverter

      protected io.kestra.plugin.jdbc.AbstractCellConverter getCellConverter(ZoneId zoneId)
      Specified by:
      getCellConverter in class io.kestra.plugin.jdbc.AbstractJdbcBaseQuery

    • registerDriver

      public void registerDriver() throws SQLException
      Specified by:
      registerDriver in interface io.kestra.plugin.jdbc.JdbcConnectionInterface
      Throws:
      SQLException

    • createPreparedStatement

      protected PreparedStatement createPreparedStatement(Connection conn, String preparedSql) throws SQLException
      Overrides:
      createPreparedStatement in class io.kestra.plugin.jdbc.AbstractJdbcBaseQuery
      Throws:
      SQLException

    • getFetchSize

      protected Integer getFetchSize(io.kestra.core.runners.RunContext runContext) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      getFetchSize in class io.kestra.plugin.jdbc.AbstractJdbcBaseQuery
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException