Package com.hazelcast.jet.pulsar.sql

Class PulsarSqlConnector

java.lang.Object
com.hazelcast.jet.pulsar.sql.PulsarSqlConnector
All Implemented Interfaces:
com.hazelcast.jet.sql.impl.connector.SqlConnector
public class PulsarSqlConnector extends Object implements com.hazelcast.jet.sql.impl.connector.SqlConnector

  • Nested Class Summary

    Nested classes/interfaces inherited from interface com.hazelcast.jet.sql.impl.connector.SqlConnector

    com.hazelcast.jet.sql.impl.connector.SqlConnector.DagBuildContext, com.hazelcast.jet.sql.impl.connector.SqlConnector.SqlExternalResource, com.hazelcast.jet.sql.impl.connector.SqlConnector.VertexWithInputConfig

  • Field Summary

    Fields inherited from interface com.hazelcast.jet.sql.impl.connector.SqlConnector

    AVRO_FORMAT, COMPACT_FORMAT, CSV_FORMAT, JAVA_FORMAT, JSON_FLAT_FORMAT, OPTION_FORMAT, OPTION_KEY_AVRO_RECORD_NAME, OPTION_KEY_AVRO_SCHEMA, OPTION_KEY_CLASS, OPTION_KEY_CLASS_ID, OPTION_KEY_CLASS_VERSION, OPTION_KEY_COMPACT_TYPE_NAME, OPTION_KEY_FACTORY_ID, OPTION_KEY_FORMAT, OPTION_PREFERRED_LOCAL_PARALLELISM, OPTION_TYPE_AVRO_SCHEMA, OPTION_TYPE_COMPACT_TYPE_NAME, OPTION_TYPE_JAVA_CLASS, OPTION_TYPE_PORTABLE_CLASS_ID, OPTION_TYPE_PORTABLE_CLASS_VERSION, OPTION_TYPE_PORTABLE_FACTORY_ID, OPTION_VALUE_AVRO_RECORD_NAME, OPTION_VALUE_AVRO_SCHEMA, OPTION_VALUE_CLASS, OPTION_VALUE_CLASS_ID, OPTION_VALUE_CLASS_VERSION, OPTION_VALUE_COMPACT_TYPE_NAME, OPTION_VALUE_FACTORY_ID, OPTION_VALUE_FORMAT, PARQUET_FORMAT, PORTABLE_FORMAT

  • Constructor Summary

    Constructors
    Constructor
    Description
    PulsarSqlConnector()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    com.hazelcast.sql.impl.schema.Table
    createTable(com.hazelcast.spi.impl.NodeEngine nodeEngine, String schemaName, String mappingName, com.hazelcast.jet.sql.impl.connector.SqlConnector.SqlExternalResource externalResource, List<com.hazelcast.sql.impl.schema.MappingField> resolvedFields)
     
    String
    defaultObjectType()
     
    Vertex
    fullScanReader(com.hazelcast.jet.sql.impl.connector.SqlConnector.DagBuildContext context, com.hazelcast.jet.sql.impl.connector.HazelcastRexNode predicate, List<com.hazelcast.jet.sql.impl.connector.HazelcastRexNode> projection, List<Map<String,com.hazelcast.sql.impl.expression.Expression<?>>> partitionPruningCandidates, FunctionEx<com.hazelcast.sql.impl.expression.ExpressionEvalContext,EventTimePolicy<com.hazelcast.sql.impl.row.JetSqlRow>> eventTimePolicyProvider)
     
    com.hazelcast.jet.sql.impl.connector.SqlConnector.VertexWithInputConfig
    insertProcessor(com.hazelcast.jet.sql.impl.connector.SqlConnector.DagBuildContext context)
     
    List<com.hazelcast.sql.impl.schema.MappingField>
    resolveAndValidateFields(com.hazelcast.spi.impl.NodeEngine nodeEngine, com.hazelcast.jet.sql.impl.connector.SqlConnector.SqlExternalResource externalResource, List<com.hazelcast.sql.impl.schema.MappingField> userFields)
     
    Vertex
    sinkProcessor(com.hazelcast.jet.sql.impl.connector.SqlConnector.DagBuildContext context)
     
    String
    typeName()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface com.hazelcast.jet.sql.impl.connector.SqlConnector

    deleteProcessor, dmlSupportsPredicates, getPrimaryKey, isNestedLoopReaderSupported, nestedLoopReader, nonSensitiveConnectorOptions, permissionsForResolve, supportsExpression, updateProcessor

  • Constructor Details

    • PulsarSqlConnector

      public PulsarSqlConnector()

  • Method Details

    • typeName

      public String typeName()
      Specified by:
      typeName in interface com.hazelcast.jet.sql.impl.connector.SqlConnector

    • defaultObjectType

      @Nonnull public String defaultObjectType()
      Specified by:
      defaultObjectType in interface com.hazelcast.jet.sql.impl.connector.SqlConnector

    • resolveAndValidateFields

      @Nonnull public List<com.hazelcast.sql.impl.schema.MappingField> resolveAndValidateFields(@Nonnull com.hazelcast.spi.impl.NodeEngine nodeEngine, @Nonnull com.hazelcast.jet.sql.impl.connector.SqlConnector.SqlExternalResource externalResource, @Nonnull List<com.hazelcast.sql.impl.schema.MappingField> userFields)
      Specified by:
      resolveAndValidateFields in interface com.hazelcast.jet.sql.impl.connector.SqlConnector

    • createTable

      @Nonnull public com.hazelcast.sql.impl.schema.Table createTable(@Nonnull com.hazelcast.spi.impl.NodeEngine nodeEngine, @Nonnull String schemaName, @Nonnull String mappingName, @Nonnull com.hazelcast.jet.sql.impl.connector.SqlConnector.SqlExternalResource externalResource, @Nonnull List<com.hazelcast.sql.impl.schema.MappingField> resolvedFields)
      Specified by:
      createTable in interface com.hazelcast.jet.sql.impl.connector.SqlConnector

    • fullScanReader

      @Nonnull public Vertex fullScanReader(@Nonnull com.hazelcast.jet.sql.impl.connector.SqlConnector.DagBuildContext context, @Nullable com.hazelcast.jet.sql.impl.connector.HazelcastRexNode predicate, @Nonnull List<com.hazelcast.jet.sql.impl.connector.HazelcastRexNode> projection, @Nullable List<Map<String,com.hazelcast.sql.impl.expression.Expression<?>>> partitionPruningCandidates, @Nullable FunctionEx<com.hazelcast.sql.impl.expression.ExpressionEvalContext,EventTimePolicy<com.hazelcast.sql.impl.row.JetSqlRow>> eventTimePolicyProvider)
      Specified by:
      fullScanReader in interface com.hazelcast.jet.sql.impl.connector.SqlConnector

    • insertProcessor

      @Nonnull public com.hazelcast.jet.sql.impl.connector.SqlConnector.VertexWithInputConfig insertProcessor(@Nonnull com.hazelcast.jet.sql.impl.connector.SqlConnector.DagBuildContext context)
      Specified by:
      insertProcessor in interface com.hazelcast.jet.sql.impl.connector.SqlConnector

    • sinkProcessor

      @Nonnull public Vertex sinkProcessor(@Nonnull com.hazelcast.jet.sql.impl.connector.SqlConnector.DagBuildContext context)
      Specified by:
      sinkProcessor in interface com.hazelcast.jet.sql.impl.connector.SqlConnector