How to enable partitioning and have the "Where" clause working in a Custom Trino plugin

[nisha-tamta]

I have built a Custom Trino Plugin which sources data from XML files stored in file system.

The SELECT query works fine, now we need to make WHEREclause work for this. Which, as per my knowledge means, we need to split data according to the condition for partitioning provided.

ChatGPT suggested "I need to define partitioning columns for your table and implement partition pruning in your plugin."

Can you all please help me with this. Please refer nelow code for SplitManager Implementation:

public ConnectorSplitSource getSplits(ConnectorTransactionHandle transaction, ConnectorSession session,
        ConnectorTableHandle connectorTableHandle, DynamicFilter dynamicFilter, Constraint constraint) {
            ECFTrinoTableHandle tableHandle = (ECFTrinoTableHandle) connectorTableHandle;
            TupleDomain<ECFTrinoColumnHandle> predicate = tableHandle.getPartitionPredicates();
            List<ConnectorSplit> splits = new ArrayList<>();

          // Get the partitioning columns for the table
          List<String> partitionColumns = new ArrayList<>();
          partitionColumns.add("daterange");

          // Add code here to get the splits.


           Collection<Domain> domains=   predicate.getDomains().get().values();
           if (domains.size() != 0) {
            Domain dd = domains.stream().findFirst().get();
            dd.getValues().getRanges().getSpan().getLowValue();
           }
        }