Class CassandraTable

    • Field Detail

      • keyFields

        Pair<java.util.List<java.lang.String>,​java.util.List<java.lang.String>> keyFields
      • columnFamily

        private final java.lang.String columnFamily
      • view

        private final boolean view
    • Constructor Detail

      • CassandraTable

        public CassandraTable​(CassandraSchema schema,
                              java.lang.String columnFamily,
                              boolean view)
      • CassandraTable

        public CassandraTable​(CassandraSchema schema,
                              java.lang.String columnFamily)
    • Method Detail

      • toString

        public java.lang.String toString()
        toString in class java.lang.Object
      • getRowType

        public RelDataType getRowType​(RelDataTypeFactory typeFactory)
        Description copied from interface: Table
        Returns this table's row type.

        This is a struct type whose fields describe the names and types of the columns in this table.

        The implementer must use the type factory provided. This ensures that the type is converted into a canonical form; other equal types in the same query will use the same object.

        Specified by:
        getRowType in interface Table
        typeFactory - Type factory with which to create the type
        Row type
      • getKeyFields

        public Pair<java.util.List<java.lang.String>,​java.util.List<java.lang.String>> getKeyFields()
      • query

        public Enumerable<java.lang.Object> query​(com.datastax.driver.core.Session session)
      • query

        public Enumerable<java.lang.Object> query​(com.datastax.driver.core.Session session,
                                                  java.util.List<java.util.Map.Entry<java.lang.String,​java.lang.Class>> fields,
                                                  java.util.List<java.util.Map.Entry<java.lang.String,​java.lang.String>> selectFields,
                                                  java.util.List<java.lang.String> predicates,
                                                  java.util.List<java.lang.String> order,
                                                  java.lang.Integer offset,
                                                  java.lang.Integer fetch)
        Executes a CQL query on the underlying table.
        session - Cassandra session
        fields - List of fields to project
        predicates - A list of predicates which should be used in the query
        Enumerator of results