Class ElasticsearchSchema

java.lang.Object
org.apache.calcite.schema.impl.AbstractSchema
org.apache.calcite.adapter.elasticsearch.ElasticsearchSchema
All Implemented Interfaces:
Schema

public class ElasticsearchSchema extends AbstractSchema
Each table in the schema is an ELASTICSEARCH index.
  • Constructor Details

    • ElasticsearchSchema

      public ElasticsearchSchema(org.elasticsearch.client.RestClient client, com.fasterxml.jackson.databind.ObjectMapper mapper, String index)
      Allows schema to be instantiated from existing elastic search client.
      Parameters:
      client - existing client instance
      mapper - mapper for JSON (de)serialization
      index - name of ES index
  • Method Details