Add table classes

.idea/inspectionProfiles/Project_Default.xml

@@ -2,5 +2,14 @@
   <profile version="1.0">
     <option name="myName" value="Project Default" />
     <inspection_tool class="PyAbstractClassInspection" enabled="false" level="WEAK WARNING" enabled_by_default="false" />
+    <inspection_tool class="PyPackageRequirementsInspection" enabled="true" level="WARNING" enabled_by_default="true">
+      <option name="ignoredPackages">
+        <value>
+          <list size="1">
+            <item index="0" class="java.lang.String" itemvalue="azure" />
+          </list>
+        </value>
+      </option>
+    </inspection_tool>
   </profile>
 </component>

tables.py

@@ -0,0 +1,44 @@
+from typing import Sequence
+
+# noinspection PyProtectedMember
+from azure.kusto.data._response import KustoResponseDataSet
+from azure.kusto.data.request import KustoClient
+
+from query import Query
+
+
+class BaseTable:
+    client: KustoClient
+    database: str
+
+    def __init__(self, client: KustoClient, database: str) -> None:
+        self.client = client
+        self.database = database
+
+    def execute(self, query: Query) -> KustoResponseDataSet:
+        raise NotImplementedError()
+
+
+class SingleTable(BaseTable):
+    table: str
+
+    def __init__(self, client: KustoClient, database: str, table: str) -> None:
+        super().__init__(client, database)
+        self.table = table
+
+    def execute(self, query: Query) -> KustoResponseDataSet:
+        return self.client.execute(self.database, self.table + query.compile_all())
+
+
+class UnionTable(BaseTable):
+    tables: Sequence[str]
+
+    def __init__(self, client: KustoClient, database: str, tables: Sequence[str]) -> None:
+        super().__init__(client, database)
+        self.tables = tables
+
+    def execute(self, query: Query) -> KustoResponseDataSet:
+        return self.client.execute(self.database, 'union {}{}'.format(
+            ', '.join(self.table),
+            query.compile_all()
+        ))