Skip to content

Instantly share code, notes, and snippets.

@asereda-gs
asereda-gs / CalciteConcurrentTest.java
Last active June 14, 2019 17:52
Using calcite connection concurrently
package org.apache.calcite.test;
import org.apache.calcite.adapter.jdbc.JdbcSchema;
import org.apache.calcite.jdbc.CalciteConnection;
import org.apache.calcite.schema.SchemaPlus;
import org.apache.commons.dbcp2.BasicDataSource;
import com.google.common.util.concurrent.MoreExecutors;
@asereda-gs
asereda-gs / CalciteOverheadTest.java
Last active January 30, 2022 01:35
CalciteOverheadTest
import org.apache.calcite.adapter.jdbc.JdbcSchema;
import org.apache.calcite.jdbc.CalciteConnection;
import org.apache.calcite.runtime.Hook;
import org.apache.calcite.schema.Schema;
import org.apache.calcite.schema.SchemaPlus;
import org.apache.commons.dbcp2.BasicDataSource;
import com.google.common.collect.ArrayListMultimap;
import com.google.common.collect.Multimap;
package sample;
import org.junit.Test;
import rx.Observable;
import rx.Scheduler;
import rx.schedulers.Schedulers;
import java.util.Arrays;
import java.util.HashSet;
import java.util.List;