diff --git a/src/main/java/io/kubesql/presto/kube/table/KubeNodeTable.java b/src/main/java/io/kubesql/presto/kube/table/KubeNodeTable.java index 2b5f275..50fcde4 100644 --- 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(Nodeunschedulable, BooleanType.BOOLEAN) { + @Override + public Object getData(V1Node v1Node) { + return v1Node.getSpec().getUnschedulable(); + } + }); put(NodeArchitecture, new KubeColumn(NodeArchitecture, VarcharType.createUnboundedVarcharType()) { @Override public Object getData(V1Node v1Node) {