Github user ajithme commented on a diff in the pull request: https://github.com/apache/carbondata/pull/2589#discussion_r207699358 --- Diff: store/sdk/src/main/java/org/apache/carbondata/sdk/store/ScanUnit.java --- @@ -15,26 +15,27 @@ * limitations under the License. */ -package org.apache.carbondata.store.impl.rpc; +package org.apache.carbondata.sdk.store; -import org.apache.carbondata.common.annotations.InterfaceAudience; -import org.apache.carbondata.store.impl.rpc.model.BaseResponse; -import org.apache.carbondata.store.impl.rpc.model.LoadDataRequest; -import org.apache.carbondata.store.impl.rpc.model.QueryResponse; -import org.apache.carbondata.store.impl.rpc.model.Scan; -import org.apache.carbondata.store.impl.rpc.model.ShutdownRequest; -import org.apache.carbondata.store.impl.rpc.model.ShutdownResponse; - -import org.apache.hadoop.ipc.VersionedProtocol; - -@InterfaceAudience.Internal -public interface StoreService extends VersionedProtocol { - - long versionID = 1L; +import java.io.Serializable; - BaseResponse loadData(LoadDataRequest request); - - QueryResponse query(Scan scan); +import org.apache.carbondata.common.annotations.InterfaceAudience; +import org.apache.carbondata.common.annotations.InterfaceStability; +import org.apache.carbondata.core.metadata.schema.table.Writable; - ShutdownResponse shutdown(ShutdownRequest request); +/** + * An unit for the scanner in Carbon Store + */ +@InterfaceAudience.User +@InterfaceStability.Unstable +public interface ScanUnit<T> extends Serializable, Writable { --- End diff -- can remove Generics
---