support node unschedulable

Signed-off-by: xuxinkun <xuxinkun@gmail.com>
xuxinkun · May 23, 2020 · c3129d2 · c3129d2
1 parent 6e1142a
commit c3129d2
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/main/java/io/kubesql/presto/kube/table/KubeNodeTable.java b/src/main/java/io/kubesql/presto/kube/table/KubeNodeTable.java
@@ -28,6 +28,7 @@ public class KubeNodeTable extends KubeResTable {
     public static String NodeLabelsPrefix = "labels.";
     public static String NodeCreationTimestamp = "creationtimestamp";
     public static String NodeDeletionTimestamp = "deletiontimstamp";
+    public static String Nodeunschedulable = "unschedulable";
     //    public static String NodeAddressesPrexif = "addresses";
     public static String NodeAllocatablePrefix = "allocatable.";
     public static String NodeCapacityPrefix = "capacity.";
@@ -82,6 +83,12 @@ public Object getData(V1Node v1Node) {
                     return v1Node.getStatus().getDaemonEndpoints().getKubeletEndpoint().getPort();
                 }
             });
+            put(Nodeunschedulable, new KubeColumn<V1Node>(Nodeunschedulable, BooleanType.BOOLEAN) {
+                @Override
+                public Object getData(V1Node v1Node) {
+                    return v1Node.getSpec().getUnschedulable();
+                }
+            });
             put(NodeArchitecture, new KubeColumn<V1Node>(NodeArchitecture, VarcharType.createUnboundedVarcharType()) {
                 @Override
                 public Object getData(V1Node v1Node) {