The Kite connector is a READONLY connector that allows querying data stored in Kite. The schema and table created in Presto is in memory only and will be removed after system restart. Data in kite will keep the same after system reboot. Since Kite is a READ ONLY connector, INSERT, UPDATE, DELETE is not supported.

The connector is compatible with presto 0.280 or above.

1. Install Java 11, Maven

2. Compile kite-client-sdk and install to Maven

% git clone [email protected]:vderic/kite-client-sdk.git
% cd kite-client-sdk/java
% mvn clean install

3. Compile kite connector

% cd presto-kite
% ./mvnw clean package -DskipTests

4. Unzip kite connector zip file presto-kite/target/presto-kite-VERSION.zip and copy all jar files to $PRESTO_HOME/plugin/kite directory

To configure the kite connector, create a catalog properties file etc/catalog/kite.properties with the following contents:

connector.name=kite
kite.splits-per-node=3

You can have as many catalogs as you need, so if you have additional Kite clusters, simply add another propoerties file to etc/catalog with a different name (making sure it ends in .properties). For example, if you name the property file dev.properties, Presto will create a catalog named dev using configured connector.

The following configuration properties is available:

Since Kite supports READ ONLY operation, data will be ignored with CREATE TABLE SQL CREATE TABLE NEWFOO AS SELECT * FROM FOO.
You can create table without data by the SQL CREATE TABLE NEWFOO AS SELECT * FROM FOO WITH NO DATA.

To create table,

presto> CREATE TABLE kite.default.lineitem ( L_ORDERKEY    BIGINT,
                             L_PARTKEY     BIGINT,
                             L_SUPPKEY     BIGINT,
                             L_LINENUMBER  BIGINT,
                             L_QUANTITY    DOUBLE,
                             L_EXTENDEDPRICE  DOUBLE,
                             L_DISCOUNT    DOUBLE,
                             L_TAX         DOUBLE,
                             L_RETURNFLAG  VARCHAR(1),
                             L_LINESTATUS  VARCHAR(1),
                             L_SHIPDATE    DATE,
                             L_COMMITDATE  DATE,
                             L_RECEIPTDATE DATE,
                             L_SHIPINSTRUCT VARCHAR(25),
                             L_SHIPMODE     VARCHAR(10),
                             L_COMMENT      VARCHAR(44))
WITH (format='csv', location='kite://localhost:7878/test_tpch/csv/lineitem*');