Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2589#discussion_r207699730
--- 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;
-
[email protected]
-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
+ */
[email protected]
[email protected]
+public interface ScanUnit<T> extends Serializable, Writable {
--- End diff --
fixed
---
